讲师中心 微信公众号
AI工具推荐 视频效率加速

怎么利用 Object.wait() 和 notify() 实现多线程间的经典生产者消费者协作

大瑶酱_2366

大瑶酱_2366

发布时间:2026-05-07 17:30:35

|

990人浏览过

|

来源于php中文网

原创

不能直接在普通对象上调用wait()和notify(),因为它们必须在synchronized块中执行且当前线程需持有该对象锁,否则抛IllegalMonitorStateException;正确做法是用synchronized(buffer)包裹所有相关逻辑,wait()须置于while循环中防虚假唤醒,notifyAll()确保不遗漏等待方。

怎么利用 object.wait() 和 notify() 实现多线程间的经典生产者消费者协作

为什么不能直接在普通对象上调用 wait() 和 notify()

因为这两个方法必须在同步上下文中执行——也就是当前线程必须持有该对象的监视器锁。否则会抛出 IllegalMonitorStateException。常见错误是忘了加 synchronized 块,或者锁的对象和调用 wait() 的对象不一致。

正确做法是:所有对共享缓冲区的操作(读/写/等待)都必须在同一个锁对象上同步,通常就是缓冲区实例本身。

  • 用 synchronized(buffer) 包裹所有涉及 wait()/notify() 的逻辑
  • 避免用 this 或新创建的锁对象,否则生产者和消费者无法看到彼此的通知
  • wait() 一定要放在 while 循环里判断条件,不能用 if——防止虚假唤醒

如何用 wait()/notify() 实现带边界检查的阻塞队列

核心是把“缓冲区满”和“缓冲区空”作为两个独立等待条件,通过同一个锁对象协调。

示例中用一个 ArrayList 模拟固定容量队列,生产者在满时 wait(),消费者在空时 wait();任一操作完成后都调用 notifyAll()(不是 notify()),确保不会漏掉等待方。

public class BoundedBuffer {
    private final List<String> buffer = new ArrayList<>();
    private final int capacity = 5;

    public void produce(String item) throws InterruptedException {
        synchronized (buffer) {
            while (buffer.size() == capacity) {
                buffer.wait(); // 等待有空间
            }
            buffer.add(item);
            buffer.notifyAll(); // 唤醒可能等待取数据的消费者
        }
    }

    public String consume() throws InterruptedException {
        synchronized (buffer) {
            while (buffer.isEmpty()) {
                buffer.wait(); // 等待有数据
            }
            String item = buffer.remove(0);
            buffer.notifyAll(); // 唤醒可能等待放数据的生产者
            return item;
        }
    }
}
  • 用 notifyAll() 而非 notify():避免唤醒错线程类型(比如只唤醒另一个生产者)
  • 容量检查必须用 while:JVM 可能无理由唤醒线程(spurious wakeup),不重检条件会出错
  • 注意 remove(0) 是 O(n) 操作,实际应改用 LinkedList 或数组循环队列

wait(long timeout) 怎么用才安全

带超时的 wait() 不等于“最多等 timeout”,而是“最多等 timeout,但可能提前被唤醒”。所以它不能替代条件判断,仍需配合 while 循环使用。

AI舌诊面诊问诊医疗系统+诊疗商城系统源码
AI舌诊面诊问诊医疗系统+诊疗商城系统源码

AI 舌诊面诊问诊医疗系统 + 诊疗商城系统源码是一套结合 AI 辅助诊断与商品转化的健康类程序,基于浩创云、ThinkPHP(PHP)开发,支持微信服务号与 H5 端,适合做中医舌诊面诊问答、健康建议推送以及配套诊疗商品的运营。

下载

典型误用是写了 if (buffer.isEmpty()) buffer.wait(1000);,结果超时后直接取数据,没再检查是否真有数据。

  • 超时后必须重新判断条件,否则可能触发 IndexOutOfBoundsException
  • 超时适合做“保底响应”,比如日志告警、降级返回 null,而不是跳过条件检查
  • 不要依赖超时值做业务逻辑分流(如“等不到就走异步路径”),那应该用 Lock.tryLock() + 条件队列

和 java.util.concurrent 里的实现比,手写有什么硬伤

手写 wait()/notify() 最大的问题是无法分离“等待条件”——所有 wait() 都共用一个等待队列,导致每次 notifyAll() 都要唤醒全部线程,再由它们各自重判条件。这在高并发下浪费严重。

ArrayBlockingQueue 内部用 ReentrantLock + 两个 Condition(notFull / notEmpty),可以精准唤醒对应等待组,避免无效竞争。

  • 手写版在百级线程规模下,notifyAll() 引发的上下文切换开销会明显上升
  • 没有中断支持:原生 wait() 可被 interrupt() 中断,但需要手动处理 InterruptedException 并恢复中断状态
  • 无法实现公平策略、无法绑定多个等待条件、难以调试死锁点

