Java多线程生产者消费者模式实现解析

核心逻辑与角色定义

在Java多线程开发中，生产者（Producer）负责生成并推送到共享数据区，而消费者（Consumer）则从该区域提取数据进行处理。两者通过中介——消息队列（MessageQueue）进行解耦通信。

关键组件实现原理

第1步：定义数据载体类 Message

目的：用于封装需在线程间传递的具体业务信息。

• 包含私有字段 data 及其对应的 Getter/Setter 方法，保证数据结构简单且可序列化。

第2步：实现同步消息队列 MessageQueue

目的：作为共享缓冲区，协调生产与消费的速度差异，防止数据溢出或空转。

1. 初始化：使用 LinkedList<Message> 存储元素，并设定最大容量限制 limit（默认值为100）。
2. 生产操作 put：
   • 进入 synchronized (queue) 代码块锁定队列。
   • 检查容量：使用 while (queue.size() > limit) 判断队列是否已满。若满，调用 queue.wait() 暂停当前线程，释放锁等待其他线程通知。
   • 插入数据：调用 queue.addLast(message) 将消息加入队尾。
   • 发送通知：调用 queue.notifyAll() 唤醒所有等待中的线程（包括可能正在等待空间的其他生产者或等待数据的消费者）。
3. 消费操作 take：
   • 同样在 synchronized (queue) 保护下执行。
   • 检查空位：使用 while (queue.isEmpty()) 判断队列是否为空。若空，调用 queue.wait() 暂停线程。
   • 移出数据：调用 queue.removeFirst() 取出队首消息。
   • 发送通知：调用 queue.notifyAll() 唤醒等待空间的线程。

第3步：创建生产者线程 ProducerThread

入口：继承自 Thread 类，持有唯一的 messageQueue 引用。

动作：在 run() 方法中使用无限循环：

1. 生成唯一标识的新消息对象 Message。
2. 调用 messageQueue.put(message) 尝试入队。若队列满，线程将在此处自动挂起直到有空间。
3. 打印日志确认已提交消息，随后让当前线程休眠随机时间以模拟真实业务处理耗时。

第4步：创建消费者线程 ConsumerThread

入口：同样继承 Thread，持有共享的 messageQueue。

动作：在 run() 方法中无限循环：

1. 调用 messageQueue.take() 获取消息。若队列为空，线程将挂起等待生产者放入数据。
2. 接收成功后的消费行为：读取消息内容并记录日志。
3. 适当延迟以防止CPU空转，持续处理队列中的任务。

第5步：组装运行客户端 ProducerAndConsumerClient

参数：创建一个默认容量的 MessageQueue 实例。

启动：分别启动多个生产者线程（如序列号1, 2, 3）和多个消费者线程。系统即开始自动运转：生产者不断填充缓冲池，消费者实时取走数据，二者由底层队列的锁机制维持稳定平衡。

总结

以上就是Java多线程中如何实现生产者与消费者模式的详细内容。该实现利用了经典的 Wait/Notify 机制处理线程间的状态依赖，有效解决了资源共享冲突问题。更多关于Java并发设计的资料请关注本站其它相关文章！