C#缓冲块

例子

(FIFO Queue:进来的数据就是出去的数据)

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

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

// Hand-off through a bounded BufferBlock<T>

private static BufferBlock<int> _Buffer = new BufferBlock<int>(

    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());

}

Stephen Toub 对 TPL 数据流的介绍

以上是 C#缓冲块 的全部内容, 来源链接: utcz.com/z/331728.html

回到顶部