Commits

Denis Bilenko committed 539aefe

fix bug in JoinableQueue(0) unfinished_tasks counter was updated too late

Comments (0)

Files changed (1)

             result += ' tasks=%s _cond=%s' % (self.unfinished_tasks, self._cond)
         return result
 
-    def put(self, item, block=True, timeout=None):
-        Queue.put(self, item, block, timeout)
+    def _put(self, item):
+        Queue._put(self, item)
         self.unfinished_tasks += 1
         self._cond.clear()