Signed-off-by: Mike O'Connor <stew@vireo.org>
assert( not self.next_in_line )
self.next_in_line = next
assert( not self.next_in_line )
self.next_in_line = next
- self.next_lock.notify()
+ self.next_lock.notifyAll()
self.next_lock.release()
def dequeue(self):
self.next_lock.release()
def dequeue(self):
result = self.next_in_line
self.next_in_line = None
result = self.next_in_line
self.next_in_line = None
- self.next_lock.notify()
+ self.next_lock.notifyAll()
self.next_lock.release()
if isinstance(result, EndOfChanges):
self.next_lock.release()
if isinstance(result, EndOfChanges):