Skip to main content

Module parallel_node

Module parallel_node 

Source
Expand description

ParallelNode — 并行执行多个分支,合并 StateDelta。

执行模型:

State
 ↓
fork (ParallelNode)
 ↓
Branch A     Branch B     Branch C
 ↓            ↓            ↓
StateDelta   StateDelta   StateDelta
 ↓            ↓            ↓
ReducerRegistry.merge_deltas()
 ↓
Merged Deltas → apply to State

每个分支接收相同的 State 快照,独立产生 StateDelta。 所有 Delta 收集后通过 ReducerRegistry::merge_deltas() 合并。 未注册 Reducer 的 key 发生多 writer → StateConflict 错误。

Structs§

ParallelNode
并行节点 — 同时执行多个分支,合并 StateDelta。
ParallelNodeBuilder
ParallelNode 构建器。

Enums§

ParallelErrorStrategy
并行执行错误处理策略。