除非教学或嵌入式受限环境,否则优先用 BlockingQueue 实现。手写只是为了理解底层协作契约——wait 是释放锁并挂起,notify 是唤醒但不抢锁,真正竞争在重新进入同步块时才开始。

热门AI工具

更多
WorkBuddy

一款AI办公效率工具,主要用于腾讯云推出的AI原生桌面智能体工作台,适合需要提升相关任务效率的用户。

DeepSeek

DeepSeek是一款面向对话、写作、编程和推理场景的AI大模型工具。

豆包大模型

豆包大模型是一款由字节跳动推出的企业级大语言模型服务平台。

超级简历WonderCV

一款AI办公效率工具,主要用于免费求职简历模版下载制作,应届生职场人必备简历制作神器,适合需要提升相关任务效率的用户。

切问学术

切问学术是一款AI论文写作工具,复旦大学NLP团队推出的AI学术智能体。

火山引擎

火山引擎是一款面向企业的云计算与AI服务平台。

音述AI
音述AI Hot

一款AI音频处理工具,主要用于音述AI是一个以“用声音述说故事”为核心的 AI 音乐创作与声音分享社区,适合需要提升相关任务效率的用户。

PixTV
PixTV Hot

PixTV是一款面向AIGC内容创作的AI视频生成工具。

讯飞绘文

讯飞绘文是一款由科大讯飞推出的一站式 AIGC 内容运营平台。

相关专题

更多
java
java

Java是一个通用术语,用于表示Java软件及其组件,包括“Java运行时环境 (JRE)”、“Java虚拟机 (JVM)”以及“插件”。php中文网还为大家带了Java相关下载资源、相关课程以及相关文章等内容,供大家免费下载使用。

11017

2023.06.15

java正则表达式语法
java正则表达式语法

java正则表达式语法是一种模式匹配工具,它非常有用,可以在处理文本和字符串时快速地查找、替换、验证和提取特定的模式和数据。本专题提供java正则表达式语法的相关文章、下载和专题,供大家免费下载体验。

8122

2023.07.05

java自学难吗
java自学难吗

Java自学并不难。Java语言相对于其他一些编程语言而言,有着较为简洁和易读的语法,本专题为大家提供java自学难吗相关的文章,大家可以免费体验。

7032

2023.07.31

java配置jdk环境变量
java配置jdk环境变量

Java是一种广泛使用的高级编程语言,用于开发各种类型的应用程序。为了能够在计算机上正确运行和编译Java代码,需要正确配置Java Development Kit(JDK)环境变量。php中文网给大家带来了相关的教程以及文章,欢迎大家前来阅读学习。

1184

2023.08.01

java保留两位小数
java保留两位小数

Java是一种广泛应用于编程领域的高级编程语言。在Java中,保留两位小数是指在进行数值计算或输出时,限制小数部分只有两位有效数字,并将多余的位数进行四舍五入或截取。php中文网给大家带来了相关的教程以及文章,欢迎大家前来阅读学习。

968

2023.08.02

java基本数据类型
java基本数据类型

java基本数据类型有:1、byte;2、short;3、int;4、long;5、float;6、double;7、char;8、boolean。本专题为大家提供java基本数据类型的相关的文章、下载、课程内容,供大家免费下载体验。

1436

2023.08.02

java有什么用
java有什么用

java可以开发应用程序、移动应用、Web应用、企业级应用、嵌入式系统等方面。本专题为大家提供java有什么用的相关的文章、下载、课程内容,供大家免费下载体验。

2909

2023.08.02

java在线网站
java在线网站

Java在线网站是指提供Java编程学习、实践和交流平台的网络服务。近年来,随着Java语言在软件开发领域的广泛应用,越来越多的人对Java编程感兴趣,并希望能够通过在线网站来学习和提高自己的Java编程技能。php中文网给大家带来了相关的视频、教程以及文章,欢迎大家前来学习阅读和下载。

20171

2023.08.03

Gradle插件开发入门教程
Gradle插件开发入门教程

本专题介绍Gradle插件开发的基本流程,涵盖插件类编写、自定义任务注册、扩展参数设计和插件应用方法,帮助你理解插件如何组织构建逻辑,减少多个项目之间的重复配置。

0

2026.10.22

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
关于我们 免责申明 举报中心 意见反馈 讲师合作 广告合作 最新更新
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号
PHP中文网订阅号
每天精选资源文章推送

Copyright 2014-2026 https://www.php.cn/ All Rights Reserved | php.cn