coordinator mode

Coordinator 智能分解复杂任务并编排多个 Agent 协作完成。

设计理念

问题

复杂任务难以一次完成：

• 需要多个步骤

• 有依赖关系

• 可以并行执行

手动分解效率低。

解决方案

Coordinator 自动分解和编排：

复杂任务
  ↓
Coordinator 分析
  ↓
生成任务图
  ↓
分配给 Agent
  ↓
监控执行
  ↓
聚合结果

核心实现

任务分解

async function decomposeTask(
  task: string
): Promise<TaskGraph> {
  const prompt = `
Decompose this task into subtasks:
${task}

Return a task graph in JSON:
{
  "tasks": [
    {
      "id": "task1",
      "description": "...",
      "dependencies": [],
      "estimatedTime": 30
    }
  ]
}
  `;
  
  const response = await query([{ role: 'user', content: prompt }]);
  return JSON.parse(response);
}

任务编排

async function orchestrateTasks(
  graph: TaskGraph
): Promise<ExecutionResult> {
  const completed = new Set<string>();
  const results = new Map<string, any>();
  
  while (completed.size < graph.tasks.length) {
    // 找出可执行的任务
    const ready = graph.tasks.filter(task =>
      !completed.has(task.id) &&
      task.dependencies.every(dep => completed.has(dep))
    );
    
    // 并行执行
    const batchResults = await Promise.all(
      ready.map(task => executeTask(task, results))
    );
    
    // 更新状态
    ready.forEach((task, i) => {
      completed.add(task.id);
      results.set(task.id, batchResults[i]);
    });
  }
  
  return { results };
}

下一步

• 探索 推测执行 的优化

• 了解 Swarm 模式 的并行协作

• 查看 多 Agent 系统 的完整实现