Clear queu tasks. fix #997

This commit is contained in:
Ruud
2012-11-02 17:28:39 +01:00
parent 2215c000b7
commit 51f9b5c673

View File

@@ -205,6 +205,10 @@ class Event(object):
handler, memoize, timeout = self.handlers[h_]
if return_on_result and got_results:
if not self.asynchronous:
self.queue.task_done()
continue
if order_lock: