TPL数据流从所有传入节点(多个生产者，1个消费者)创建聚合结果数组

using System;
using System.Collections.Generic;
using System.Threading.Tasks;
using System.Threading.Tasks.Dataflow;

public class Program
{
    public static async Task Main()
    {
        var bufferBlock = new BufferBlock<int>(); // 创建一个BufferBlock作为数据流块

        var producers = new List<Task>(); // 存储生产者任务的列表

        // 创建多个生产者任务
        for (int i = 0; i < 5; i++)
        {
            var producer = Task.Run(async () =>
            {
                for (int j = 0; j < 10; j++)
                {
                    await bufferBlock.SendAsync(j); // 向BufferBlock发送数据
                }
            });

            producers.Add(producer);
        }

        var consumer = Task.Run(async () =>
        {
            var result = new List<int>(); // 存储聚合结果的数组

            // 从BufferBlock接收数据直到所有生产者任务完成并且BufferBlock为空
            while (producers.Any() || bufferBlock.Count > 0)
            {
                var data = await bufferBlock.ReceiveAsync(); // 从BufferBlock接收数据
                result.Add(data);
            }

            Console.WriteLine("聚合结果数组：");
            foreach (var item in result)
            {
                Console.WriteLine(item);
            }
        });

        await Task.WhenAll(producers); // 等待所有生产者任务完成
        await consumer; // 等待消费者任务完成
    }
}