使用 TPL-Dataflow 进行聚合和连接（内、外、左……）？

Question

有没有比使用BatchBlock 缓冲所有项目直到完成、将它们作为集合发出然后使用转换块进行实际聚合的更好方法来实现 TPL-Dataflow 网格中的聚合等功能？

同样，有没有其他方法可以在不使用BatchedJoinBlock 缓冲两个数据源的所有项目的情况下对两个数据集进行内/外/左/右连接，将它们作为两个集合的元组发出，然后执行实际加入一个变换块？

Answer 1

否。 TPL Dataflow 中没有这种开箱即用的机制，因为聚合和连接操作与 flowing 无关，它们与查询数据有关。

但是，作为blocks are perfectly fit with RX library，您可以在聚合数据时使用Join Patterns in Rx 范例。

更多相关链接：

• Aggregation 在Rx
• Reactive Extensions for .NET (Rx): Take action once all events are completed
• Guide to System.Reactive.Joins