Lines Matching refs:processes
103 # Controls how many more calls than processes will be queued in the call queue.
104 # A smaller number will mean that processes spend more time idle waiting for
110 # On Windows, WaitForMultipleObjects is used to wait for processes to finish.
275 """Manages the communication between this process and the worker processes.
311 self.processes = executor._processes
349 p = self.processes.pop(result_item.exit_pid)
403 # that all worker processes are still running, or for a wake up
411 worker_sentinels = [p.sentinel for p in list(self.processes.values())]
440 p = self.processes.pop(result_item)
442 if not self.processes:
497 for p in self.processes.values():
526 # on running processes over and over.
550 # If .join() is not called on the created processes then
552 for p in self.processes.values():
557 return sum(p.is_alive() for p in self.processes.values())
621 max_workers: The maximum number of processes that can be used to
623 worker processes will be created as the machine has processors.
627 initializer: A callable used to initialize worker processes.
684 # Map of pids to processes
707 # Make the call queue slightly larger than the number of processes to
708 # prevent the worker processes from idling. But don't make it too big
716 # Killed worker processes can produce spurious "broken pipe"
718 # processes anyway, so silence the tracebacks.
725 # Start the processes so that their sentinels are known.
752 'deadlock in the child processes could result.')