Struct ParallelAgent 

pub struct ParallelAgent { /* private fields */ }

并行 Agent 执行模式

多个 Agent 并行执行同一任务，然后聚合结果

示例

let parallel = ParallelAgent::new()
    .add("expert1", agent1)
    .add("expert2", agent2)
    .add("expert3", agent3)
    .with_aggregation(AggregationStrategy::Concatenate);

let result = parallel.run("Analyze this problem").await?;

Implementations

impl ParallelAgent

pub fn new() -> Self

创建新的并行 Agent

pub fn add(self, name: impl Into<String>, agent: Arc<ReActAgent>) -> Self

添加 ReAct Agent

pub fn add_llm(self, name: impl Into<String>, agent: Arc<LLMAgent>) -> Self

添加 LLM Agent

pub fn add_unit(self, name: impl Into<String>, unit: AgentUnit) -> Self

添加通用 AgentUnit

pub fn with_aggregation(self, strategy: AggregationStrategy) -> Self

设置聚合策略

pub fn with_aggregate_on_partial_failure(self, enabled: bool) -> Self

设置是否在部分失败时仍聚合

pub fn with_timeout_ms(self, timeout_ms: u64) -> Self

设置超时时间

pub fn with_verbose(self, verbose: bool) -> Self

设置是否详细输出

pub fn with_task_template( self, agent_name: impl Into<String>, template: impl Into<String>, ) -> Self

设置特定 Agent 的任务模板

模板中可使用 {task} 占位符表示原始任务

示例

parallel.with_task_template("analyst", "As a financial analyst, {task}");

pub async fn run(&self, task: impl Into<String>) -> LLMResult<ParallelResult>

执行并行 Agent

pub fn len(&self) -> usize

获取 Agent 数量

pub fn is_empty(&self) -> bool

检查是否为空

Trait Implementations

impl Default for ParallelAgent

fn default() -> Self

Returns the “default value” for a type.