Method add_log

src/web/task_manager.py:99–114

添加日志并推送到 WebSocket（线程安全）

(self, task_uuid: str, log_message: str)

        logger.info(f"任务 {task_uuid} 已标记为取消")

    def add_log(self, task_uuid: str, log_message: str):
        """添加日志并推送到 WebSocket（线程安全）"""
        # 先广播到 WebSocket，确保实时推送
        # 然后再添加到队列，这样 get_unsent_logs 不会获取到这条日志
        if self._loop and self._loop.is_running():
            try:
                asyncio.run_coroutine_threadsafe(
                    self._broadcast_log(task_uuid, log_message),
                    self._loop
                )
            except Exception as e:
                logger.warning(f"推送日志到 WebSocket 失败: {e}")

        # 广播后再添加到队列
        with _get_log_lock(task_uuid):
            _log_queues[task_uuid].append(log_message)

    async def _broadcast_log(self, task_uuid: str, log_message: str):
        """广播日志到所有 WebSocket 连接"""