Java 并发之 wait、notify 机制三问

2024-01-06 16:52

本文主要是介绍Java 并发之 wait、notify 机制三问,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

1. 调用 notify/notifyAll 之后,会立马释放锁吗?

不会。那么什么时候才释放掉锁从而使得在 WaitSet 中的被唤醒的线程能够有机会重新竞争到锁呢?例如:

synchronized(obj) {obj.notify();foo();
}

在这段代码中,就是 foo() 方法执行完毕后,会释放掉 obj 对象的锁,换句话说,也就是 synchronized 代码块执行完毕后,从字节码层面也就是执行了 monitorexit 指令之后。

2. notify、notifyAll 有什么区别

  • notify():Calling notify() causes the JVM to select one thread waiting on that condition queue to wake up.
  • notifyAll():Calling notifyAll() wakes up all the threads waiting on that condition queue.

简而言之,唤醒随机一个还是所有的区别,不过需要注意的是唤醒所有并不是所有等待的线程都会同一时刻恢复执行,还是需要竞争从而那个重新获取到锁的线程可以执行,毕竟同一时刻只可能有一个线程可以持有对象的锁。我们可以通过一段代码来理解这其中的差别:

public class NotificationTest {private volatile boolean go = false;private synchronized void shouldGo() throws InterruptedException {while (!go) {System.out.println(Thread.currentThread() + " is going to wait on this object");wait();System.out.println(Thread.currentThread() + " is woken up");}go = false;}private synchronized void go() {while (!go) {System.out.println(Thread.currentThread() + " is going to notify all or one thread waiting on this object");go = true;notify();}}public static void main(String[] args) throws InterruptedException {NotificationTest test = new NotificationTest();Runnable waitTask = () -> {try {test.shouldGo();} catch (InterruptedException e) {Logger.getLogger(NotificationTest.class.getName()).log(Level.SEVERE, null, e);}System.out.println(Thread.currentThread() + " finished execution");};Runnable notifyTask = () -> {test.go();System.out.println(Thread.currentThread() + " finished execution");};Thread t1 = new Thread(waitTask, "WT1");Thread t2 = new Thread(waitTask, "WT2");Thread t3 = new Thread(waitTask, "WT3");Thread t4 = new Thread(notifyTask, "NT1");t1.start();t2.start();t3.start();Thread.sleep(200);t4.start();}
}

我们来一起看下这段代码。

  1. 有一个共享的 boolean 类型的变量 go,并且使用 volatile 关键字修饰,保证变量的可见性。
  2. 同步方法 shouldGo():wait 的调用以及将 go 置为 false
  3. 同步方法 go():notify 的调用以及将 go 置为 true。
  4. main() 测试方法:3个线程调用 shouldGo(),即3个 wait(),1个线程调用 go(),即 notify()。

运行看下输出结果:
在这里插入图片描述

我们再把上述示例代码中 notify() 改成 notifyAll(),再看输出结果:
在这里插入图片描述
注意红框部分,调用 notifyAll() 把 WaitSet 中的三个线程都唤醒了,被唤醒的第一个线程执行完了 shouldGo() 方法,并且将 go 变量置为 false,这样导致 notifyAll() 唤醒的后面两个线程因为判断条件不满足再次 wait。而 notify() 只随机唤醒了一个线程。

那么我们怎么区分 notify/notifyAll 的使用场景呢?

我们可以借助于 《Java Concurrent In Practice》:

Single notify can be used instead of notifyAll only when both of the following conditions hold:

  • Uniform waiters:Only one condition predicate is associated with the condition queue, and each thread executes the

    same logic upon returning from wait;(只有一个等待条件并且从 wait 放回后执行的逻辑是一样的)

  • One-in, one-out:A notification on the condition variable enables at most one thread to proceed.(一次 notify 只唤醒一个线程)。

只有在同时满足上述两种情况下我们可以使用 notify,剩下的场景我们都应使用 notifyAll,从而保证程序的正确性,虽然会导致无效的通知影响性能。

Most classes don’t meet these requirements, so the prevailing wisdom is to use notifyAll in preference to single notify. While this may be inefficient,it is much easier to ensure that you classes behave correctly when using notifyAll instead of notify.

