作者 | 磊哥

来源 | Java面试真题解析(ID:aimianshi666)

转载请联系授权(微信ID:GG_Stone)

在多线程编程中,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 方法阻塞休眠,这里需要调用唤醒方法 notifynotify(); // ③}}/*** 获取方法(阻塞式执行)* 如果队列里面有数据则返回数据,如果没有数据就阻塞等待数据* @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 一起使用的原因了。

总结

本文介绍了 wait 和 notify 的基础使用,以及为什么 wait 和 notify/notifyAll 一定要配合 synchronized 使用的原因。如果 wait 和 notify/notifyAll 不强制和 synchronized 一起使用,那么在多线程执行时,就会出现 wait 执行了一半,然后又执行了添加数据和 notify 的操作,从而导致线程一直休眠的缺陷。

是非审之于己,毁誉听之于人,得失安之于数。

公众号:Java面试真题解析

面试合集:https://gitee.com/mydb/interview

往期推荐
面试突击23:说一下线程生命周期,以及转换过程?面试突击22:为什么start方法不能重复调用?而run方法却可以?有哪些创建线程的方法?推荐使用哪种?求点赞、在看、分享三连

为什么wait和notify必须放在synchronized中?相关推荐

  1. 为什么wait和notify只能在synchronized中?

    前言 wait和notify必须在synchronized块中,否则会抛出IllegalMonitorStateException. 原因 代码示例 class BlockingQueue {Queu ...

  2. 为什么wait、notify必须在synchronized保护的同步代码中

    先思考如果wait.notify不在synchronized保护的同步代码中的样子: //经典的生产者与消费者 public class BlockingQueue{Queue<String&g ...

  3. Java synchronized 中的while 和 notifyAll

    转载自  Java synchronized 中的while 和 notifyAll 问题1 为什么是while 而不是if 大多数人都知道常见的使用synchronized代码: synchroni ...

  4. synchronized 中的 4 个优化,你知道几个?

    作者 | 王磊 来源 | Java中文社群(ID:javacn666) 转载请联系授权(微信ID:GG_Stone) synchronized 在 JDK 1.5 时性能是比较低的,然而在后续的版本中 ...

  5. 常见的锁策略、synchronized中的锁优化机制

    一.常见的锁策略 锁策略,和普通程序猿基本没啥关系,和 "实现锁" 的人才有关系的 这里所提到的锁策略,和 Java 本身没关系,适用于所有和 "锁" 相关的情 ...

  6. 怎样把DataGrid存放在ViewState中的无用数据卡掉

    作者:无间道的博客http://www.cnblogs.com/wangsaokui/articles/10031.html 怎样把 DataGrid 存放在 ViewState 中的无用数据(有时候 ...

  7. 汇编: mul乘法指令(字乘法结果在dx:ax中,8位乘法:一个乘数默认放在al中)

    版权声明:本文为博主原创文章,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接和本声明. 本文链接:https://blog.csdn.net/m0_37564426/article/ ...

  8. IMXRT1052/1064 如何将代码存放在ITCM中

    IAR中将代码全部放在ITCRAM中执行 ① 修改启动文件,添加一个新的中断向量表(具体代码可以查看例程中example例程). ② 修改分散加载文件,将新的中断向量表放到ITCRAM中 ③ 修改分散 ...

  9. CSS样式为什么放在head中,而不放在body底部

    CSS样式为什么放在head中,而不放在body底部 1. 放在body底部 代码: <!DOCTYPE html> <html lang="en"> &l ...

最新文章

  1. 10w行级别数据的Excel导入优化记录
  2. mysql判断视图是否存在_使用JDBC查询是否存在某表或视图,按月动态生成表
  3. 11年标致307多少钱_11优布劳幼兽红西柚精酿啤酒多少钱一瓶?
  4. 结束语:投递简历和选公司的策略
  5. jdk 中英对照 百度网盘_Hadoop部署一jdk与MySQL
  6. 关于hexo与github使用过程中的问题与笔记
  7. 【Sqoop】Sqoop job实现增量导入的原理
  8. 《Visual Studio Code权威指南》读后总结
  9. hadoop记录-flink测试
  10. UnderWater+SDN论文之六
  11. Ubuntu下RabbitMQ安装
  12. 5 添加数据获得id_D3库实践笔记之元素定位与数据绑定 |可视化系列33
  13. iPhone5捣鼓mobile terminal
  14. 【神经网络】学习笔记五—循环神经网络RNN简介1.0
  15. Cloudera 的开放湖仓采用dbt Core增压
  16. 小程序加盟怎么样?加盟小程序赚钱吗?
  17. KERNEL32.DLL中可供调用的API函数列表
  18. APP多平台快速切换
  19. 怎样快速画出一个正方体_素描教程:新手如何快速学会正方体
  20. 持续盈利的乐享互动谋变:电商相关业务猛增,与巨头相比差距甚远

热门文章

  1. 【SSM面向CRUD编程专栏 1】Spring简介 xml配置文件 依赖注入 数据注入
  2. Angular添加class的正确方式
  3. 权限组件(6):权限分配的角色管理
  4. 如何快速把音乐转成MP3格式
  5. eclipse init 配置
  6. centos下安装pip时失败:
  7. java基础——java基本运算
  8. a20隐藏底部按钮及隐藏状态栏和虚拟按键栏
  9. linux 调优 网络调优
  10. 支持上传文件的xhEditor for Typecho EX插件