C#缓冲块
例子
（FIFOQueue：进来的数据就是出去的数据）
简而言之，BufferBlock提供了一个无界或有界缓冲区来存储T的实例。
您可以将T的实例“发布”到块中，这会导致发布的数据以先进先出(FIFO)顺序存储由块。
您可以从块中“接收”，这允许您同步或异步获取先前存储或将来可用的T实例（再次，FIFO）。
具有节流生产者的异步生产者/消费者
// Hand-off through a bounded BufferBlockprivate static BufferBlock _Buffer = new BufferBlock ( new DataflowBlockOptions { BoundedCapacity = 10 }); //制作人 private static async void Producer() { while(true) { await _Buffer.SendAsync(Produce()); } } //消费者 private static async Task Consumer() { while(true) { Process(await _Buffer.ReceiveAsync()); } } //启动生产者和消费者 private static async Task Run() { await Task.WhenAll(Producer(), Consumer()); }
StephenToub对TPL数据流的介绍