kbarbel640-del 多任务并行执行管理器
核心能力
接收用户的多条指令，自动识别任务类型、优先级和依赖关系，并在并发执行池中同步处理。
任务队列管理
任务注册
当收到多条指令时，自动注册为独立任务：
{
"task_id": "task_123",
"command": "下载文件",
"priority": 1,
"status": "pending",
"created_at": "2026-02-05T22:30:00Z",
"depends_on": []
}
优先级系统
优先级级别：
P0- 最高优先级（紧急任务）P1- 高优先级（重要任务）P2- 中优先级（普通任务）P3- 低优先级（可选任务）
调度策略：
- 高优先级任务优先执行
- 同优先级任务按时间戳 FIFO
- 低优先级任务在系统空闲时执行
并发执行池
执行模式
同步执行模式：
{
"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
}
}
最佳实践
任务拆分原则
- 将复杂任务拆分为独立小任务
- 避免任务间强依赖
- 合理设置任务优先级
并发控制
- 高优先级任务可提高并发数
- 避免过度并发导致系统负载过高
- 监控系统资源使用
错误处理
- 允许部分失败
- 详细记录错误信息
- 提供恢复建议
资源
- 执行报告格式
- 任务优先级规范
- 调度算法说明