在.NET中创建阻塞队列<T>？

在.NET中，创建阻塞队列<T>可以使用System.Collections.Concurrent命名空间中的BlockingCollection<T>类。BlockingCollection<T>是一个线程安全的集合类，可以实现阻塞队列的功能，即当队列为空时，取数据的操作将会被阻塞，直到有新的数据被添加到队列中；当队列已满时，添加数据的操作也将被阻塞，直到有数据被移除出队列。

以下是一个简单的示例代码：

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

class Program
{
    static void Main(string[] args)
    {
        // 创建一个阻塞队列
        BlockingCollection<int> queue = new BlockingCollection<int>();

        // 创建一个生产者任务，向队列中添加数据
        Task producer = Task.Run(() =>
        {
            for (int i = 0; i < 10; i++)
            {
                queue.Add(i);
                Console.WriteLine($"Producer added {i} to the queue.");
            }
            queue.CompleteAdding();
        });

        // 创建一个消费者任务，从队列中取出数据
        Task consumer = Task.Run(() =>
        {
            foreach (int item in queue.GetConsumingEnumerable())
            {
                Console.WriteLine($"Consumer retrieved {item} from the queue.");
                Thread.Sleep(1000); // 模拟处理数据的时间
            }
        });

        // 等待生产者和消费者任务完成
        Task.WaitAll(producer, consumer);
    }
}

在上面的示例代码中，我们创建了一个阻塞队列queue，并且分别创建了一个生产者任务和一个消费者任务。生产者任务向队列中添加数据，消费者任务从队列中取出数据并进行处理。通过GetConsumingEnumerable()方法可以获取一个可枚举的数据结构，当队列为空时，枚举将会被阻塞，直到有新的数据被添加到队列中。

总之，在.NET中创建阻塞队列<T>可以使用BlockingCollection<T>类，它提供了线程安全的队列操作，并且可以方便地实现阻塞队列的功能。