Always release lock
This commit is contained in:
@@ -235,12 +235,12 @@ class Event(object):
|
||||
self.error_handler(sys.exc_info())
|
||||
finally:
|
||||
|
||||
if not self.asynchronous:
|
||||
self.queue.task_done()
|
||||
|
||||
if order_lock:
|
||||
order_lock.release()
|
||||
|
||||
if not self.asynchronous:
|
||||
self.queue.task_done()
|
||||
|
||||
if self.queue.empty():
|
||||
raise Empty
|
||||
|
||||
|
||||
Reference in New Issue
Block a user