TaskQueue — Async Task Queue for AI Agents

🔄 AI Agent 异步任务队列引擎

开源异步任务队列工具,支持优先级调度、自动重试和依赖链管理,让AI Agent任务执行井然有序。

收藏
3.9k
安装
992
版本
1.0.0
CLS 安全扫描中
预计需要 3 分钟...

使用说明

核心用法

TaskQueue 是为 AI Agent 设计的异步任务编排工具,采用 JavaScript 实现,支持顺序或并行执行任务链。核心功能包括:

  • 任务队列管理:通过 add() 方法添加任务,支持数字优先级(1最高)
  • 重试机制:可配置最大重试次数(默认3次)、延迟间隔,支持指数退避
  • 并发控制concurrency 参数控制并行度,设为1时严格串行执行
  • 依赖链:支持"X成功后才执行Y"的显式依赖声明
  • 执行控制:提供暂停/恢复功能,支持长时间任务的中断与续跑

典型工作流

const queue = new TaskQueue({ maxRetries: 3, concurrency: 1 });
queue.add({ task: 'Check email', priority: 1 });
const results = await queue.run(); // 返回完整执行日志

显著优点

1. 故障隔离:单任务失败不会终止整个队列,可配置跳过依赖失败的任务
2. 完整可观测性:内置执行日志含时间戳、耗时、状态流转(queued→running→success/failed/skipped)

3. MIT开源协议:商用友好,无授权顾虑

4. 轻量化设计:无外部服务依赖,纯本地运行

潜在局限

  • 语言限制:仅提供 JavaScript/Node.js 实现,Python/Go 用户需自行移植
  • 持久化缺失:文档未提及任务状态持久化,系统崩溃可能导致队列丢失
  • 无分布式能力:单机架构,无法横向扩展应对高并发场景
  • 调试工具有限:相比 Bull/Bee Queue 等成熟方案,缺少可视化监控面板

适合人群

  • 构建个人自动化工作流的开发者
  • 需要简单任务编排的 AI Agent 项目(OpenClaw 生态用户)
  • 对复杂工作流引擎(如 Temporal、Airflow)感到过重的中轻型用户

常规风险

  • 数据安全:免责声明明确指出作者不对数据丢失、安全漏洞负责,用户需自行评估
  • 维护状态:由独立开发者 @TheShadowRose 维护,长期支持存在不确定性
  • 生产就绪性:v1.0.0 版本,缺乏大规模生产环境验证的公开案例
  • 无SLA保证:MIT 协议下无商业支持承诺,关键业务需自行 fork 维护

TaskQueue — Async Task Queue for AI Agents 内容

src文件夹
手动下载zip · 6.6 kB
task-queue.jstext/javascript
请选择文件