Method start

task.py:2958–2990

运行任务队列

(self)

    def start(self):
        """运行任务队列"""
        self.init_tasks()
        while True:
            if not self.heap:
                time.sleep(1)
                continue

            with self.lock:
                # 取出最近任务
                next_time, _, task = heapq.heappop(self.heap)

            # 计算等待时间
            current_time = int(time.time())
            wait_time = max(0, next_time - current_time)

            # 等待执行
            if wait_time > 0:
                time.sleep(wait_time)

            # 出现拥塞，跳过本次执行
            if not task.congestion or not self.repetition_check(task):
                task.run()

            # 获取下一次执行时间重新入队
            try:
                next_execution_time = task.get_next_time()
                with self.lock:
                    heapq.heappush(self.heap, (next_execution_time, task.get_ident(), task))
            except Exception as e:
                # 如果无法获取下一次执行时间，任务不再重新入队
                write_log("获取{}任务下次执行时间失败: {}".format(task.name, str(e)), traceback.format_exc(), _level='error', color='red')
                pass


def start_scripts_service():