def get(self):
        self.condition.acquire()
        try:
            while True:
                for queue in self.queues.values():
                    try:
                        ret = queue.popleft()
                        self.incomplete.append(ret)
                        return ret
                    except __HOLE__:
                        pass
                self.condition.wait()
        finally:
            self.condition.release()
dataset/ETHPy150Open openstack/gertty/gertty/sync.py/MultiQueue.get