分叉结构TPL Dataflow管道如何正确等待所有任务执行完成？

这个现象不是随机竞态，是PropagateCompletion配置的默认行为导致的必然结果：当多个源块同时链接到同一个目标块时，只要任意一个源块完成并传播完成信号，目标块就会立刻进入完成状态，不再接收其他源块后续发来的剩余消息。
你的代码中，处理偶数的fork1没有处理延迟，会比加了100ms阻塞的fork2早很多完成。fork1完成时会通过开启的PropagateCompletion直接将printBlock标记为完成，此时fork2中尚未处理完的奇数消息会被直接丢弃，最终只能输出全部偶数。

不要在两个分叉传播块到最终目标块的链接上开启PropagateCompletion，改为手动控制最终块的完成时机：

• 保留起始bufferBlock到两个分叉块的PropagateCompletion配置，保证起始块完成后两个分叉块能正常收到结束信号
• 关闭两个分叉块到最终printBlock的完成传播
• 投递完所有消息后，先等待两个分叉块全部处理并转发完自身所有消息，再主动标记最终块为完成，等待最终块处理结束

修复后的可运行代码如下：

internal static class Program
{
    public static async Task Main(string[] args)
    {
        // 起始块到分叉块的链接保留完成传播
        var forkLinkOptions = new DataflowLinkOptions
        {
            PropagateCompletion = true
        };
        // 分叉块到最终块的链接关闭自动完成传播
        var finalLinkOptions = new DataflowLinkOptions
        {
            PropagateCompletion = false
        };
        
        var bufferBlock = new BufferBlock<int>();
        var fork1 = new TransformBlock<int, int>(n => n);
        var fork2 = new TransformBlock<int, int>(async n =>
        {
            // 原阻塞Thread.Sleep替换为异步Delay更符合TPL Dataflow异步设计，保留Thread.Sleep也不影响修复效果
            await Task.Delay(100);
            return n;
        });
        var printBlock = new ActionBlock<int>(Console.WriteLine);

        bufferBlock.LinkTo(fork1, forkLinkOptions, n => n % 2 == 0);
        bufferBlock.LinkTo(fork2, forkLinkOptions, n => n % 2 != 0);
        
        fork1.LinkTo(printBlock, finalLinkOptions);
        fork2.LinkTo(printBlock, finalLinkOptions);
        
        for (var n = 1; n <= 10; ++n)
        {
            bufferBlock.Post(n);
        }
        bufferBlock.Complete();

        // 等待两个分叉块全部处理完成
        await Task.WhenAll(fork1.Completion, fork2.Completion);
        // 确认所有上游消息都已转发后，再标记最终块完成
        printBlock.Complete();
        await printBlock.Completion;
    }
}

运行上述代码可以稳定输出全部10个数字，不会再出现部分消息丢失的问题。这种手动控制完成时机的方式还能更灵活地处理上游块的异常，避免默认传播机制只传递第一个到达的异常、屏蔽其他块异常的问题。

内容的提问来源于stack exchange，提问作者Tohnmeister