我有一个TransformManyBlock<Tin, Tout>，在运行时通过LinkTo(...) 添加消费者（ActionBlocks）。
TransformManyBlock 是否是正确的数据流块来消费元素、转换它们，然后输出（与输入相同数量的元素输出）给多个消费者（每个链接到的消费者像广播一样消费相同的元素）？我故意不选择 BroadCastBlock，因为它似乎无法像 BufferBlock 一样转换元素。
我想知道如何在运行时取消链接消费者（此处为 ActionBlock）？据我所知，LinkTo() 似乎没有提供这样的功能。
【问题讨论】：
标签： c# concurrency task-parallel-library dataflow tpl-dataflow
TransformManyBlock用于将输入上的一项转化为输出上的多项，与消费者数量无关。
如果您想为每个目标分别执行转换，那么这正是BroadcastBlock 中的cloningFunction 的用途。
如果您想执行一次转换，然后向每个目标发送相同的对象，您可以通过将TransformBlock 和BroadcastBlock 链接在一起来组合它们。该项目将由TransformBlock 转换，然后由BroadcastBlock 发送到所有目标。
LinkTo()的返回值为：
一个
IDisposable，在调用Dispose时，将取消源与目标的链接。
这正是您所需要的。只需存储从LinkTo() 返回的值，然后在必要时存储Dispose()。
【讨论】：
BroadcastBlock 是唯一一个将每条消息发送到其所有目标的内置块吗？是的。 （WriteOnceBlock 也可以这样做，但非常有限。）如果 BroadcastBlock 的开销对您来说实在是太多了，那么您将不得不创建自己的块，结合 TransformBlock 和 BroadcastBlock，或类似的东西那个。