.NET Core 高性能队列 Channels 使用

小渣渣

System.Threading.Channels 是 .NET Core 3.0 后推出的新的集合类型, 具有异步API,高性能，线程安全等特点，它可以用来做消息队列，进行数据的生产和消费, 公开的 Writer 和 Reader api对应消息的生产者和消费者，也让Channel更加的简洁和易用，与Rabbit MQ 等其他队列不同的是，Channel 是进程内的队列。

.NET/C# 基于 BlockingCollection 后台任务队列
https://www.itsvse.com/thread-9528-1-1.html

System.Threading.Channels 库：超链接登录可见。
Channel<T> 类：超链接登录可见。

Channel 类型

微软提供了两种类型的 channel，一种是有限容量的 bound channel，一种是无限容量的 unbound channel。

创建有限容量的 Channel：Channel.CreateBounded<string>(100);
创建无限容量的 Channel：Channel.CreateUnbounded<string>();

创建无限的 Channel

创建  Channel 时，可以设置 ChannelOptions 的 SingleWriter 和 SingleReader，来指定 Channel 时单一的生产者和消费者，默认都是 false，当设置了 SingleWriter = true 时, 会限制同一个时间只能有一个生产者可以写入数据, SingleReader = true 是同样的。


尝试开启三个生产者线程和一个消费者线程，代码如下：

登录可见。

消费者使用 WaitToReadAsync 等待读取数据。 数据可用后，消费者才会尝试读取数据。


在上面的代码中，消费者都是一条一条的读取数据执行操作，如何让消费者批量消费数据一块处理呢？

新建 ChannelReaderExtensions 扩展，代码如下：

登录可见。

调整消费者代码如下：

登录可见。

（完）

飞鱼

学习学习

zgy0209zgy

学习学习

qiuyueming

学习学习