(self)
| 121 | self.terminate() |
| 122 | |
| 123 | def terminate(self) -> None: |
| 124 | for tid in list(self._precvs): |
| 125 | self._procs[tid].terminate() |
| 126 | self._result_funcs.pop(tid) |
| 127 | self._procs.pop(tid) |
| 128 | self._precvs.pop(tid) |
| 129 | self._pworking -= 1 |
| 130 | |
| 131 | def _join_one(self) -> bool: |
| 132 | joined_any = False |