c# blockingcollection怎样处理并发操作

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> 实例，并启动了两个生产者线程和一个消费者线程。生产者线程尝试向集合中添加元素，如果集合已满，则等待。消费者线程尝试从集合中获取元素，如果集合为空，则等待。这样，我们就实现了一个简单的并发操作处理。