[issue15983] multiprocessing JoinableQueue's join function with timeout
Tumer Topcu
report at bugs.python.org
Sun Jun 22 22:30:53 CEST 2014
Tumer Topcu added the comment:
Another option is instead of adding a timeout parameter, a new function to check if everything is done. Like:
def all_tasks_finished(self)
return self._unfinished_tasks._semlock._is_zero()
Which can then be utilized exactly shown in the above noted stackoverflow answer. This way it will be consistent with queue.py
----------
_______________________________________
Python tracker <report at bugs.python.org>
<http://bugs.python.org/issue15983>
_______________________________________
More information about the Python-bugs-list
mailing list