Searched refs:task_handler (Results 1 – 1 of 1) sorted by relevance
477 def _help_stuff_finish(inqueue, task_handler, size): argument481 while task_handler.is_alive() and inqueue._reader.poll():487 worker_handler, task_handler, result_handler, cache): argument492 task_handler._state = TERMINATE495 cls._help_stuff_finish(inqueue, task_handler, len(pool))516 if threading.current_thread() is not task_handler:517 task_handler.join(1e100)736 def _help_stuff_finish(inqueue, task_handler, size): argument