diff --git a/gertty/sync.py b/gertty/sync.py index 7f26c1a..1735cd2 100644 --- a/gertty/sync.py +++ b/gertty/sync.py @@ -64,13 +64,16 @@ class MultiQueue(object): return count 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 def get(self): self.condition.acquire()