Struct ParallelNode 

pub struct ParallelNode<S: WorkflowState = State, M: MergeStrategy<S> = StateMerge> { /* private fields */ }

并行节点 — 同时执行多个分支，通过 MergeStrategy 合并 State。

每个分支接收相同的 State 快照，独立产生变更。 所有分支完成后，变更通过 MergeStrategy 合并。

泛型参数

• S — 类型化状态
• M — 合并策略（默认为 StateMerge）

示例

let parallel = ParallelNode::builder()
    .branch("search", Arc::new(SearchNode::new()))
    .branch("analyze", Arc::new(AnalyzeNode::new()))
    .build();

graph.node("research", NodeKind::Parallel(parallel));

Implementations

impl ParallelNode

pub fn builder() -> ParallelNodeBuilder

创建默认构建器（State + StateMerge）。

impl<S: WorkflowState, M: MergeStrategy<S>> ParallelNode<S, M>

pub fn with_label(self, label: impl Into<String>) -> Self

pub fn branch_count(&self) -> usize

pub fn branch_names(&self) -> Vec<&str>

pub fn branches_iter( &self, ) -> impl Iterator<Item = (&str, &Arc<dyn FlowNode<S>>)>

pub fn error_strategy(&self) -> ParallelErrorStrategy

pub fn label(&self) -> Option<&str>

Trait Implementations

impl<S: WorkflowState, M: MergeStrategy<S>> Clone for ParallelNode<S, M>

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<S: WorkflowState, M: MergeStrategy<S>> Debug for ParallelNode<S, M>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<S: WorkflowState, M: MergeStrategy<S>> FlowNode<S> for ParallelNode<S, M>

fn execute<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, ctx: &'life1 mut NodeContext<'life2, S>, ) -> Pin<Box<dyn Future<Output = Result<(), GraphError>> + Send + 'async_trait>>

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

执行节点逻辑。