C TPL Dataflow BatchBlock 等待完成永远不会返回答案

【问题标题】：C TPL Dataflow BatchBlock await Completion never returnsC TPL Dataflow BatchBlock 等待完成永远不会返回
【发布时间】：2018-11-16 21:07:59
【问题描述】：

我创建了一个小测试程序来说明我的问题

class Item
{
    public string Name;
}

class Program
{
    static BatchBlock<Item> items = new BatchBlock<Item>(2);
    static ConcurrentBag<Item> bag = new ConcurrentBag<Item>();

    public static async Task Main(string[] args)
    {
        var insertItems = new ActionBlock<Item[]>(b => BatchProcessor(b));
        items.LinkTo(insertItems);
        var finished = items.Completion.ContinueWith(delegate { insertItems.Complete(); }).ConfigureAwait(false);

        Console.WriteLine("From main 1");
        items.Post(new Item() { Name = "1" });

        Console.WriteLine("From main 2");
        items.Post(new Item() { Name = "2" });

        Console.WriteLine("From main 3");
        items.Post(new Item() { Name = "3" });

        Console.WriteLine("From main 4");
        items.Post(new Item() { Name = "4" });

        Console.WriteLine("From main 5");
        items.Post(new Item() { Name = "5" });

        Console.WriteLine("From main 6");
        items.Post(new Item() { Name = "6" });

        Console.WriteLine("From main 7");
        items.Post(new Item() { Name = "7" });

        Console.WriteLine("Finishing");
        items.TriggerBatch();

        await items.Completion; // Never completes!!!
    }

    static void BatchProcessor(Item[] items)
    {
        Console.WriteLine("Callback");
        foreach(var i in items)
        {
            Console.WriteLine("From Callback " + i.Name);
            bag.Add(i);
        }
    }
}

控制台输出如预期：

From main 1
From main 2
From main 3
From main 4
From main 5
From main 6
From main 7
Finishing
Callback
From Callback 1
From Callback 2
Callback
From Callback 3
From Callback 4
Callback
From Callback 5
From Callback 6
Callback
From Callback 7

我错过了什么？

【问题讨论】：

我相信items.Completion.ContinueWith(delegate { insertItems.Complete(); }) 是蛇吃自己的尾巴，只有在Completion 解决后才能完成批处理，只有在您调用Complete() 后才会解决。

标签： c# tpl-dataflow

【解决方案1】：

向区块发送数据后，您需要致电Complete。

这个：

await items.Completion;

为了等待整个流程的完成，确实应该是：

items.Complete()
await insertItems.Completion;

最后，您可以链接块来传播完成，因此在这种情况下，ContinueWith 是不必要的。

这个：

items.Completion.ContinueWith(delegate { insertItems.Complete(); }).ConfigureAwait(false);

可以替换为：

items.LinkTo(insertItems, new DataflowLinkOptions() { PropagateCompletion = true });

【讨论】：