多 Agent

Recursive 内置了基于相同正交原语构建的多 Agent 系统。

概念

概念	说明
AgentPool	按角色命名的 Agent 集合
SharedMemory	池中所有 Agent 共享的键值存储
MessageBus	Agent 间通信的发布/订阅通道
Pipeline	串行运行 Agent，将输出作为下一个 Agent 的输入
Team	协调 Agent 将任务委派给专家 Agent

Agent Pool

use recursive::multi::{AgentPool, AgentRole};

let pool = AgentPool::new()
    .add(AgentRole::Orchestrator, orchestrator_agent)
    .add(AgentRole::Researcher, researcher_agent)
    .add(AgentRole::Coder, coder_agent);

pool.run("实现功能 X").await?;

SharedMemory（共享内存）

use recursive::multi::SharedMemory;

let memory = SharedMemory::new();

// 写入
memory.set("current_task", "review src/agent.rs").await;

// 读取
let task = memory.get("current_task").await;

MessageBus（消息总线）

use recursive::multi::MessageBus;

let bus = MessageBus::new();
let mut rx = bus.subscribe("results");

bus.publish("results", "Agent A 完成：发现 3 个 bug").await;

while let Some(msg) = rx.recv().await {
    println!("收到：{msg}");
}

Pipeline（流水线）

use recursive::multi::Pipeline;

let pipeline = Pipeline::new()
    .step(research_agent)
    .step(planning_agent)
    .step(coding_agent)
    .step(review_agent);

pipeline.run("实现登录功能").await?;

Team（团队编排）

use recursive::multi::Team;

let team = Team::new(orchestrator_agent)
    .specialist("researcher", researcher_agent)
    .specialist("coder", coder_agent)
    .specialist("reviewer", reviewer_agent);

let outcome = team.run("构建用户管理 REST API").await?;
println!("{}", outcome.final_text.unwrap_or_default());

协调 Agent 会分析目标，将子任务分配给各专家 Agent，再整合所有结果。