此代码永远不会到达最后一行,因为完成不会从 saveBlock 传播到 sendBlock。我究竟做错了什么?
var readGenerateBlock = new TransformBlock<int, int>(n =>
{
Console.WriteLine("Read " + n);
Thread.Sleep(15);
return n;
});
var groupingBlock = new BatchBlock<int>(10);
var saveBlock = new TransformManyBlock<int[], int>(n =>
{
Console.WriteLine("Saving {0} items [{1}; {2}]", n.Count(), n.First(), n.Last());
Thread.Sleep(150);
return n;
});
var sendBlock = new TransformBlock<int, int>(n =>
{
Console.WriteLine("Sending {0}", n);
Thread.Sleep(25);
return n;
}, new ExecutionDataflowBlockOptions { MaxDegreeOfParallelism = 2 });
readGenerateBlock.LinkTo(groupingBlock, new DataflowLinkOptions { PropagateCompletion = true });
groupingBlock.LinkTo(saveBlock, new DataflowLinkOptions { PropagateCompletion = true });
saveBlock.LinkTo(sendBlock, new DataflowLinkOptions { PropagateCompletion = true });
Parallel.For(0, 250, i => readGenerateBlock.Post(i));
readGenerateBlock.Complete();
sendBlock.Completion.Wait();
Console.WriteLine("Completed.");
您必须先从块中读取数据,然后才能完成。既然没有人在读书saveBlock
,它永远不会完成。
如果您不需要数据,最简单的解决方案是使用ActionBlock
代替TransformBlock
。否则,就继续读取数据,直到块完成。
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)