Lines Matching refs:inqueue
93 def worker(inqueue, outqueue, initializer=None, initargs=(), maxtasks=None, argument
99 get = inqueue.get
100 if hasattr(inqueue, '_writer'):
101 inqueue._writer.close()
563 def _help_stuff_finish(inqueue, task_handler, size): argument
566 inqueue._rlock.acquire()
567 while task_handler.is_alive() and inqueue._reader.poll():
568 inqueue._reader.recv()
572 def _terminate_pool(cls, taskqueue, inqueue, outqueue, pool, argument
581 cls._help_stuff_finish(inqueue, task_handler, len(pool))
811 def _help_stuff_finish(inqueue, task_handler, size): argument
815 inqueue.get(block=False)
819 inqueue.put(None)