BufferBlockT

(FIFO 队列:进来的数据是输出的数据)

简而言之,BufferBlock 提供了一个无限制或有界缓冲区来存储 T 的实例。
你可以将 T 的实例发布到块中,这会导致发布的数据以先进先出(FIFO)顺序存储在街区。
你可以从块中接收,这允许你同步或异步地获取以前存储或将来可用的 T 的实例(同样,FIFO)。

StackOverflow 文档

具有限制生产者的异步生产者/消费者

// Hand-off through a bounded BufferBlock<T>
private static BufferBlock<int> _Buffer = new BufferBlock<int>(
    new DataflowBlockOptions { BoundedCapacity = 10 });

// Producer
private static async void Producer()
{
    while(true)
    {
        await _Buffer.SendAsync(Produce());
    }
}

// Consumer
private static async Task Consumer()
{
    while(true)
    {
        Process(await _Buffer.ReceiveAsync());
    } 
}

// Start the Producer and Consumer
private static async Task Run()
{
    await Task.WhenAll(Producer(), Consumer());
}

Stephen Toub 介绍 TPL 数据流