Java实现生产者消费者模型应优先使用BlockingQueue而非wait/notify，因其已封装线程安全、阻塞语义和容量控制；手写易出错，如虚假唤醒、锁不一致、if误用、状态检查缺失等，导致卡死或数据丢失。
Java 里实现生产者消费者模型，核心不是自己手写 wait/notify，而是优先用 BlockingQueue —— 它已封装线程安全、阻塞语义和容量控制，出错率低、可维护性强。
为什么别直接用 wait/notify 手写？
手写容易漏掉几个关键点：虚假唤醒没处理、锁对象不一致、条件判断用 if 而非 while、未在同步块内检查状态。一旦出错，程序会卡死或数据丢失，且难以复现。
典型错误现象：
- 生产者往满队列塞数据时没阻塞，抛
IllegalStateException或直接覆盖 - 消费者从空队列取数据时返回
null而非等待，导致空指针 - 多个生产者/消费者下出现重复消费或漏消费
BlockingQueue 的三种典型用法场景
选哪种取决于你对「容量控制」「阻塞策略」「响应性」的要求：
-
ArrayBlockingQueue：固定大小、公平锁可选，适合明确容量上限的场景（如日志缓冲区） -
LinkedBlockingQueue：默认无界（实际是Integer.MAX_VALUE），吞吐高但可能 OOM；指定容量后行为接近ArrayBlockingQueue -
SynchronousQueue：不存储元素，每个put必须配一个take，适合任务交接型场景（如线程池的DirectHandoff）
一个最小可运行的双线程示例
以下代码演示一个生产者向队列塞整数、消费者从中取并打印，使用 ArrayBlockingQueue 确保严格容量控制：
Java 接口排错助手
下载
在调试 Java 后端 API 故障时使用此技能，尤其适用于以下任务：分析日志、跨 Controller、Service 和 Mapper 层追踪请求、定位异常根因、检查 SQL 执行或参数流转，以及生成简洁的诊断结论与修复方案。
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.ArrayBlockingQueue;
public class ProducerConsumerDemo {
private static final BlockingQueue<integer> queue = new ArrayBlockingQueue(3);
public static void main(String[] args) {
Thread producer = new Thread(() -> {
try {
for (int i = 0; i {
try {
for (int i = 0; i <p>注意：<code>put()</code> 和 <code>take()</code> 是阻塞式方法；若需超时或非阻塞，改用 <code>offer(e, timeout, unit)</code> 或 <code>poll(timeout, unit)</code>。</p>
<h3>容易被忽略的边界点</h3>
<p>实际项目中这几个细节常引发问题：</p>
<ul>
<li>
<code>BlockingQueue</code> 不保证跨 JVM 进程可见性 —— 它只是线程间通信工具，不是分布式队列</li>
<li>若消费者处理逻辑抛异常未捕获，线程会退出，后续生产的数据将永远堆积在队列中</li>
<li>
<code>size()</code> 返回的是近似值，高并发下可能不准，不能用它做业务逻辑判断（比如“如果 size > 5 就告警”）</li>
<li>用 <code>LinkedBlockingQueue</code> 且未设容量时，<code>put()</code> 几乎不会阻塞，但内存持续增长风险极高</li>
</ul>
<p>真正复杂的场景（如多生产者多消费者、优先级消费、失败重试、监控埋点），建议直接上 <code>Disruptor</code> 或消息中间件，而不是在 <code>BlockingQueue</code> 上叠补丁。</p></integer>
Java免费学习笔记：立即使用
解锁 Java 大师之旅：从入门到精通的终极指南
