BlockingCollection 是 .NET 集合框架中的一个类，它提供了一种线程安全的集合，可以用于在生产者和消费者线程之间传递数据。它可以处理阻塞操作，以确保在生产者向集合中添加元素时，消费者不会在集合为空时尝试获取元素，反之亦然。
以下是使用 BlockingCollection 处理阻塞操作的一个简单示例：
using System; using System.Collections.Concurrent; using System.Threading; class Program { static BlockingCollection<int> _blockingCollection = new BlockingCollection<int>(); static void Main(string[] args) { // 创建一个生产者线程 Thread producerThread = new Thread(() => { for (int i = 0; i < 10; i++) { Console.WriteLine($"生产者生产了: {i}"); _blockingCollection.Add(i); Thread.Sleep(1000); // 模拟生产过程耗时 } _blockingCollection.CompleteAdding(); // 通知消费者不再有新的元素添加 }); // 创建一个消费者线程 Thread consumerThread = new Thread(() => { while (!_blockingCollection.IsCompleted) // 当集合未完成时，继续循环 { int item = _blockingCollection.Take(); // 从集合中获取元素，如果集合为空，则阻塞线程 Console.WriteLine($"消费者消费了: {item}"); Thread.Sleep(2000); // 模拟消费过程耗时 } }); // 启动生产者和消费者线程 producerThread.Start(); consumerThread.Start(); // 等待线程执行完成 producerThread.Join(); consumerThread.Join(); Console.WriteLine("所有操作已完成"); } } 在这个示例中，我们创建了一个 BlockingCollection<int> 实例，用于在生产者和消费者线程之间传递整数。生产者线程向集合中添加元素，消费者线程从集合中获取元素。当集合为空时，消费者线程会被阻塞，直到生产者线程向集合中添加新元素。同样，当集合中的所有元素都被消费完毕时，生产者线程会被阻塞，直到消费者线程从集合中获取元素。
BlockingCollection 还提供了其他方法，如 TryAdd() 和 TryTake()，它们在无法添加或获取元素时会立即返回，而不是阻塞线程。这可以在某些情况下提供更好的性能。
