import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.ThreadLocalRandom;

// 生产者线程
class Producer implements Runnable {
    private final LinkedBlockingQueue<Integer> queue;

    Producer(LinkedBlockingQueue<Integer> queue) {
        this.queue = queue;
    }

    @Override
    public void run() {
        while (true) {
            try {
                // 生成一个随机数
                int number = ThreadLocalRandom.current().nextInt(100);

                // 在队列中插入随机数
                queue.put(number);

                System.out.println("Producer inserted number: "   number);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }
}

// 消费者线程
class Consumer implements Runnable {
    private final LinkedBlockingQueue<Integer> queue;

    Consumer(LinkedBlockingQueue<Integer> queue) {
        this.queue = queue;
    }

    @Override
    public void run() {
        while (true) {
            try {
                // 从队列中获取元素
                int number = queue.take();

                // 处理元素
                System.out.println("Consumer retrieved number: "   number);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }
}

public class Main {
    public static void main(String[] args) {
        // 创建并发队列
        LinkedBlockingQueue<Integer> queue = new LinkedBlockingQueue<>();

        // 创建生产者和消费者线程
        Producer producer = new Producer(queue);
        Consumer consumer = new Consumer(queue);

        // 启动生产者和消费者线程
        new Thread(producer).start();
        new Thread(consumer).start();
    }
}