多任务并行执行管理器

核心能力

接收用户的多条指令，自动识别任务类型、优先级和依赖关系，并在并发执行池中同步处理。

任务队列管理

任务注册

当收到多条指令时，自动注册为独立任务：

{
  "task_id": "task_123",
  "command": "下载文件",
  "priority": 1,
  "status": "pending",
  "created_at": "2026-02-05T22:30:00Z",
  "depends_on": []
}

优先级系统

优先级级别： - P0 - 最高优先级（紧急任务） - P1 - 高优先级（重要任务） - P2 - 中优先级（普通任务） - P3 - 低优先级（可选任务）

调度策略： 1. 高优先级任务优先执行 2. 同优先级任务按时间戳 FIFO 3. 低优先级任务在系统空闲时执行

并发执行池

执行模式

同步执行模式：

{
  "mode": "parallel",
  "max_concurrent": 4,
  "tasks": [
    { "task_id": 1, "command": "任务1" },
    { "task_id": 2, "command": "任务2" },
    { "task_id": 3, "command": "任务3" }
  ]
}

串行执行模式：

{
  "mode": "serial",
  "tasks": [
    { "task_id": 1, "command": "任务1" },
    { "task_id": 2, "command": "任务2" },
    { "task_id": 3, "command": "任务3" }
  ]
}

并发控制

最大并发数： 默认 4
超时时间： 默认 30 秒
重试次数： 默认 3
资源限制： CPU、内存、I/O

任务类型识别

自动识别的任务类型

文件操作
创建/删除文件
移动/重命名文件
下载/上传文件
浏览器操作
打开网页
填写表单
截图
命令执行
Shell 命令
脚本执行
应用程序启动
数据处理
解析 JSON/XML
文件转换
数据计算
网络请求
HTTP 请求
API 调用
数据库查询

任务调度流程

接收指令 → 任务注册 → 优先级排序 → 执行池分配 → 并发执行 → 结果收集 → 报告生成

详细流程

接收指令
解析用户的多条消息
提取任务命令
识别任务类型
任务注册
生成唯一任务 ID
设置优先级
检查依赖关系
优先级排序
按 P0→P1→P2→P3 排序
同优先级按时间排序
执行池分配
最多 N 个并发任务
检查系统资源
分配到执行槽
并发执行
执行任务
实时进度更新
错误处理
结果收集
收集所有任务结果
合并成功/失败状态
生成报告

进度追踪

实时进度

{
  "total_tasks": 5,
  "completed": 2,
  "running": 2,
  "pending": 1,
  "progress": "40%",
  "eta": "预计剩余 30 秒"
}

任务状态

pending - 等待中
running - 执行中
completed - 已完成
failed - 失败
cancelled - 已取消

结果报告

执行报告

{
  "execution_id": "exec_456",
  "total_tasks": 5,
  "completed": 4,
  "failed": 1,
  "success_rate": "80%",
  "duration": "45.2秒",
  "tasks": [
    {
      "task_id": 1,
      "command": "创建文件",
      "status": "completed",
      "result": "成功",
      "duration": "2.1秒"
    },
    {
      "task_id": 2,
      "command": "下载文件",
      "status": "completed",
      "result": "成功",
      "duration": "18.5秒"
    }
  ]
}

错误处理

错误恢复策略

自动重试
失败任务自动重试
最多重试 3 次
指数退避策略
错误隔离
单个任务失败不影响其他任务
失败任务独立处理
失败报告详细
错误通知
实时错误状态
失败原因分析
建议解决方案

使用示例

示例1：多条独立任务

# 用户发送
"创建文件A，创建文件B，下载文件C"

# 系统自动处理为 3 个并发任务
# 结果：
# ✓ 任务1: 创建文件A - 成功
# ✓ 任务2: 创建文件B - 成功
# ✓ 任务3: 下载文件C - 成功

示例2：带优先级任务

# 用户发送
"高优先级：删除临时文件，中优先级：备份文件，低优先级：整理文档"

# 系统按优先级排序执行
# 结果：
# ✓ 高优先级：删除临时文件 - 成功
# ✓ 中优先级：备份文件 - 成功
# ✓ 低优先级：整理文档 - 成功

示例3：任务依赖

# 用户发送
"先创建目录，再创建文件"

# 系统自动识别依赖关系
# 结果：
# ✓ 任务1: 创建目录 - 成功
# ✓ 任务2: 创建文件 - 成功（依赖任务1完成）

配置参数

可在 ~/.openclaw/openclaw.json 中配置：

{
  "parallel-executor": {
    "max_concurrent_tasks": 4,
    "task_timeout_seconds": 30,
    "max_retries": 3,
    "default_priority": "P1",
    "enable_progress_tracking": true,
    "enable_error_recovery": true
  }
}

最佳实践

任务拆分原则

将复杂任务拆分为独立小任务
避免任务间强依赖
合理设置任务优先级

并发控制

高优先级任务可提高并发数
避免过度并发导致系统负载过高
监控系统资源使用

错误处理

允许部分失败
详细记录错误信息
提供恢复建议

资源

执行报告格式
任务优先级规范
调度算法说明

parallel-task-executor

Installation

多任务并行执行管理器

核心能力

任务队列管理

任务注册

优先级系统

并发执行池

执行模式

并发控制

任务类型识别

自动识别的任务类型

任务调度流程

详细流程

进度追踪

实时进度

任务状态

结果报告

执行报告

错误处理

错误恢复策略

使用示例

示例1：多条独立任务

示例2：带优先级任务

示例3：任务依赖

配置参数

最佳实践

任务拆分原则

并发控制

错误处理

资源