(self)
| 101 | os._exit(1) |
| 102 | |
| 103 | def stop(self) -> None: |
| 104 | self.__is_shutdown.set() |
| 105 | if self.running: |
| 106 | self.__is_stopped.wait() |
| 107 | self.join(THREAD_TIMEOUT_MAX) |
| 108 | self.running = False |
| 109 | |
| 110 | def ensure_started(self) -> None: |
| 111 | if not self.running and not self.is_alive(): |