| D | pool.py | 97 def worker(inqueue, outqueue, initializer=None, initargs=(), maxtasks=None, argument
103 get = inqueue.get
104 if hasattr(inqueue, '_writer'):
105 inqueue._writer.close()
312 def _repopulate_pool_static(ctx, Process, processes, pool, inqueue, 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
513 cls._maintain_pool(ctx, Process, processes, pool, inqueue,
[all …]
|