Searched refs:inqueue (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 91 get = inqueue.get 92 if hasattr(inqueue, '_writer'): 93 inqueue._writer.close() 477 def _help_stuff_finish(inqueue, task_handler, size): argument 480 inqueue._rlock.acquire() 481 while task_handler.is_alive() and inqueue._reader.poll(): 482 inqueue._reader.recv() 486 def _terminate_pool(cls, taskqueue, inqueue, outqueue, pool, argument 495 cls._help_stuff_finish(inqueue, task_handler, len(pool)) [all …]
|