(self)
| 112 | self.terminate() |
| 113 | |
| 114 | def join(self) -> None: |
| 115 | try: |
| 116 | while self._pworking: |
| 117 | if not self._join_one(): |
| 118 | time.sleep(0.02) |
| 119 | finally: |
| 120 | # shutdown other child processes on failure |
| 121 | self.terminate() |
| 122 | |
| 123 | def terminate(self) -> None: |
| 124 | for tid in list(self._precvs): |