单生产者多消费者Java

import java.util.concurrent.ArrayBlockingQueue;

public class SPMCExample {
    private static final int BUFFER_SIZE = 10;
    private static ArrayBlockingQueue<Integer> buffer = new ArrayBlockingQueue<>(BUFFER_SIZE);

    public static void main(String[] args) {
        Producer producer = new Producer();
        Consumer consumer1 = new Consumer("Consumer 1");
        Consumer consumer2 = new Consumer("Consumer 2");

        producer.start();
        consumer1.start();
        consumer2.start();
    }

    static class Producer extends Thread {
        @Override
        public void run() {
            try {
                for (int i = 1; i <= 100; i++) {
                    buffer.put(i);
                    System.out.println("Produced: " + i);
                }
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }

    static class Consumer extends Thread {
        private String name;

        public Consumer(String name) {
            this.name = name;
        }

        @Override
        public void run() {
            try {
                while (true) {
                    int data = buffer.take();
                    System.out.println(name + " consumed: " + data);
                }
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }
}