在C#中实现生产者/消费者模式

using System;
using System.Collections.Generic;
using System.Threading;

class Program
{
    static void Main()
    {
        // 创建一个缓冲区，用于存储数据
        Buffer buffer = new Buffer(10);

        // 创建生产者线程
        Thread producerThread = new Thread(() =>
        {
            for (int i = 0; i < 20; i++)
            {
                buffer.Add(i);
                Console.WriteLine($"Produced: {i}");
                Thread.Sleep(100);
            }
        });

        // 创建消费者线程
        Thread consumerThread = new Thread(() =>
        {
            for (int i = 0; i < 20; i++)
            {
                int data = buffer.Get();
                Console.WriteLine($"Consumed: {data}");
                Thread.Sleep(150);
            }
        });

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

        // 等待线程结束
        producerThread.Join();
        consumerThread.Join();
    }
}

class Buffer
{
    private readonly object _lock = new object();
    private readonly Queue<int> _queue;
    private readonly int _size;

    public Buffer(int size)
    {
        _size = size;
        _queue = new Queue<int>(size);
    }

    public void Add(int data)
    {
        lock (_lock)
        {
            while (_queue.Count >= _size)
            {
                Monitor.Wait(_lock);
            }

            _queue.Enqueue(data);
            Monitor.Pulse(_lock);
        }
    }

    public int Get()
    {
        lock (_lock)
        {
            while (_queue.Count == 0)
            {
                Monitor.Wait(_lock);
            }

            int data = _queue.Dequeue();
            Monitor.Pulse(_lock);
            return data;
        }
    }
}