Struct NodeAggregator 

pub struct NodeAggregator<T: Clone + Send + Sync + 'static> { /* private fields */ }

并行节点聚合器

提供高性能的树形节点聚合计算，支持自定义聚合逻辑

类型参数

• T: 聚合结果类型

Implementations

impl<T: Clone + Send + Sync + 'static> NodeAggregator<T>

pub fn new<F, Fut>( processor: F, level_strategy: impl LevelStrategy + 'static, ) -> Self

where F: Fn(NodeId, Arc<State>, Arc<ConcurrentCache<T>>) -> Fut + Send + Sync + 'static, Fut: Future<Output = ForgeResult<T>> + Send + 'static,

创建新的节点聚合器

参数

• processor: 节点聚合处理函数
• level_strategy: 层级计算策略

示例

let aggregator = NodeAggregator::new(
    |node_id, state, cache| async move {
        // 自定义聚合逻辑
        Ok(result)
    },
    CachedLevelStrategy::new(),
);

pub fn with_default_strategy<F, Fut>(processor: F) -> Self

where F: Fn(NodeId, Arc<State>, Arc<ConcurrentCache<T>>) -> Fut + Send + Sync + 'static, Fut: Future<Output = ForgeResult<T>> + Send + 'static,

使用默认层级策略创建聚合器

pub fn with_cached_strategy<F, Fut>(processor: F) -> Self

where F: Fn(NodeId, Arc<State>, Arc<ConcurrentCache<T>>) -> Fut + Send + Sync + 'static, Fut: Future<Output = ForgeResult<T>> + Send + 'static,

使用缓存层级策略创建聚合器（推荐）

Trait Implementations

impl<T: Clone + Send + Sync + 'static> NodeAggregatorTrait<T> for NodeAggregator<T>

async fn aggregate_up( &self, start_node: &NodeId, state: Arc<State>, ) -> ForgeResult<HashMap<NodeId, T>>

执行自下而上的层级聚合

算法流程

1. 收集从起始节点到根节点的所有祖先
2. 按层级分组（叶子节点层级最大）
3. 从最深层级开始，逐层向上处理
4. 每层内部使用 tokio::spawn 并发处理
5. 确保当前层完全处理完成后再处理上一层

性能特性

• 同层并发: 使用 tokio::spawn 真正异步并发
• 层间串行: 保证数据依赖正确性
• 零开销: 使用调用方现有的 tokio runtime
• 层级缓存: O(1) 层级查询