C#加入块

例子

(收集 2-3 个输入并将它们组合成一个元组)

与 BatchBlock 一样,JoinBlock<T1, T2, …> 能够对来自多个数据源的数据进行分组。事实上,这就是 JoinBlock<T1, T2, ...> 的主要目的。

例如,JoinBlock<string, double, int> 是 ISourceBlock<Tuple<string, double, int>>。

与 BatchBlock 一样,JoinBlock<T1, T2,…> 能够在贪婪和非贪婪模式下运行。

  • 在默认的贪婪模式下,所有提供给目标的数据都被接受,即使另一个目标没有形成元组所需的数据。

  • 在非贪婪模式下,块的目标将推迟数据,直到为所有目标提供了创建元组所需的数据,此时块将参与两阶段提交协议,以原子方式从源中检索所有必要的项目。这种延迟使得另一个实体可以同时消费数据,从而允许整个系统向前推进。

使用有限数量的池对象处理请求

var throttle = new JoinBlock<ExpensiveObject, Request>();
for(int i=0; i<10; i++) 
{
    requestProcessor.Target1.Post(new ExpensiveObject()); 
}

var processor = new Transform<Tuple<ExpensiveObject, Request>, ExpensiveObject>(pair =>
{
    var resource = pair.Item1;
    var request = pair.Item2;
    
    request.ProcessWith(resource);
    
    return resource;
});

throttle.LinkTo(processor);
processor.LinkTo(throttle.Target1);

Stephen Toub 对 TPL 数据流的介绍