Java中如何实现生产者消费者模式

import java.util.concurrent.BlockingQueue;
import java.util.concurrent.LinkedBlockingQueue;
import java.util.Random;

class Producer implements Runnable {
    private BlockingQueue<Integer> queue;
    private int id;
    private Random random = new Random();

    public Producer(BlockingQueue<Integer> queue, int id) {
        this.queue = queue;
        this.id = id;
    }

    @Override
    public void run() {
        try {
            while (true) {
                int number = random.nextInt(100);
                queue.put(number); // 阻塞直到队列有空间
                System.out.println("Producer " + id + " produced: " + number);
                Thread.sleep(random.nextInt(500)); // 模拟生产时间
            }
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
        }
    }
}

class Consumer implements Runnable {
    private BlockingQueue<Integer> queue;
    private int id;
    private Random random = new Random();

    public Consumer(BlockingQueue<Integer> queue, int id) {
        this.queue = queue;
        this.id = id;
    }

    @Override
    public void run() {
        try {
            while (true) {
                int number = queue.take(); // 阻塞直到队列有数据
                System.out.println("Consumer " + id + " consumed: " + number);
                Thread.sleep(random.nextInt(500)); // 模拟消费时间
            }
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
        }
    }
}

public class ProducerConsumerExample {
    public static void main(String[] args) {
        BlockingQueue<Integer> queue = new LinkedBlockingQueue<>(10); // 缓冲区大小为10

        Thread producer1 = new Thread(new Producer(queue, 1));
        Thread producer2 = new Thread(new Producer(queue, 2));
        Thread consumer1 = new Thread(new Consumer(queue, 1));
        Thread consumer2 = new Thread(new Consumer(queue, 2));

        producer1.start();
        producer2.start();
        consumer1.start();
        consumer2.start();
    }
}