如何实现BlockingCollection来修复此生产者/消费者问题？

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

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

        // 创建生产者线程
        Thread producerThread = new Thread(() =>
        {
            for (int i = 0; i < 10; i++)
            {
                // 向BlockingCollection中添加数据
                blockingCollection.Add(i);
                Console.WriteLine($"生产者生产了数据 {i}");
            }

            // 添加完数据后，调用Complete方法通知消费者线程
            blockingCollection.CompleteAdding();
        });

        // 创建消费者线程
        Thread consumerThread = new Thread(() =>
        {
            // 不断从BlockingCollection中获取数据并处理
            foreach (int data in blockingCollection.GetConsumingEnumerable())
            {
                Console.WriteLine($"消费者处理了数据 {data}");
            }
        });

        // 启动生产者和消费者线程
        producerThread.Start();
        consumerThread.Start();

        // 等待生产者和消费者线程执行完毕
        producerThread.Join();
        consumerThread.Join();

        Console.WriteLine("生产者/消费者问题已解决");
    }
}