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
559             outqueue.put(None)
571     def _handle_results(outqueue, get, cache):  argument
614         if hasattr(outqueue, '_reader'):
621                     if not outqueue._reader.poll():
678     def _terminate_pool(cls, taskqueue, inqueue, outqueue, pool, change_notifier,  argument
700         outqueue.put(None)                  # sentinel