fix(gpu): TaskHeartbeat 的 _stop 属性改名 _stop_event，避免覆盖 Thread._stop 方法

CI 单测报错 'Event' object is not callable：threading.Thread 内部存在 _stop() 方法（join/GC 时调用），子类用 self._stop = Event() 覆盖了它，线程回收时 TypeError。本地因时序差异未复现。
2026-09-19 14:50:26 +08:00
parent a8f1069cd2
commit 10294e9eb9
1 changed files with 4 additions and 4 deletions
@@ -315,20 +315,20 @@ class TaskHeartbeat(threading.Thread):
        super().__init__(daemon=True, name=f"hb-{task_id[:8]}")
        self.task_id = task_id
        self.interval = max(5.0, interval)
-        self._stop = threading.Event()
+        self._stop_event = threading.Event()

    def run(self) -> None:
        # 先立即发一次，再按间隔循环（首次心跳失败不影响主流程）
-        while not self._stop.is_set():
+        while not self._stop_event.is_set():
            try:
                if _register(self.task_id):
                    logger.debug("任务 %s 心跳已发送", self.task_id)
            except Exception as exc:  # noqa: BLE001
                logger.warning("任务 %s 心跳异常（忽略）: %s", self.task_id, exc)
-            self._stop.wait(self.interval)
+            self._stop_event.wait(self.interval)

    def stop(self) -> None:
-        self._stop.set()
+        self._stop_event.set()


 def _handle_task(task: dict) -> None: