Method get

imperative/python/megengine/data/tools/_queue.py:158–168

(self, block=True, timeout=None)

            raise queue.Full

    def get(self, block=True, timeout=None):
        if self.client is None:
            self.client = plasma.connect(self.socket_name)
        object_id = self.queue.get(block, timeout)
        if not self.client.contains(object_id):
            exc_type = "ObjectIDGetError"
            data = (self.get_error(exc_type),)
        else:
            data = self.client.get(object_id)
            self.client.delete([object_id])
        return data

    def qsize(self):
        return self.queue.qsize()