17370845950

Java实现生产者消费者模型有三种核心方式：一是用阻塞队列（如ArrayBlockingQueue），自动处理满/空阻塞，无需手动同步；二是用synchronized+wait/notify，需在同步块中用while循环防虚假唤醒并调用notifyAll；三是用Lock+Condition，可精准唤醒生产或消费线程。

Java中实现生产者消费者模型，核心是解决多线程对共享资源的协同访问：生产者往缓冲区放数据，消费者从缓冲区取数据，二者需避免重复操作、空取、满写，并保证线程安全。关键不在“写多少代码”，而在理清协作逻辑和同步边界。

用阻塞队列（推荐初学者）

Java并发包提供了线程安全的阻塞队列（如 ArrayBlockingQueue、LinkedBlockingQueue），内部已封装 wait/notify 和锁机制，自动处理“满时阻塞生产”“空时阻塞消费”，大幅降低出错概率。

• 创建固定容量的队列（如 new ArrayBlockingQueue(10)），容量即缓冲区大小
• 生产者调用 queue.put(item)：队列满则自动等待；消费者调用 queue.take()：队列空则自动等待
• 无需手动加锁、判断条件、调用 wait/notify —— 这些都由队列内部完成

用 synchronized + wait/notify（理解底层原理）

若想深入掌握线程协作本质，可手动实现：定义共享缓冲区（如 List）、用 synchronized 锁住临界区，再配合 wait() 释放锁并等待，notifyAll() 唤醒所有等待线程。

• 必须在 synchronized 块内调用 wait/notify，否则抛 IllegalMonitorStateException
• 使用 while 循环判断条件（如 while (list.size() == MAX)），而非 if —— 防止虚假唤醒
• 生产者在“满”时 wait，唤醒后检查是否仍满；消费者在“空”时 wait，唤醒后检查是否仍空
• 每次修改状态后调用 notifyAll()（不是 notify），确保不遗漏该被唤醒的某一方

用 Lock + Condition（更灵活的显式控制）

相比 synchronized，ReentrantLock 配合 Condition 可为“生产等待”和“消费等待”分别定义条件变量，避免 notifyAll 的“惊群效应”，唤醒更精准。

• 声明两个 Condition：notFull = lock.newCondition() 和 notEmpty = lock.newCondition()
• 生产者在满时 notFull.await()，成功放入后 notEmpty.signal()
• 消费者在空时 notEmpty.await()，成功取出后 notFull.signal()
• 注意：await() 会释放锁，signal() 不释放锁，需在 finally 中 unlock()

别忽略的实用细节

真实场景中，仅实现基础协作远远不够：

• 生产者或消费者应支持优雅停止：用 volatile boolean 标志位控制循环，避免死等
• 考虑异常处理：比如 IO 生产失败、解析异常，不能让单个异常导致整个线程退出或阻塞
• 缓冲区大小需权衡：太小易频繁阻塞，太大占内存且延迟高；可结合吞吐量与响应要求调整
• 日志或监控建议打在“真正入队/出队”位置，而非线程启动处，便于定位瓶颈

不复杂但容易忽略。选对工具（优先阻塞队列），守住同步边界（锁+条件判断），再补上停止和异常逻辑，一个健壮的生产者消费者就落地了。