BlockingCollection.GetConsumingEnumerable 是一个线程安全的消费式枚举器，每次 MoveNext() 移除并返回一个元素，配合 CompleteAdding() 自动终止；不可超时、不可取消、不可重入，需用 foreach 安全遍历，异常需外层捕获。
BlockingCollection.GetConsumingEnumerable 是什么
它不是普通迭代器，而是一个「消费式枚举器」：每次 MoveNext() 都会从 BlockingCollection 中 移除并返回 一个元素；一旦集合被标记为完成添加（CompleteAdding()）且内部为空，枚举就会自然结束。
它本质是为「生产者-消费者」场景设计的简化循环写法，替代手动调用 Take() 并捕获 InvalidOperationException 的繁琐逻辑。
怎么安全地用在多线程消费循环里
- 必须搭配
CompleteAdding() 使用——否则枚举永远不会退出，即使集合已空，也会一直阻塞等待新元素
- 不能在多个线程中同时调用同一个
GetConsumingEnumerable() 返回的枚举器（它不是线程安全的），但可以多个线程各自调用 GetConsumingEnumerable() 获取独立枚举器（每个都独占消费路径）
- 推荐配合
foreach 使用，不要手动调用 GetEnumerator() + MoveNext()，避免意外跳过 Dispose 导致资源未释放
- 如果消费逻辑可能抛异常，建议在
foreach 外层包 try/catch，否则异常会中断整个枚举，后续元素不再处理
var collection = new BlockingCollection();
// 启动消费者线程
Task.Run(() =>
{
foreach (var item in collection.GetConsumingEnumerable())
{
Console.WriteLine($"处理: {item}");
// 模拟耗时操作
Thread.Sleep(100);
}
Console.WriteLine("消费者退出");
});
// 生产者：添加 3 个项，然后完成添加
collection.Add("A");
collection.Add("B");
collection.Add("C");
collection.CompleteAdding(); // ⚠️ 这行必不可少
和 Take()、TryTake() 的关键区别
-
Take()：阻塞直到有元素或被取消，失败时抛 InvalidOperationException（如已 CompleteAdding() 且为空）
-
TryTake(out T, int)：非阻塞或带超时，返回 bool 表示是否取到，适合需要控制等待时间的场景
-
GetConsumingEnumerable()：隐式阻塞 + 自动判空 + 自动终止，语义更清晰，但**不可中断、不可超时、不可重入**
CompleteAdding() 使用——否则枚举永远不会退出，即使集合已空，也会一直阻塞等待新元素GetConsumingEnumerable() 返回的枚举器（它不是线程安全的），但可以多个线程各自调用 GetConsumingEnumerable() 获取独立枚举器（每个都独占消费路径）foreach 使用，不要手动调用 GetEnumerator() + MoveNext()，避免意外跳过 Dispose 导致资源未释放foreach 外层包 try/catch，否则异常会中断整个枚举，后续元素不再处理-
Take()：阻塞直到有元素或被取消，失败时抛InvalidOperationException（如已CompleteAdding()且为空） -
TryTake(out T, int)：非阻塞或带超时，返回bool表示是否取到，适合需要控制等待时间的场景 -
GetConsumingEnumerable()：隐式阻塞 + 自动判空 + 自动终止，语义更清晰，但**不可中断、不可超时、不可重入**
如果你需要超时、取消或多次复用同一集合做不同逻辑的消费，请别用 GetConsumingEnumerable()，改用 Take() 或 TryTake() 配合循环。
容易踩的坑：CompleteAdding 调用时机 & 异常后状态
- 忘了调用
CompleteAdding() → 消费者线程永久挂起，CPU 不占但线程卡死
- 在生产者还没结束时就调了
CompleteAdding() → 后续 Add() 会立即抛 InvalidOperationException
- 消费过程中抛未捕获异常 → 枚举器终止，但集合本身状态不变，其他正在调用
GetConsumingEnumerable() 的线程仍可继续消费剩余元素（只要没被 Complete）
-
BlockingCollection 被 dispose 后再调用 GetConsumingEnumerable() → 抛 ObjectDisposedException
CompleteAdding() → 消费者线程永久挂起，CPU 不占但线程卡死CompleteAdding() → 后续 Add() 会立即抛 InvalidOperationException
GetConsumingEnumerable() 的线程仍可继续消费剩余元素（只要没被 Complete）BlockingCollection 被 dispose 后再调用 GetConsumingEnumerable() → 抛 ObjectDisposedException
最常被忽略的是：这个枚举器不响应 CancellationToken，也不能传入超时参数。真要支持取消，得自己包装一层，用 TryTake() 循环 + IsCancellationRequested 判断。
