def put(self, item, priority):
        added = False
        self.condition.acquire()
        try:
            if item not in self.queues[priority]:
                self.queues[priority].append(item)
                added = True
            self.condition.notify()
        finally:
            self.condition.release()
        return added
dataset/ETHPy150Open openstack/gertty/gertty/sync.py/MultiQueue.put/original