在.NET中创建阻塞队列<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);
    }
}