c# - TPL 数据流管道在服务内部不断运行

Question

比如我有三个 block :

       Buffer -> Transform -> Action 

我正在运行 webapi 服务，它将请求中的数据带到缓冲区 block 。如何创建这样一个将永远运行的管道，而无需在 Action block 中调用 Completion() 并停止整个管道。

Answer 1

Dataflow 没有很好的解决方案来获取特定输入的管道输出(因为它支持的不仅仅是简单的管道)。

解决这个问题的方法是创建一个 TaskCompletionSource<T>并将其与输入一起发送到管道。管道中的每个 block 将其发送到下一个 block ，最后一个 block 调用其 SetResult() .

然后将输入发送到管道的代码可以 await TaskCompletionSource的 Task等待管道的输出。