使用谓词时 TPL 数据流永远不会完成

Question

我有以下 TPL 数据流，在使用谓词过滤从 TransformBlock 传递到 ActionBlock 的项目时永远不会完成。

如果任何项的谓词 returns 为假，则数据流将挂起。

有人可以提供一些关于正在发生的事情以及如何解决这个问题的见解吗？

// define blocks 
var getBlock = new TransformBlock<int, int>(i =>
{
    Console.WriteLine($"getBlock: {i}");

    return ++i;
});

var writeBlock = new ActionBlock<int>(i =>
{
    Console.WriteLine($"writeBlock: {i}");
});

// link blocks
getBlock.LinkTo(writeBlock, new DataflowLinkOptions
{
    PropagateCompletion = true
}, i => i == 12); // <-- this predicate prevents the completion of writeBlock

// push to block 
var items = new List<int> { 1, 2, 3, 4, 5, 6, 7, 8, 9, 10 };
foreach (var i in items)
{
    getBlock.Post(i); 
}

// wait for all operations to complete
getBlock.Complete();
await writeBlock.Completion; // <-- application hangs here

Answer 1

getBlock 没有完成，因为发布到它的项目无处可去。如果您有谓词，请添加一个空目标，以便任何不匹配的项目都有一个退出管道的位置。

getBlock.LinkTo(writeBlock, new DataflowLinkOptions
{
    PropagateCompletion = true
}, i => i == 12)
getBlock.LinkTo(DataflowBlock.NullTarget<int>());

使用谓词时 TPL 数据流永远不会完成

TPL Dataflow never completes when using a predicate

tpl-dataflow