为什么wait和notify必须放在synchronized中使用
作者:??Java中文社群???? 发布时间:2022-07-20 07:32:39
前言:
在多线程编程中,wait 方法是让当前线程进入休眠状态,直到另一个线程调用了 notify 或 notifyAll 方法之后,才能继续恢复执行。而在 Java 中,wait 和 notify/notifyAll 有着一套自己的使用格式要求,也就是在使用 wait 和 notify(notifyAll 的使用和 notify 类似,所以下文就只用 notify 用来指代二者)必须配合 synchronized 一起使用才行。
wait/notify基础使用
wait 和 notify 的基础方法如下:
Object lock = new Object();
new Thread(() -> {
synchronized (lock) {
try {
System.out.println("wait 之前");
// 调用 wait 方法
lock.wait();
System.out.println("wait 之后");
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}).start();
Thread.sleep(100);
synchronized (lock) {
System.out.println("执行 notify");
// 调用 notify 方法
lock.notify();
}
以上代码的执行结果如下图所示:
wait/notify和synchronized一起用?
那问题来了,是不是 wait 和 notify 一定要配合 synchronized 一起使用呢?wait 和 notify 单独使用行不行呢? 我们尝试将以上代码中的 synchronized 代码行删除,实现代码如下:
初看代码好像没啥问题,编译器也没报错,好像能“正常使用”,然而当我们运行以上程序时就会发生如下错误:
从上述结果可以看出:无论是 wait 还是 notify,如果不配合 synchronized 一起使用,在程序运行时就会报 IllegalMonitorStateException 非法的监视器状态异常,而且 notify 也不能实现程序的唤醒功能了。
原因分析
从上述的报错信息我们可以看出,JVM 在运行时会强制检查 wait 和 notify 有没有在 synchronized 代码中,如果没有的话就会报非法监视器状态异常(IllegalMonitorStateException),但这也仅仅是运行时的程序表象,那为什么 Java 要这样设计呢? 其实这样设计的原因就是为了防止多线程并发运行时,程序的执行混乱问题。初看这句话,好像是用来描述“锁”的。然而实际情况也是如此,wait 和 notify 引入锁就是来规避并发执行时程序的执行混乱问题的。那这个“执行混乱问题”到底是啥呢?接下来我们继续往下看。
wait和notify问题复现
我们假设 wait 和 notify 可以不加锁,我们用它们来实现一个自定义阻塞队列。 这里的阻塞队列是指读操作阻塞,也就是当读取数据时,如果有数据就返回数据,如果没有数据则阻塞等待数据,实现代码如下:
class MyBlockingQueue {
// 用来保存数据的集合
Queue<String> queue = new LinkedList<>();
/**
* 添加方法
*/
public void put(String data) {
// 队列加入数据
queue.add(data);
// 唤醒线程继续执行(这里的线程指的是执行 take 方法的线程)
notify(); // ③
}
/**
* 获取方法(阻塞式执行)
* 如果队列里面有数据则返回数据,如果没有数据就阻塞等待数据
* @return
*/
public String take() throws InterruptedException {
// 使用 while 判断是否有数据(这里使用 while 而非 if 是为了防止虚假唤醒)
while (queue.isEmpty()) { // ①
// 没有任务,先阻塞等待
wait(); // ②
}
return queue.remove(); // 返回数据
}
}
注意上述代码,我们在代码中标识了三个关键执行步骤:①:判断队列中是否有数据;②:执行 wait 休眠操作;③:给队列中添加数据并唤醒阻塞线程。 如果不强制要求添加 synchronized,那么就会出现如下问题:
步骤 | 线程1 | 线程2 |
---|---|---|
1 | 执行步骤 ① 判断当前队列中没有数据 | |
2 | 执行步骤 ③ 将数据添加到队列,并唤醒线程1继续执行 | |
3 | 执行步骤 ② 线程 1 进入休眠状态 |
从上述执行流程看出问题了吗? 如果 wait 和 notify 不强制要求加锁,那么在线程 1 执行完判断之后,尚未执行休眠之前,此时另一个线程添加数据到队列中。然而这时线程 1 已经执行过判断了,所以就会直接进入休眠状态,从而导致队列中的那条数据永久性不能被读取,这就是程序并发运行时“执行结果混乱”的问题。 然而如果配合 synchronized 一起使用的话,代码就会变成以下这样:
class MyBlockingQueue {
// 用来保存任务的集合
Queue<String> queue = new LinkedList<>();
/**
* 添加方法
*/
public void put(String data) {
synchronized (MyBlockingQueue.class) {
// 队列加入数据
queue.add(data);
// 为了防止 take 方法阻塞休眠,这里需要调用唤醒方法 notify
notify(); // ③
}
}
/**
* 获取方法(阻塞式执行)
* 如果队列里面有数据则返回数据,如果没有数据就阻塞等待数据
* @return
*/
public String take() throws InterruptedException {
synchronized (MyBlockingQueue.class) {
// 使用 while 判断是否有数据(这里使用 while 而非 if 是为了防止虚假唤醒)
while (queue.isEmpty()) { // ①
// 没有任务,先阻塞等待
wait(); // ②
}
}
return queue.remove(); // 返回数据
}
}
这样改造之后,关键步骤 ① 和关键步骤 ② 就可以一起执行了,从而当线程执行了步骤 ③ 之后,线程 1 就可以读取到队列中的那条数据了,它们的执行流程如下:
步骤 | 线程1 | 线程2 |
---|---|---|
1 | 执行步骤 ① 判断当前队列没有数据 | |
2 | 执行步骤 ② 线程进入休眠状态 | |
3 | 执行步骤 ③ 将数据添加到队列,并执行唤醒操作 | |
4 | 线程被唤醒,继续执行 | |
5 | 判断队列中有数据,返回数据 |
这样咱们的程序就可以正常执行了,这就是为什么 Java 设计一定要让 wait 和 notify 配合上 synchronized 一起使用的原因了。
来源:https://juejin.cn/post/7067322092936495112


猜你喜欢
- RFC6749OAuth2的官方文档在RFC6749:https://datatracker.ietf.org/doc/html/rfc67
- 前言Java8新特性java.time.*包学习。 自从java发布模式变更就发现自己有些跟不上他们的速度,java8还有不少没有用透而9、
- Java中的BigDecimal类的使用:使用Java中的BigDecimal可以进行精确的计算,但是在使用BigDecimal时我们需要注
- 本文章向大家讲解java中时间的获取和格式化, 一. 获取当前系统时间和日期并格式化输出:import java.util.Dat
- 什么是自动填充有些表中会有更新时间、创建时间、更新人或者创建人这些字段。每次对数据进行新增、删除、修改时都需要对这些字段进行设置。传统的做法
- java.lang.OutOfMemoryError处理错误java.lang.OutOfMemoryError异常解决方法原因: 常见的有
- Spring Security中的内置过滤器顺序是怎么维护的?我想很多开发者都对这个问题感兴趣。本篇我和大家一起探讨下这个问题。HttpSe
- 应用启动的时候有短暂的白屏,如图:可以通过设置theme的方式来解决 <style name="AppTheme"
- 本文实例讲述了Android编程将Activity背景设置为墙纸的简单实现方法。分享给大家供大家参考,具体如下:1)代码方式Drawable
- 目录方案一,更改启动项方案二,禁用检查应用程序的CAS发布者策略方案一,更改启动项出问题应用的启动项是使用的默认设置,查看App.g.cs文
- 1、final修饰类被final修饰的类不能被继承,因此final类的成员方法也不能被覆写,被final关键字修饰的类没有子类,因此类的实现
- 先看一下效果图Tinker已知问题由于原理与系统限制,Tinker有以下已知问题:Tinker不支持修改AndroidManifest.xm
- 方法一:利用两个指针p,q,首先将q往链表尾部移动n位,然后再将p、q一起往后移,那么当q达到链表尾部时,p即指向链表的倒数第n个节点。no
- 前言Spring Data Jpa框架的目标是显著减少实现各种持久性存储的数据访问层所需的样板代码量。Spring Data Jpa存储库抽
- 从一个Stream中过滤null值复习一个Stream 包含 null 数据的例子.Java8Examples.javapackage co
- 一般查询手机归属地内容应该很好用json格式保存,在网上找到了淘宝的归属地API,并下了处理json相关的jar包,做了这个手机归属地查询功
- 1. 问题所示编译ssm的项目的时候出现了这个错误导致一直运行不起来SLF4J: Failed to load class "or
- Bean Searcher 号称 任何复杂的查询都可以 一行代码搞定,但 Mybatis Plus 似乎也有类似的动态查询功能,它们有怎样的
- 1.OpenFileDialogprivate void btnOpen_Click(object sender, EventArgs e)
- 为了让大家知道下面内容是否是自己想要的,我先发效果图。好了,那就开始贴代码了以下为一个按钮的事件,为裁剪准备图片、裁剪路径、保存路径priv