(self)
| 789 | self._spawn_process() |
| 790 | |
| 791 | def _launch_processes(self): |
| 792 | # https://github.com/python/cpython/issues/90622 |
| 793 | assert not self._executor_manager_thread, ( |
| 794 | 'Processes cannot be fork()ed after the thread has started, ' |
| 795 | 'deadlock in the child processes could result.') |
| 796 | for _ in range(len(self._processes), self._max_workers): |
| 797 | self._spawn_process() |
| 798 | |
| 799 | def _spawn_process(self): |
| 800 | p = self._mp_context.Process( |
no test coverage detected