BlockingCollection是C#中专为线程安全生产者-消费者场景设计的核心类型，封装ConcurrentQueue等容器，提供阻塞添加/消费、CompleteAdding()结束通知、超时与取消支持及自定义底层容器能力。
BlockingCollectionConcurrentQueue<t></t>），自动处理阻塞、取消和完成通知，让多线程协作变得简洁可靠。
只需指定内部容器（可选）和最大容量，就能快速启用阻塞行为：
ConcurrentQueue<t></t>，无限容量new BlockingCollection<int>(10)</int>）：Add() 在满时阻塞，Take() 在空时阻塞Add(item) 和 Take() 是最常用方法，线程安全且自带阻塞语义当所有生产者完成投递，需显式调用 CompleteAdding()，否则消费者调用 Take() 会一直阻塞等待新项：
IsCompleted 返回 true，且后续 Add() 抛出异常GetConsumingEnumerable() 遍历——它会在完成添加后自动退出循环foreach (var item in collection.GetConsumingEnumerable()) { /* 处理 */ }
避免无限等待，可用重载方法传入 TimeSpan 或 CancellationToken：
TryAdd(item, TimeSpan.FromMilliseconds(500))：超时返回 false
TryTake(out item, TimeSpan.FromSeconds(1))：空时等待 1 秒后返回 false
Take(cancellationToken)：支持协作式取消，适合长任务中响应中断BlockingCollection 不限于队列，还可包装 ConcurrentStack<t></t>（LIFO）或 ConcurrentBag<t></t>（无序）：
new BlockingCollection<string>(new ConcurrentStack<string>())</string></string> 实现栈式消费基本上就这些。BlockingCollection 的价值不在功能繁多，而在把生产者-消费者中最容易出错的同步、边界、生命周期问题都收束到几个简单方法里——写对一次，线程安全就有了保障。
以上就是C# BlockingCollection的用法 - 生产者-消费者模式的利器的详细内容，更多请关注php中文网其它相关文章！
每个人都需要一台速度更快、更稳定的 PC。随着时间的推移，垃圾文件、旧注册表数据和不必要的后台进程会占用资源并降低性能。幸运的是，许多工具可以让 Windows 保持平稳运行。
广告Copyright 2014-2025 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号
346
收藏
