[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