链接数据流块完成不起作用

Question

我有一个链接到ActionBlock 的BroadcastBlock。当我在BroadcastBlock 和ActionBlock 上依次调用“完成”时，它不起作用。而仅在 BroadCastBlock 上调用“完成”就可以了。

public class ActionTester
{
    private readonly ActionBlock<int> _action;
    private readonly BroadcastBlock<int> _input;

    public ActionTester()
    {
        _input = new BroadcastBlock<int>(null);
        _action = new ActionBlock<int>(i => Process(i));

        _input.LinkTo(_action, new DataflowLinkOptions { PropagateCompletion = true });
    }

    public void Post(int i) => _input.Post(i);

    public async Task Process(int i)
    {
        await Task.Delay(2000);
        Console.WriteLine(i);
    }

    public void Complete()
    {
        _input.Complete();
        _action.Complete(); // When this is removed, program is working as expected
    }

    public Task Completion => _action.Completion;
}

测试代码是

static void Main(string[] args)
{
    var actor = new ActionTester();

    actor.Post(5);
    actor.Post(7);

    actor.Complete();
    actor.Completion.Wait();

    Console.WriteLine("Finished");
    Console.Read();
}

当_action.Complete() 存在时（注释行），代码将移过actor.Completion.wait() 并显示“已完成”。如果我删除_aciton.Complete()，则发布的值会正确显示，然后写入“完成”。

当数据流块被链接时，我们应该只调用根块的“完成”吗？将PropagateCompletion 设置为 true/false 无效。

解决方案

通过等待根块完成来解决

public void Complete()
{
    _input.Complete();
    _input.Completion.Wait();
    _action.Complete(); 
}

Answer 1

当数据流块被链接时，我们应该只调用根块的“完成”吗？

是的，这正是你应该做的。

如果您确实传播了Completion，那么您确实不需要需要自己完成_actionBlock - 它会在处理完缓冲区中的所有项目后完成。完成操作块后，它不会接受任何新消息，因此所描述的行为是预期的且有效的。