JavaBlockingQueue生产者消费者实战技巧

import java.util.concurrent.*;

public class ProducerConsumer {
    private static final int QUEUE_CAPACITY = 5;

    public static void main(String[] args) {
        BlockingQueue queue = new ArrayBlockingQueue<>(QUEUE_CAPACITY);

        Thread producer = new Thread(() -> {
            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();
            }
        });

        Thread consumer = new Thread(() -> {
            try {
                while (true) {
                    String item = queue.take();
                    System.out.println("消费者接收: " + item);
                    Thread.sleep(800); // 模拟消费耗时
                    // 可添加退出条件，例如 if ("END".equals(item)) break;
                }
            } catch (InterruptedException e) {
                Thread.currentThread().interrupt();
            }
        });

        producer.start();
        consumer.start();

        try {
            producer.join();
            // 生产结束后，可发送结束信号
            queue.put("END");
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
        }
    }
}