(self)
| 797 | self._spawn_process() |
| 798 | |
| 799 | def _spawn_process(self): |
| 800 | p = self._mp_context.Process( |
| 801 | target=_process_worker, |
| 802 | args=(self._call_queue, |
| 803 | self._result_queue, |
| 804 | self._initializer, |
| 805 | self._initargs, |
| 806 | self._max_tasks_per_child)) |
| 807 | p.start() |
| 808 | self._processes[p.pid] = p |
| 809 | |
| 810 | def submit(self, fn, /, *args, **kwargs): |
| 811 | with self._shutdown_lock: |
no test coverage detected