C#缓冲块

2023-06-05 17:15:04 534

例子

（FIFOQueue：进来的数据就是出去的数据）

简而言之，BufferBlock提供了一个无界或有界缓冲区来存储T的实例。
您可以将T的实例“发布”到块中，这会导致发布的数据以先进先出(FIFO)顺序存储由块。
您可以从块中“接收”，这允许您同步或异步获取先前存储或将来可用的T实例（再次，FIFO）。

具有节流生产者的异步生产者/消费者

// Hand-off through a bounded BufferBlock
private 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数据流的介绍

C#缓冲块

例子

热门推荐

随机推荐