Clean up any exited workers and start replacements for them.
(ctx, Process, processes, pool, inqueue, outqueue,
initializer, initargs, maxtasksperchild,
wrap_exception)
| 332 | |
| 333 | @staticmethod |
| 334 | def _maintain_pool(ctx, Process, processes, pool, inqueue, outqueue, |
| 335 | initializer, initargs, maxtasksperchild, |
| 336 | wrap_exception): |
| 337 | """Clean up any exited workers and start replacements for them. |
| 338 | """ |
| 339 | if Pool._join_exited_workers(pool): |
| 340 | Pool._repopulate_pool_static(ctx, Process, processes, pool, |
| 341 | inqueue, outqueue, initializer, |
| 342 | initargs, maxtasksperchild, |
| 343 | wrap_exception) |
| 344 | |
| 345 | def _setup_queues(self): |
| 346 | self._inqueue = self._ctx.SimpleQueue() |
no test coverage detected