5.4 代码作为元能力：智能体的 6 维可执行思维

// planning-as-code.ts
 
export interface TaskNode {
  id: string;
  name: string;
  dependencies: string[]; // 依赖的前置任务 ID
  status: 'pending' | 'running' | 'completed' | 'failed';
  execute: () => Promise<void>;
}
 
export class ExecutablePlanEngine {
  private tasks: Map<string, TaskNode> = new Map();
 
  addTask(task: TaskNode) {
    this.tasks.set(task.id, task);
  }
 
  /**
   * 拓扑排序校验并按依赖层级执行
   */
  async runPlan() {
    console.log('[Plan Engine] 启动代码化计划执行引擎...');
    
    const completedTasks = new Set<string>();
    const remainingTasks = new Set(this.tasks.keys());
 
    while (remainingTasks.size > 0) {
      // 找出当前所有前置依赖均已满足的就绪任务
      const readyTasks: TaskNode[] = [];
      for (const taskId of remainingTasks) {
        const node = this.tasks.get(taskId)!;
        const allDepsMet = node.dependencies.every((dep) => completedTasks.has(dep));
        if (allDepsMet) {
          readyTasks.push(node);
        }
      }
 
      if (readyTasks.length === 0) {
        throw new Error('检测到计划中存在循环依赖死锁 (Circular Dependency Deadlock)！');
      }
 
      // 并发执行所有就绪任务
      await Promise.all(
        readyTasks.map(async (task) => {
          console.log(`[Plan Engine] 正在并发执行节点: ${task.name} (${task.id})`);
          task.status = 'running';
          try {
            await task.execute();
            task.status = 'completed';
            completedTasks.add(task.id);
            remainingTasks.delete(task.id);
          } catch (err: any) {
            task.status = 'failed';
            throw new Error(`任务节点 ${task.id} 失败: ${err.message}`);
          }
        })
      );
    }
 
    console.log('[Plan Engine] 全量代码化计划成功完成全绿交付！');
  }
}