当前位置：首页 > news >正文

C#并发编程新宠：Channel通道全解析（第一部分）

news 2026/3/26 19:35:48

简介

Channel的诞生背景

核心概念模型

创建Channel

写入Channel

读取Channel

完整示例

实践练习

核心要点

简介

你可能早已听说过async、await任务等概念，但在多线程间安全传输数据时，大多数人还是给List加个锁然后祈祷系统不会崩溃。现在，让我们认识Channel——.NET并发编程中被低估的王者。

这是C#通道系列教程的第一部分，记得订阅以便接收后续更新。

可以把Channel想象成线程安全的邮箱：一端投递信件，另一端取出信件。无需锁机制，天生支持异步操作。

本文将深入浅出，展示生产者如何轻松向消费者传递消息，既不费力也不消耗CPU。读完本篇，你不仅能掌握Channel的工作原理，还能为后续更复杂的模式打下基础。

Channel的诞生背景

坦白说，如果你用C#编写多线程代码，大概率曾与ConcurrentQueue、BlockingCollection纠缠过，或手动给List加锁。这些方案确实能用...但也就勉强能用。当你需要非阻塞线程的异步操作时怎么办？当单个生产者需要向异步运行的消费者发送数百条消息时又该如何？

Channel优雅地解决了这些问题，它提供：

• 生产者与消费者间的线程安全通信
• 原生异步API，无需手动阻塞线程
• 明确的读写分离（ChannelWriter与ChannelReader）

就像现实中的邮箱，一端投信另一端取信，即使多线程同时操作也不会引发混乱。

核心概念模型

接触代码前，先建立最简心智模型：
生产者 → Channel → 消费者

• 生产者：向通道推送消息
• Channel：安全存储消息并处理线程同步
• 消费者：从通道读取消息（支持异步）

后续我们会扩展至多生产者/消费者场景，目前先聚焦单读写器模式。

创建Channel

.NET让通道创建变得轻而易举：

using System; using System.Threading.Channels; using System.Threading.Tasks; var channel = Channel.CreateUnbounded<int>(); // 无边界通道 Console.WriteLine("Channel created!");

仅需一行代码，你就获得了可用的通信邮箱。现在你拥有了包含两个核心组件的Channel：

• channel.Writer → 生产者写入端
• channel.Reader → 消费者读取端

写入Channel

来看生产者的实际运作：

async Task ProduceAsync(ChannelWriter<int> writer) { for (int i = 1; i <= 5; i++) { await writer.WriteAsync(i); // 将数据存入通道 Console.WriteLine($"Produced: {i}"); await Task.Delay(500); // 模拟工作负载 } writer.Complete(); // 发出完成信号 }

注意：

• WriteAsync体现通道的异步优先特性
• Task.Delay仅用于模拟实际生产中的处理过程
• writer.Complete()通知消费者数据流已终止

读取Channel

消费者端的实现：

async Task ConsumeAsync(ChannelReader<int> reader) { await foreach (var item in reader.ReadAllAsync()) { Console.WriteLine($"Consumed: {item}"); } }

关键特性：

• ReadAllAsync()自动等待新项目直到通道关闭
• 无需锁机制，无需自旋循环
• 生产者调用Complete()后消费者自动结束

完整示例

以下是整合生产者与消费者的最小控制台程序：

using System; using System.Threading.Channels; using System.Threading.Tasks; classProgram { static async Task Main() { var channel = Channel.CreateUnbounded<int>(); var producer = ProduceAsync(channel.Writer); var consumer = ConsumeAsync(channel.Reader); await Task.WhenAll(producer, consumer); } static async Task ProduceAsync(ChannelWriter<int> writer) { for (int i = 1; i <= 5; i++) { await writer.WriteAsync(i); Console.WriteLine($"Produced: {i}"); await Task.Delay(500); // 模拟工作负载 } writer.Complete(); } static async Task ConsumeAsync(ChannelReader<int> reader) { awaitforeach (var item in reader.ReadAllAsync()) { Console.WriteLine($"Consumed: {item}"); } } }

运行后将看到数字几乎同步被生产和消费。这个简洁优雅的示例完美诠释了核心概念。