3. wait、notify 方法为啥定义在 Object 类,而不是 Thread 类

  • 每个 Java 对象都可以作为锁和条件队列
  • 每个对象都可以一个 Monitor 对象与之对应
  • 锁标志放在对象头比在 Thread 类中维护一份列表更合理

参考资料:

https://javarevisited.blogspot.com/2012/10/difference-between-notify-and-notifyall-java-example.html#axzz8Nju8slQg

《Java Concurrent In Practice》

这篇关于Java 并发之 wait、notify 机制三问的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/576987

相关文章

Spring Security自定义身份认证的实现方法

《SpringSecurity自定义身份认证的实现方法》:本文主要介绍SpringSecurity自定义身份认证的实现方法,下面对SpringSecurity的这三种自定义身份认证进行详细讲解,... 目录1.内存身份认证(1)创建配置类(2)验证内存身份认证2.JDBC身份认证(1)数据准备 (2)配置依

SpringBoot整合OpenFeign的完整指南

《SpringBoot整合OpenFeign的完整指南》OpenFeign是由Netflix开发的一个声明式Web服务客户端,它使得编写HTTP客户端变得更加简单,本文为大家介绍了SpringBoot... 目录什么是OpenFeign环境准备创建 Spring Boot 项目添加依赖启用 OpenFeig

Java Spring 中 @PostConstruct 注解使用原理及常见场景

《JavaSpring中@PostConstruct注解使用原理及常见场景》在JavaSpring中,@PostConstruct注解是一个非常实用的功能,它允许开发者在Spring容器完全初... 目录一、@PostConstruct 注解概述二、@PostConstruct 注解的基本使用2.1 基本代

springboot使用Scheduling实现动态增删启停定时任务教程

《springboot使用Scheduling实现动态增删启停定时任务教程》:本文主要介绍springboot使用Scheduling实现动态增删启停定时任务教程,具有很好的参考价值,希望对大家有... 目录1、配置定时任务需要的线程池2、创建ScheduledFuture的包装类3、注册定时任务,增加、删

SpringBoot整合mybatisPlus实现批量插入并获取ID详解

《SpringBoot整合mybatisPlus实现批量插入并获取ID详解》这篇文章主要为大家详细介绍了SpringBoot如何整合mybatisPlus实现批量插入并获取ID,文中的示例代码讲解详细... 目录【1】saveBATch(一万条数据总耗时:2478ms)【2】集合方式foreach(一万条数

IntelliJ IDEA 中配置 Spring MVC 环境的详细步骤及问题解决

《IntelliJIDEA中配置SpringMVC环境的详细步骤及问题解决》:本文主要介绍IntelliJIDEA中配置SpringMVC环境的详细步骤及问题解决,本文分步骤结合实例给大... 目录步骤 1:创建 Maven Web 项目步骤 2:添加 Spring MVC 依赖1、保存后执行2、将新的依赖

SpringBoot中配置文件的加载顺序解读

《SpringBoot中配置文件的加载顺序解读》:本文主要介绍SpringBoot中配置文件的加载顺序,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录SpringBoot配置文件的加载顺序1、命令⾏参数2、Java系统属性3、操作系统环境变量5、项目【外部】的ap

SpringBoot UserAgentUtils获取用户浏览器的用法

《SpringBootUserAgentUtils获取用户浏览器的用法》UserAgentUtils是于处理用户代理(User-Agent)字符串的工具类,一般用于解析和处理浏览器、操作系统以及设备... 目录介绍效果图依赖封装客户端工具封装IP工具实体类获取设备信息入库介绍UserAgentUtils

Spring 中的循环引用问题解决方法

《Spring中的循环引用问题解决方法》:本文主要介绍Spring中的循环引用问题解决方法,本文给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友参考下吧... 目录什么是循环引用?循环依赖三级缓存解决循环依赖二级缓存三级缓存本章来聊聊Spring 中的循环引用问题该如何解决。这里聊

Java学习手册之Filter和Listener使用方法

《Java学习手册之Filter和Listener使用方法》:本文主要介绍Java学习手册之Filter和Listener使用方法的相关资料,Filter是一种拦截器,可以在请求到达Servl... 目录一、Filter(过滤器)1. Filter 的工作原理2. Filter 的配置与使用二、Listen