code: def get(self, block=True, timeout=None):
          
          try:
              item = super().get(block, timeout)
              self._getsocket.recv(1)
              return item
          except queue.Empty:
              raise queue.Empty
docs: get.