queue: fix issue #45. join() should not block on empty JoinableQueue(). Patch by Dmitry Chechik.

dec3a5df · Denis Bilenko · 3d8f801e · dec3a5df
Commit dec3a5df authored Sep 23, 2010 by Denis Bilenko
Hide whitespace changes
Inline Side-by-side

Showing with 1 addition and 0 deletions

gevent/queue.py gevent/queue.py +1 -0

No files found.
--- a/gevent/queue.py
+++ b/gevent/queue.py
@@ -277,6 +277,7 @@ class JoinableQueue(Queue):
        Queue.__init__(self, maxsize)
        self.unfinished_tasks = 0
        self._cond = Event()
+        self._cond.set()

    def _format(self):
        result = Queue._format(self)