BlockingQueue 提供开箱即用的线程安全队列，内置阻塞、唤醒与JMM语义保障；无需手写wait/notify，避免虚假唤醒、死锁等错误；ArrayBlockingQueue适合固定容量场景，LinkedBlockingQueue吞吐更高但有GC压力；关闭需配合结束标记或中断机制。
用 BlockingQueue 实现开箱即用的线程安全队列
Java 标准库已提供线程安全的生产者消费者实现，无需手写 wait/notify 或锁逻辑。BlockingQueue 接口及其实现类（如 ArrayBlockingQueue、LinkedBlockingQueue、SynchronousQueue）天然支持阻塞式插入与移除，内部已处理所有可见性、原子性和重入问题。
关键点：
-
put()和take()是阻塞方法：队列满时put()阻塞，空时take()阻塞，自动唤醒，无需手动同步 -
offer(e, timeout, unit)和poll(timeout, unit)支持超时控制，避免无限等待 -
ArrayBlockingQueue是有界队列，构造时必须指定容量；LinkedBlockingQueue默认无界（实际是Integer.MAX_VALUE），但建议显式设容量以防内存溢出 - 所有操作均已声明为
synchronized或使用ReentrantLock+Condition，JMM 语义完备，不需额外volatile修饰
public class ProducerConsumerExample {
private final BlockingQueue queue = new ArrayBlockingQueue<>(10);
public void start() {
Thread producer = new Thread(() -> {
for (int i = 0; i < 20; i++) {
try {
queue.put("item-" + i); // 自动阻塞
System.out.println("Produced: item-" + i);
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
return;
}
}
});
Thread consumer = new Thread(() -> {
for (int i = 0; i < 20; i++) {
try {
String item = queue.take(); // 自动阻塞
System.out.println("Consumed: " + item);
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
return;
}
}
});
producer.start();
consumer.start();
}
}
为什么不要手写 wait/notify 版本
手动基于 synchronized + wait/notifyAll 实现容易出错，且多数场景下得不偿失。
常见错误现象：
立即学习“Java免费学习笔记（深入）”；
- 忘记在
while循环中检查条件（用if会导致虚假唤醒后直接消费 null 或越界） -
notify()误用：只唤醒一个线程，但多个消费者/生产者等待时可能造成死锁或饥饿 - 锁粒度不合理：比如把整个生产逻辑包进 synchronized 块，导致 CPU 密集型操作阻塞其他线程
- 未处理
InterruptedException，吞掉异常后中断状态丢失，线程无法被优雅关闭
除非你正在学习 JVM 线程模型，或需要定制唤醒策略（如按优先级分发），否则没必要绕过 BlockingQueue。
LinkedBlockingQueue 与 ArrayBlockingQueue 的性能和行为差异
二者都满足线程安全，但底层机制和适用场景不同，选错会影响吞吐或内存稳定性。
核心区别：
-
ArrayBlockingQueue：基于可重入锁 + 单一Condition，生产与消费者共用同一把锁，适合中低并发、容量固定、对内存占用敏感的场景 -
LinkedBlockingQueue：使用两把独立锁（takeLock和putLock），生产与消费可并行，吞吐更高；但节点对象带来 GC 压力，且默认无界易 OOM -
size()行为不同：ArrayBlockingQueue.size()是 O(1)，LinkedBlockingQueue.size()是 O(n)（需遍历链表），高并发下调用要谨慎 - 构造时若传入
Comparator或自定义容量，ArrayBlockingQueue更轻量；若需动态扩容语义，应考虑ConcurrentLinkedQueue+ 外部阻塞逻辑（但不再满足“阻塞”语义）
如何安全关闭生产者消费者系统
没有标准的「关闭队列」API，BlockingQueue 本身不管理生命周期。关闭逻辑必须由上层协调，否则可能卡在 take() 或 put() 上。
推荐做法：
- 向队列插入一个特殊结束标记（如
null或自定义POISON_PILL对象），消费者收到后退出循环 - 使用
Thread.interrupt()并捕获InterruptedException，确保线程能响应中断 —— 所有BlockingQueue阻塞方法都会响应中断 - 避免在 finally 块里调用
queue.clear()：多线程下 clear 可能与生产者冲突，且无实际意义 - 若使用线程池，记得调用
shutdown()+awaitTermination()，而非直接shutdownNow()（会丢失未处理完的队列项）
真正容易被忽略的是：消费者线程退出后，生产者仍在运行且队列未满，程序不会自动终止。必须显式控制生产者生命周期，或引入计数器/信号量配合关闭流程。
