BlockingCollection 是 .NET 集合框架中提供的一个线程安全的集合，它可以很好地处理并发操作。BlockingCollection 提供了 Add、TryAdd、Take 和 TryTake 等方法，这些方法在内部使用了锁和信号量来确保线程安全。
以下是一个简单的示例，展示了如何使用 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 producer1 = new Thread(Produce); Thread producer2 = new Thread(Produce); Thread consumer = new Thread(Consume); producer1.Start(); producer2.Start(); consumer.Start(); // 等待所有线程完成 producer1.Join(); producer2.Join(); consumer.Join(); } static void Produce() { for (int i = 0; i < 10; i++) { // 尝试向集合中添加元素，如果集合已满，则等待 _blockingCollection.TryAdd(i); Console.WriteLine($"Produced: {i}"); Thread.Sleep(100); // 模拟生产过程耗时 } } static void Consume() { while (true) { // 尝试从集合中获取元素，如果集合为空，则等待 int item = _blockingCollection.Take(); Console.WriteLine($"Consumed: {item}"); Thread.Sleep(200); // 模拟消费过程耗时 } } } 在这个示例中，我们创建了一个 BlockingCollection<int> 实例，并启动了两个生产者线程和一个消费者线程。生产者线程尝试向集合中添加元素，如果集合已满，则等待。消费者线程尝试从集合中获取元素，如果集合为空，则等待。这样，我们就实现了一个简单的并发操作处理。
