parallel-task-executor多任务并行执行管理器。接收多条指令并同步执行,支持优先级调度、任务依赖、结果收集和进度跟踪。适用于需要并发处理多个独立任务的场景。
Install via ClawdBot CLI:
clawdbot install Erichy777/parallel-task-executor接收用户的多条指令,自动识别任务类型、优先级和依赖关系,并在并发执行池中同步处理。
当收到多条指令时,自动注册为独立任务:
{
"task_id": "task_123",
"command": "下载文件",
"priority": 1,
"status": "pending",
"created_at": "2026-02-05T22:30:00Z",
"depends_on": []
}
优先级级别:
P0 - 最高优先级(紧急任务)P1 - 高优先级(重要任务)P2 - 中优先级(普通任务)P3 - 低优先级(可选任务)调度策略:
同步执行模式:
{
"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" }
]
}
接收指令 → 任务注册 → 优先级排序 → 执行池分配 → 并发执行 → 结果收集 → 报告生成
{
"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秒"
}
]
}
# 用户发送
"创建文件A,创建文件B,下载文件C"
# 系统自动处理为 3 个并发任务
# 结果:
# ✓ 任务1: 创建文件A - 成功
# ✓ 任务2: 创建文件B - 成功
# ✓ 任务3: 下载文件C - 成功
# 用户发送
"高优先级:删除临时文件,中优先级:备份文件,低优先级:整理文档"
# 系统按优先级排序执行
# 结果:
# ✓ 高优先级:删除临时文件 - 成功
# ✓ 中优先级:备份文件 - 成功
# ✓ 低优先级:整理文档 - 成功
# 用户发送
"先创建目录,再创建文件"
# 系统自动识别依赖关系
# 结果:
# ✓ 任务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
}
}
Generated Mar 1, 2026
Automates concurrent deployment tasks like code compilation, container building, and environment provisioning in CI/CD pipelines. It prioritizes critical deployments (P0) and handles failures with retries, reducing manual intervention and speeding up release cycles.
Manages parallel data ingestion, transformation, and analysis tasks from multiple sources such as APIs, databases, and files. It schedules high-priority data updates (P1) and ensures dependent tasks like parsing before calculation run sequentially, improving data pipeline efficiency.
Executes simultaneous order processing tasks including inventory checks, payment verification, and shipping label generation. It uses priority scheduling to handle urgent orders (P0) and tracks progress in real-time, enhancing customer satisfaction and operational throughput.
Coordinates multiple system updates, backups, and security scans across servers or endpoints. It allocates tasks based on resource limits and retries failed operations, minimizing downtime and ensuring consistent system health monitoring.
Handles concurrent content creation tasks like image resizing, metadata tagging, and publishing to various platforms. It prioritizes time-sensitive content (P1) and collects results into reports, streamlining editorial workflows for media teams.
Offers the skill as a cloud-based service with tiered plans based on concurrent task limits, priority levels, and support. Revenue comes from monthly or annual subscriptions, targeting businesses needing scalable task automation without infrastructure overhead.
Sells perpetual licenses or annual contracts for on-premises deployment, customized for large organizations with specific integration needs. Revenue includes upfront licensing fees and optional maintenance/support packages, ensuring compliance and control.
Charges based on metrics like number of tasks executed, execution time, or priority levels consumed. This pay-as-you-go model appeals to startups or projects with variable workloads, generating revenue from active usage without long-term commitments.
💬 Integration Tip
Integrate by configuring max_concurrent_tasks and default_priority in the JSON config file to match your system's resource limits and workflow needs.
Captures learnings, errors, and corrections to enable continuous improvement. Use when: (1) A command or operation fails unexpectedly, (2) User corrects Clau...
Helps users discover and install agent skills when they ask questions like "how do I do X", "find a skill for X", "is there a skill that can...", or express interest in extending capabilities. This skill should be used when the user is looking for functionality that might exist as an installable skill.
Search and analyze your own session logs (older/parent conversations) using jq.
Typed knowledge graph for structured agent memory and composable skills. Use when creating/querying entities (Person, Project, Task, Event, Document), linking related objects, enforcing constraints, planning multi-step actions as graph transformations, or when skills need to share state. Trigger on "remember", "what do I know about", "link X to Y", "show dependencies", entity CRUD, or cross-skill data access.
Ultimate AI agent memory system for Cursor, Claude, ChatGPT & Copilot. WAL protocol + vector search + git-notes + cloud backup. Never lose context again. Vibe-coding ready.
Headless browser automation CLI optimized for AI agents with accessibility tree snapshots and ref-based element selection