c# blockingcollection如何处理阻塞操作

BlockingCollection 是 .NET 集合框架中的一个类，它提供了一种线程安全的集合，可以用于在生产者和消费者线程之间传递数据。它可以处理阻塞操作，以确保在生产者向集合中添加元素时，消费者不会在集合为空时尝试获取元素，反之亦然。

以下是使用 BlockingCollection 处理阻塞操作的一个简单示例：

using System;
using System.Collections.Concurrent;
using System.Threading;

class Program
{
    static BlockingCollection _blockingCollection = new BlockingCollection();

    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 实例，用于在生产者和消费者线程之间传递整数。生产者线程向集合中添加元素，消费者线程从集合中获取元素。当集合为空时，消费者线程会被阻塞，直到生产者线程向集合中添加新元素。同样，当集合中的所有元素都被消费完毕时，生产者线程会被阻塞，直到消费者线程从集合中获取元素。

BlockingCollection 还提供了其他方法，如 TryAdd() 和 TryTake()，它们在无法添加或获取元素时会立即返回，而不是阻塞线程。这可以在某些情况下提供更好的性能。