Lines Matching refs:inqueue
88 def worker(inqueue, outqueue, initializer=None, initargs=(), maxtasks=None): argument
91 get = inqueue.get
92 if hasattr(inqueue, '_writer'):
93 inqueue._writer.close()
482 def _help_stuff_finish(inqueue, task_handler, size): argument
485 inqueue._rlock.acquire()
486 while task_handler.is_alive() and inqueue._reader.poll():
487 inqueue._reader.recv()
491 def _terminate_pool(cls, taskqueue, inqueue, outqueue, pool, argument
500 cls._help_stuff_finish(inqueue, task_handler, len(pool))
741 def _help_stuff_finish(inqueue, task_handler, size): argument
743 inqueue.not_empty.acquire()
745 inqueue.queue.clear()
746 inqueue.queue.extend([None] * size)
747 inqueue.not_empty.notify_all()
749 inqueue.not_empty.release()