C# BlockingCollection的用法 - 生产者-消费者模式的利器

BlockingCollection是C#中专为线程安全生产者-消费者场景设计的核心类型，封装ConcurrentQueue等容器，提供阻塞添加/消费、CompleteAdding()结束通知、超时与取消支持及自定义底层容器能力。

BlockingCollection 是 C# 中专为线程安全的生产者-消费者场景设计的核心类型，它封装了线程安全的队列（默认 ConcurrentQueue<t></t>），自动处理阻塞、取消和完成通知，让多线程协作变得简洁可靠。

基础用法：创建、添加与消费

只需指定内部容器（可选）和最大容量，就能快速启用阻塞行为：

• 无参构造：使用默认 ConcurrentQueue<t></t>，无限容量
• 指定容量（如 new BlockingCollection<int>(10)</int>）：Add() 在满时阻塞，Take() 在空时阻塞
• Add(item) 和 Take() 是最常用方法，线程安全且自带阻塞语义

优雅结束：CompleteAdding 与 IsCompleted

当所有生产者完成投递，需显式调用 CompleteAdding()，否则消费者调用 Take() 会一直阻塞等待新项：

• 调用后，IsCompleted 返回 true，且后续 Add() 抛出异常
• 消费者可通过 GetConsumingEnumerable() 遍历——它会在完成添加后自动退出循环
• 示例：foreach (var item in collection.GetConsumingEnumerable()) { /* 处理 */ }

带超时与取消：更可控的阻塞操作

避免无限等待，可用重载方法传入 TimeSpan 或 CancellationToken：