在Java中如何使用LinkedBlockingQueue实现生产者消费者模式_LinkedBlockingQueue集合技巧

<font face="Courier New">
class Producer implements Runnable {
    private final BlockingQueue<String> queue;

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

    @Override
    public void run() {
        try {
            for (int i = 1; i <= 10; i++) {
                String item = "消息-" + i;
                queue.put(item);
                System.out.println("生产者发送: " + item);
                Thread.sleep(500); // 模拟生产耗时
            }
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
        }
    }
}
</font>

<font face="Courier New">
class Consumer implements Runnable {
    private final BlockingQueue<String> queue;

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

    @Override
    public void run() {
        try {
            while (true) {
                String item = queue.take();
                System.out.println("消费者收到: " + item);
                Thread.sleep(800); // 模拟处理时间
            }
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
        }
    }
}
</font>

<font face="Courier New">
public class ProducerConsumerExample {
    public static void main(String[] args) {
        // 创建有界队列，最多存放5个元素
        BlockingQueue<String> queue = new LinkedBlockingQueue<>(5);

        Thread producerThread = new Thread(new Producer(queue));
        Thread consumerThread = new Thread(new Consumer(queue));

        producerThread.start();
        consumerThread.start();

        try {
            producerThread.join();
            consumerThread.interrupt(); // 生产结束，中断消费者
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
        }
    }
}
</font>