(收集 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);