c# – 如何在TPL Dataflow中将多个目标块与源块链接？

发布时间：2020-12-15 17:37:05 所属栏目：百科来源：网络整理

导读：我预计以下几个方面可以从两个出版商那里获得产出,但是它只产生第一个输出： var broadcastBlock = new BroadcastBlockint(null);var transformBlock = new TransformBlockint,int(i = i*10);var publish1 = new ActionBlockint(i = Console.WriteLine("Publ

我预计以下几个方面可以从两个出版商那里获得产出,但是它只产生第一个输出：

var broadcastBlock = new BroadcastBlock<int>(null);
var transformBlock = new TransformBlock<int,int>(i => i*10);
var publish1 = new ActionBlock<int>(i => Console.WriteLine("Publisher 1:" + i));
var publish2 = new ActionBlock<int>(i => Console.WriteLine("Publisher 2:" + i));

broadcastBlock.LinkTo(transformBlock,new DataflowLinkOptions() { PropagateCompletion = true });
transformBlock.LinkTo(publish1,new DataflowLinkOptions() { PropagateCompletion = true });
transformBlock.LinkTo(publish2,new DataflowLinkOptions() { PropagateCompletion = true });

foreach (var i in Enumerable.Range(0,5))
{
    broadcastBlock.Post(i);
}
broadcastBlock.Complete();
Task.WhenAll(publish1.Completion,publish2.Completion).Wait();

我显然在这里遗漏了一些基本的东西,任何想法？

解决方法

您将2个ActionBlock链接到一个TransformBlock.您应该将2个ActionBlock链接到BrodcastBlock并将BroadcastBlock链接到TransformBlock.

你有什么：

BroadCast => Transfrom => ActionBlock
                       => ActionBlock

你需要什么

Transfrom => BroadCast => ActionBlock
                       => ActionBlock

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!