@@ -67,6 +67,8 @@ class CrawlerScheduler:
def start(self):
"""启动调度器"""
self.set_flag(False)
+ if hasattr(self, 'heartbeat_thread') and self.heartbeat_thread and self.heartbeat_thread.is_alive():
+ return
self.heartbeat_thread = threading.Thread(
target=self._heartbeat_reporter,
daemon=True