在C#的System.Threading.Channels命名空间下，Channel提供了两种核心的模式，分别是Bounded和Unbounded，二者的核心差异体现在容量限制和背压处理机制上，会直接影响生产者消费者模型的运行表现。
Bounded和Unbounded的基础定义
Bounded模式即有限容量通道，创建时需要指定通道的最大可存储消息数量，当通道内消息数量达到上限时，写入操作会根据配置的策略进行处理。Unbounded模式即无限容量通道，没有预设的消息存储上限，写入操作默认不会因容量问题被阻塞。
核心差异对比
两种模式的核心区别可以通过下表直观查看：
| 对比维度 | Bounded模式 | Unbounded模式 |
|---|---|---|
| 容量限制 | 有固定最大容量，创建时指定 | 无固定容量，理论上可无限存储 |
| 写入行为 | 容量满时，写入可能阻塞、抛异常或丢弃消息 | 写入操作默认立即完成，无容量阻塞 |
| 背压支持 | 原生支持背压，可调节生产者写入速度 | 无原生背压，生产者可无限制写入 |
| 内存风险 | 内存占用可控，不会因消息堆积无限增长 | 若消费者处理慢，可能导致内存溢出 |
| 适用场景 | 生产者速度可能快于消费者、需要控制资源占用 | 生产者速度稳定慢于消费者、消息量可控 |
创建方式差异
两种模式的创建需要调用不同的工厂方法，并且参数配置也有区别。
Bounded模式创建
创建时需要传入 BoundedChannelOptions 对象，其中 Capacity 是必填参数，用来指定最大容量，还可以配置写入满时的处理策略。
using System.Threading.Channels;
// 创建容量为10的Bounded通道，满时写入任务会等待
var boundedChannel = Channel.CreateBounded<int>(new BoundedChannelOptions(10)
{
FullMode = BoundedChannelFullMode.Wait // 满时等待，可选值还有DropNewest、DropOldest、DropWrite
});
// 生产者写入示例
async Task ProducerBounded(ChannelWriter<int> writer)
{
for (int i = 0; i < 20; i++)
{
await writer.WriteAsync(i);
Console.WriteLine($"Bounded通道写入: {i}");
}
writer.Complete();
}
// 消费者读取示例
async Task ConsumerBounded(ChannelReader<int> reader)
{
while (await reader.WaitToReadAsync())
{
while (reader.TryRead(out var item))
{
Console.WriteLine($"Bounded通道读取: {item}");
await Task.Delay(100); // 模拟处理耗时
}
}
}
Unbounded模式创建
创建时不需要指定容量，可选择传入 UnboundedChannelOptions 配置其他属性，默认写入不会阻塞。
using System.Threading.Channels;
// 创建Unbounded通道
var unboundedChannel = Channel.CreateUnbounded<int>(new UnboundedChannelOptions
{
SingleWriter = false, // 是否允许单个生产者
SingleReader = false // 是否允许单个消费者
});
// 生产者写入示例
async Task ProducerUnbounded(ChannelWriter<int> writer)
{
for (int i = 0; i < 20; i++)
{
await writer.WriteAsync(i);
Console.WriteLine($"Unbounded通道写入: {i}");
// 生产者无阻塞，写入速度可以很快
}
writer.Complete();
}
// 消费者读取示例
async Task ConsumerUnbounded(ChannelReader<int> reader)
{
while (await reader.WaitToReadAsync())
{
while (reader.TryRead(out var item))
{
Console.WriteLine($"Unbounded通道读取: {item}");
await Task.Delay(500); // 消费者处理慢，消息会堆积在通道中
}
}
}
背压机制差异
背压是两种模式最关键的差异点。Bounded模式在容量满时，会根据 FullMode 的配置处理写入请求：如果配置为 Wait ，那么生产者的写入操作会异步等待，直到通道中有消息被消费者取出，腾出容量后再继续写入，天然实现了生产者的速度调节。如果配置为 DropNewest ，则新写入的消息会被丢弃，不会进入通道。
Unbounded模式没有内置的背压机制，只要生产者调用写入方法，消息就会被存入通道，不管消费者处理速度有多慢。如果生产者速度持续快于消费者，通道内的消息会不断堆积，最终可能导致内存溢出，因此使用Unbounded模式时需要确保消费者的处理速度能够匹配生产者，或者业务上允许短暂的消息堆积。
适用场景选择
实际开发中可以根据以下场景选择对应模式：
- 如果生产者产生消息的速度可能快于消费者处理速度，并且需要控制程序的内存占用，避免消息无限制堆积，优先选择Bounded模式，同时根据业务需求配置合适的
FullMode。 - 如果生产者速度稳定慢于消费者，或者消息总量本身可控，不会出现大量堆积的情况，可以选择Unbounded模式，简化写入逻辑，避免写入操作被阻塞。
- 如果业务对消息丢失零容忍，且可以接受生产者暂时等待，Bounded模式配置
Wait策略是最稳妥的选择。
注意事项
使用Bounded模式时，需要注意 Capacity 的设置要符合业务实际情况，设置过小会导致生产者频繁等待，影响吞吐量；设置过大则失去了限制内存的意义。使用Unbounded模式时，需要监控通道内的消息数量，避免出现内存泄漏问题。另外两种模式的读取逻辑是一致的，都通过 ChannelReader 的 WaitToReadAsync 和 TryRead 方法读取消息，写入都通过 ChannelWriter 的 WriteAsync 方法完成。
ChannelBounded_ChannelUnbounded_Channel异步编程生产者消费者修改时间：2026-06-18 06:36:47