Lines Matching refs:executor
268 def __init__(self, executor): argument
273 self.thread_wakeup = executor._executor_manager_thread_wakeup
274 self.shutdown_lock = executor._shutdown_lock
290 self.executor_reference = weakref.ref(executor, weakref_cb)
293 self.processes = executor._processes
297 self.call_queue = executor._call_queue
300 self.result_queue = executor._result_queue
303 self.work_ids_queue = executor._work_ids
307 self.pending_work_items = executor._pending_work_items
329 executor = self.executor_reference()
330 if executor is not None:
331 executor._idle_worker_semaphore.release()
332 del executor
422 executor = self.executor_reference()
427 return (_global_shutdown or executor is None
428 or executor._shutdown_thread)
436 executor = self.executor_reference()
437 if executor is not None:
438 executor._broken = ('A child process terminated '
441 executor._shutdown_thread = True
442 executor = None
471 executor = self.executor_reference()
472 if executor is not None:
473 executor._shutdown_thread = True
475 if executor._cancel_pending_futures:
492 executor._cancel_pending_futures = False