多任务并行执行管理器

核心能力

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

任务队列管理

任务注册

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

优先级系统

优先级级别：

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

调度策略：

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

并发执行池

执行模式

同步执行模式：
json
{
mode: parallel,
max_concurrent: 4,
tasks: [
{ task_id: 1, command: 任务1 },
{ task_id: 2, command: 任务2 },
{ task_id: 3, command: 任务3 }
]
}

串行执行模式：
json
{
mode: serial,
tasks: [
{ task_id: 1, command: 任务1 },
{ task_id: 2, command: 任务2 },
{ task_id: 3, command: 任务3 }
]
}

并发控制

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

任务类型识别

自动识别的任务类型

1. 1. 文件操作

1. 2. 浏览器操作

1. 3. 命令执行

1. 4. 数据处理

1. 5. 网络请求

任务调度流程

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

详细流程

1. 1. 接收指令

1. 2. 任务注册

1. 3. 优先级排序

1. 4. 执行池分配

1. 5. 并发执行

1. 6. 结果收集

进度追踪

实时进度

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

任务状态

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

结果报告

执行报告

json
{
executionid: exec456,
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秒
}
]
}

错误处理

错误恢复策略

1. 1. 自动重试

1. 2. 错误隔离

1. 3. 错误通知

使用示例

示例1：多条独立任务

bash

用户发送

系统自动处理为 3 个并发任务

结果：

✓ 任务1: 创建文件A - 成功

✓ 任务2: 创建文件B - 成功

✓ 任务3: 下载文件C - 成功

示例2：带优先级任务

bash

用户发送

系统按优先级排序执行

结果：

✓ 高优先级：删除临时文件 - 成功

✓ 中优先级：备份文件 - 成功

✓ 低优先级：整理文档 - 成功

示例3：任务依赖

bash

用户发送

系统自动识别依赖关系

结果：

✓ 任务1: 创建目录 - 成功

✓ 任务2: 创建文件 - 成功（依赖任务1完成）

配置参数

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

json
{
parallel-executor: {
maxconcurrenttasks: 4,
tasktimeoutseconds: 30,
max_retries: 3,
default_priority: P1,
enableprogresstracking: true,
enableerrorrecovery: true
}
}

最佳实践

任务拆分原则

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

并发控制

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

错误处理

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

资源

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