Channels： C# 实现高效的线程间通信

admin管理员组

文章数量:1438480

Channels： C# 实现高效的线程间通信

在C#中，Channel是.NET Core 3.0及更高版本引入的一种新的集合类型，位于System.Threading.Channels命名空间下。主要用于实现生产者-消费者模式，支持异步编程、高性能和线程安全。

应用场景

• • 生产者-消费者模式：最典型的应用场景。
• • 流水线模式：多个步骤通过Channel传递数据。
• • 发布-订阅模式：生产者发布消息，多个消费者订阅。

安装

在使用 .NET Core 或 .NET 5/6 时，默认包含的。如果项目中没有这个库，可以使用 NuGet 包管理器安装：

代码语言：javascript代码运行次数：0运行复制

dotnet add package System.Threading.Channels

1. Channel的类型

• 无界通道（Unbounded Channel）：可以容纳任意数量的元素。创建方式如下：

代码语言：javascript代码运行次数：0运行复制

var channel = Channel.CreateUnbounded<int>();

• 有界通道（Bounded Channel）：具有最大容量限制。创建方式如下：

代码语言：javascript代码运行次数：0运行复制

var channel = Channel.CreateBounded<int>(10); // 最大容量为10

2. Channel的使用

• 生产者：通过channel.Writer.WriteAsync()方法写入数据。

代码语言：javascript代码运行次数：0运行复制

await channel.Writer.WriteAsync(data);

• 消费者：通过channel.Reader.ReadAllAsync()或channel.Reader.WaitToReadAsync()读取数据。

代码语言：javascript代码运行次数：0运行复制

await foreach (var item in channel.Reader.ReadAllAsync())
{
    Console.WriteLine(item);
}

3. Channel的配置

• • 单生产者/单消费者模式：可以通过SingleWriter和SingleReader属性设置。
• • 满时策略（FullMode）：当有界通道已满时，可以选择以下策略：
  • • Wait：等待直到有空间。
  • • DropNewest：丢弃最新数据。
  • • DropOldest：丢弃最旧数据。
  • • DropWrite：丢弃写入的数据。

4. 高级用法

• 批量处理：可以一次读取多个元素。

代码语言：javascript代码运行次数：0运行复制

IAsyncEnumerable<int> batch = channel.Reader.ReadBatchAsync(10);

• 取消令牌（CancellationToken）：支持取消读取或写入操作。

代码语言：javascript代码运行次数：0运行复制

await channel.Reader.WaitToReadAsync(cts.Token);

示例：生产者消费者模式

代码语言：javascript代码运行次数：0运行复制

using System;
using System.Threading.Channels;
using System.Threading.Tasks;

classProgram
{
    static async Task Main(string[] args)
    {
        var channel = Channel.CreateUnbounded<int>();

        // 启动生产者和消费者
        var producerTask = ProduceItems(channel);
        var consumerTask = ConsumeItems(channel);

        // 等待任务完成
        await Task.WhenAll(producerTask, consumerTask);
    }

    static async Task ProduceItems(Channel<int> channel)
    {
        for (int i = 0; i < 10; i++)
        {
            await channel.Writer.WriteAsync(i);
            Console.WriteLine($"Produced: {i}");
        }
        channel.Writer.Complete(); // 完成写入
    }

    static async Task ConsumeItems(Channel<int> channel)
    {
        awaitforeach (var item in channel.Reader.ReadAllAsync())
        {
            Console.WriteLine($"Consumed: {item}");
        }
    }
}

总结

C# Channels是一种强大的异步编程工具，适用于处理并发和流式数据。

本文参与 腾讯云自媒体同步曝光计划，分享自微信公众号。原始发表：2025-04-21，如有侵权请联系 cloudcommunity@tencent 删除线程异步编程c#channel数据

本文标签： Channels C 实现高效的线程间通信