Struct ParallelCoordinator 

pub struct ParallelCoordinator { /* private fields */ }

并行协调器

并行将任务分发给多个 Agent

Implementations

impl ParallelCoordinator

pub fn new(agent_ids: Vec<String>) -> ParallelCoordinator

创建新的并行协调器

Trait Implementations

impl Coordinator for ParallelCoordinator

fn dispatch<'life0, 'life1, 'async_trait>( &'life0 self, task: Task, _ctx: &'life1 AgentContext, ) -> Pin<Box<dyn Future<Output = Result<Vec<DispatchResult>, AgentError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, ParallelCoordinator: 'async_trait,

分发任务给 Agent(s)

fn aggregate<'life0, 'async_trait>( &'life0 self, results: Vec<AgentOutput>, ) -> Pin<Box<dyn Future<Output = Result<AgentOutput, AgentError>> + Send + 'async_trait>>

where 'life0: 'async_trait, ParallelCoordinator: 'async_trait,

聚合多个 Agent 的结果

fn pattern(&self) -> CoordinationPattern

获取协调模式

fn name(&self) -> &str

协调器名称

fn select_agents<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, _task: &'life1 Task, _ctx: &'life2 AgentContext, ) -> Pin<Box<dyn Future<Output = Result<Vec<String>, AgentError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, ParallelCoordinator: 'async_trait,

选择执行任务的 Agent

fn requires_all(&self) -> bool

是否需要所有 Agent 完成