java多线程共享队列怎么做

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

public class SharedQueueExample {
    public static void main(String[] args) {
        // 创建一个容量为10的阻塞队列
        BlockingQueue queue = new LinkedBlockingQueue<>(10);

        // 创建并启动多个生产者线程
        for (int i = 0; i < 5; i++) {
            new Producer(queue).start();
        }

        // 创建并启动一个消费者线程
        new Consumer(queue).start();
    }

    static class Producer extends Thread {
        private final BlockingQueue queue;

        public Producer(BlockingQueue queue) {
            this.queue = queue;
        }

        @Override
        public void run() {
            try {
                for (int i = 0; i < 10; i++) {
                    queue.put(i); // 阻塞等待直到队列有空闲位置
                    System.out.println("Produced: " + i);
                    Thread.sleep(1000);
                }
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }

    static class Consumer extends Thread {
        private final BlockingQueue queue;

        public Consumer(BlockingQueue queue) {
            this.queue = queue;
        }

        @Override
        public void run() {
            try {
                while (true) {
                    int value = https://www.yisu.com/ask/queue.take(); // 阻塞等待直到队列有可用元素"Consumed: " + value);
                    Thread.sleep(2000);
                }
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }
}