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