我试图将一条消息的副本从ActionBlock<int>发送给多个使用者，这些使用者也是ActionBlock<int>。这很好，但是如果其中一个目标块引发异常，看起来这不会传播到源块。在这里，我怎么尝试处理异常，但它从未进入到catch部分： static void Main(string[] args)
{
var t1 = new ActionBlock<int>(async i
我正在使用TPL数据流构建应用程序。其实我有以下问题。我有一个transformblock var tfb1 = new TranformBlock<InMsg, IReadOnlyCollection<OutMsg>>。因此，tfb1在消息中接收并创建出站消息列表。这个out-messages列表应该链接到一个路由器数据块，它接收OutMsg作为输入（而不是IReadOnlyCollection
我有一个BroadcastBlock链接到ActionBlock。当我在BroadcastBlock和ActionBlock上顺序呼叫“完成”时，它不起作用。而仅仅在BroadCastBlock上打电话“完成”正在工作。 public class ActionTester
{
private readonly ActionBlock<int> _action;
private