BlockingCollection是C#中专为线程安全生产者-消费者场景设计的核心类型，封装ConcurrentQueue等容器，提供阻塞添加/消费、CompleteAdding()结束通知、超时与取消支持及自定义底层容器能力。
<img src="https://img.php.cn/upload/article/001/221/864/176519671762952.png" alt="c# blockingcollection的用法 – 生产者-消费者模式的利器”>
BlockingCollection 是 C# 中专为线程安全的生产者-消费者场景设计的核心类型，它封装了线程安全的队列（默认 ConcurrentQueue），自动处理阻塞、取消和完成通知，让多线程协作变得简洁可靠。
基础用法：创建、添加与消费
只需指定内部容器（可选）和最大容量，就能快速启用阻塞行为：
无参构造：使用默认 ConcurrentQueue，无限容量指定容量（如 new BlockingCollection(10)）：Add() 在满时阻塞，Take() 在空时阻塞Add(item) 和 Take() 是最常用方法，线程安全且自带阻塞语义
优雅结束：CompleteAdding 与 IsCompleted
当所有生产者完成投递，需显式调用 CompleteAdding()，否则消费者调用 Take() 会一直阻塞等待新项：
调用后，IsCompleted 返回 true，且后续 Add() 抛出异常消费者可通过 GetConsumingEnumerable() 遍历——它会在完成添加后自动退出循环示例：foreach (var item in collection.GetConsumingEnumerable()) { /* 处理 */ }
带超时与取消：更可控的阻塞操作
避免无限等待，可用重载方法传入 TimeSpan 或 CancellationToken：
TryAdd(item, TimeSpan.FromMilliseconds(500))：超时返回 falseTryTake(out item, TimeSpan.FromSeconds(1))：空时等待 1 秒后返回 falseTake(cancellationToken)：支持协作式取消，适合长任务中响应中断
进阶技巧：自定义容器与批量操作
BlockingCollection 不限于队列，还可包装 ConcurrentStack（LIFO）或 ConcurrentBag（无序）：
new BlockingCollection(new ConcurrentStack()) 实现栈式消费注意：不同底层容器影响遍历顺序和性能特征，但阻塞逻辑保持一致不直接支持批量 Add/Take，但可通过循环 + 超时控制实现“尽力批量”逻辑
基本上就这些。BlockingCollection 的价值不在功能繁多，而在把生产者-消费者中最容易出错的同步、边界、生命周期问题都收束到几个简单方法里——写对一次，线程安全就有了保障。
以上就是C# BlockingCollection的用法 – 生产者-消费者模式的利器的详细内容，更多请关注创想鸟其它相关文章！
版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。
如发现本站有涉嫌抄袭侵权/违法违规的内容， 请发送邮件至 chuangxiangniao@163.com 举报，一经查实，本站将立刻删除。
发布者：程序猿，转转请注明出处：https://www.chuangxiangniao.com/p/1442802.html
微信扫一扫 
支付宝扫一扫 
