Searched refs:outqueue (Results 1 – 1 of 1) sorted by relevance
/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() 333 def _handle_tasks(taskqueue, put, outqueue, pool, cache): argument 372 outqueue.put(None) 384 def _handle_results(outqueue, get, cache): argument 425 if hasattr(outqueue, '_reader'): 432 if not outqueue._reader.poll(): 486 def _terminate_pool(cls, taskqueue, inqueue, outqueue, pool, argument 500 outqueue.put(None) # sentinel
|