task_done called to many times, fix

2012-01-23 23:41:54 +01:00
parent 7dbba20618
commit 20c54b5301
1 changed files with 4 additions and 1 deletions
@@ -193,7 +193,10 @@ class Event(object):
                        self.lock.release()

                    if not self.asynchronous:
-                        self.queue.task_done()
+                        try:
+                            self.queue.task_done()
+                        except ValueError:
+                            pass

                    if self.queue.empty():
                        raise Queue.Empty