homepage

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