Lines Matching refs:processes
77 # Code run by worker processes
183 def __init__(self, processes=None, initializer=None, initargs=(),
202 if processes is None:
203 processes = os.cpu_count() or 1
204 if processes < 1:
205 raise ValueError("Number of processes must be at least 1")
213 self._processes = processes
291 """Cleanup after any worker processes which have exited due to reaching
315 def _repopulate_pool_static(ctx, Process, processes, pool, inqueue,
318 """Bring the number of pool processes up to the specified number,
321 for i in range(processes - len(pool)):
334 def _maintain_pool(ctx, Process, processes, pool, inqueue, outqueue,
340 Pool._repopulate_pool_static(ctx, Process, processes, pool,
507 def _handle_workers(cls, cache, taskqueue, ctx, Process, processes,
516 cls._maintain_pool(ctx, Process, processes, pool, inqueue,
644 'pool objects cannot be passed between processes or pickled'
929 def __init__(self, processes=None, initializer=None, initargs=()):
930 Pool.__init__(self, processes, initializer, initargs)