Searched refs:result_handler (Results 1 – 2 of 2) sorted by relevance
492 worker_handler, task_handler, result_handler, cache): argument502 assert result_handler.is_alive() or len(cache) == 0504 result_handler._state = TERMINATE525 if threading.current_thread() is not result_handler:526 result_handler.join(1e100)
573 worker_handler, task_handler, result_handler, cache): argument583 if (not result_handler.is_alive()) and (len(cache) != 0):587 result_handler._state = TERMINATE608 if threading.current_thread() is not result_handler:609 result_handler.join()