(self)
| 37 | return |
| 38 | self._stop_event.clear() |
| 39 | self._thread = threading.Thread(target=self._run_loop, name="glm-desk-scheduler", daemon=True) |
| 40 | self._thread.start() |
| 41 | threading.Thread(target=self.check_cached_accounts_once, name="glm-desk-account-check", daemon=True).start() |
| 42 | self.runtime_logs.log_system_event( |
| 43 | stage="scheduler", |
| 44 | status="started", |
| 45 | message="调度器已启动", |
| 46 | ) |
| 47 | |
| 48 | def stop(self) -> None: |
| 49 | self._stop_event.set() |
| 50 | if self._thread and self._thread.is_alive(): |
| 51 | self._thread.join(timeout=2) |
| 52 | self.runtime_logs.log_system_event( |
| 53 | stage="scheduler", |
| 54 | status="stopped", |
| 55 | message="调度器已停止", |
no test coverage detected