Searched refs:outqueue (Results 1 – 2 of 2) sorted by relevance
| /external/python/cpython3/Lib/multiprocessing/ |
| D | pool.py | 97 def worker(inqueue, outqueue, initializer=None, initargs=(), maxtasks=None, argument
102 put = outqueue.put
106 outqueue._reader.close()
313 outqueue, initializer, initargs, argument
320 args=(inqueue, outqueue,
331 def _maintain_pool(ctx, Process, processes, pool, inqueue, outqueue, argument
338 inqueue, outqueue, initializer,
505 pool, inqueue, outqueue, initializer, initargs, argument
514 outqueue, initializer, initargs,
525 def _handle_tasks(taskqueue, put, outqueue, pool, cache): argument
[all …]
|
| /external/python/cpython2/Lib/multiprocessing/ |
| D | pool.py | 88 def worker(inqueue, outqueue, initializer=None, initargs=(), maxtasks=None): argument
90 put = outqueue.put
94 outqueue._reader.close()
335 def _handle_tasks(taskqueue, put, outqueue, pool, cache): argument
375 outqueue.put(None)
387 def _handle_results(outqueue, get, cache): argument
430 if hasattr(outqueue, '_reader'):
437 if not outqueue._reader.poll():
491 def _terminate_pool(cls, taskqueue, inqueue, outqueue, pool, argument
505 outqueue.put(None) # sentinel
|