mirror of
https://github.com/countbot-ai/CountBot.git
synced 2026-09-14 20:46:47 +08:00
w
14d4d4e2a0
功能(核心): 会话级配置系统与前端体验全面升级 核心功能：- 会话级配置系统，轻松打造你的AI团队（每个会话独立 API、模型、提示词） - 新增微博、企业微信、小智 AI 三个 IM 渠道 - 实现企业微信、飞书两个IM渠道的消息流式输出 - 全面优化多智能体协作系统 - 全面优化项目代码兼容性 - 新增 /help 命令（通过 IM 渠道输入即可体验） - 集成 Mermaid 图表渲染引擎 - 全面兼容 OpenClaw Skills 技能生态 - Heartbeat 主动问候系统重构 - WEB聊天页面支持自定义用户头像 - 支持自定义输出语言，比如中文、英文、西语等 - 修复大量已知问题
33 lines
813 B
Python
33 lines
813 B
Python
"""任务取消令牌"""
|
|
|
|
from typing import Callable, List
|
|
|
|
from loguru import logger
|
|
|
|
|
|
class CancellationToken:
|
|
"""取消令牌 — 用于协作式任务取消"""
|
|
|
|
def __init__(self):
|
|
self._cancelled = False
|
|
self._callbacks: List[Callable] = []
|
|
|
|
def cancel(self):
|
|
"""标记为已取消并执行回调"""
|
|
if self._cancelled:
|
|
return
|
|
self._cancelled = True
|
|
for cb in self._callbacks:
|
|
try:
|
|
cb()
|
|
except Exception as e:
|
|
logger.error(f"Error in cancellation callback: {e}")
|
|
|
|
@property
|
|
def is_cancelled(self) -> bool:
|
|
return self._cancelled
|
|
|
|
def register_callback(self, callback: Callable):
|
|
"""注册取消时的回调"""
|
|
self._callbacks.append(callback)
|