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

相关文章

Java编译生成多个.class文件的原理和作用

《Java编译生成多个.class文件的原理和作用》作为一名经验丰富的开发者,在Java项目中执行编译后,可能会发现一个.java源文件有时会产生多个.class文件,从技术实现层面详细剖析这一现象... 目录一、内部类机制与.class文件生成成员内部类(常规内部类)局部内部类(方法内部类)匿名内部类二、

SpringBoot实现数据库读写分离的3种方法小结

《SpringBoot实现数据库读写分离的3种方法小结》为了提高系统的读写性能和可用性,读写分离是一种经典的数据库架构模式,在SpringBoot应用中,有多种方式可以实现数据库读写分离,本文将介绍三... 目录一、数据库读写分离概述二、方案一:基于AbstractRoutingDataSource实现动态

Springboot @Autowired和@Resource的区别解析

《Springboot@Autowired和@Resource的区别解析》@Resource是JDK提供的注解,只是Spring在实现上提供了这个注解的功能支持,本文给大家介绍Springboot@... 目录【一】定义【1】@Autowired【2】@Resource【二】区别【1】包含的属性不同【2】@

springboot循环依赖问题案例代码及解决办法

《springboot循环依赖问题案例代码及解决办法》在SpringBoot中,如果两个或多个Bean之间存在循环依赖(即BeanA依赖BeanB,而BeanB又依赖BeanA),会导致Spring的... 目录1. 什么是循环依赖?2. 循环依赖的场景案例3. 解决循环依赖的常见方法方法 1:使用 @La

Java枚举类实现Key-Value映射的多种实现方式

《Java枚举类实现Key-Value映射的多种实现方式》在Java开发中,枚举(Enum)是一种特殊的类,本文将详细介绍Java枚举类实现key-value映射的多种方式,有需要的小伙伴可以根据需要... 目录前言一、基础实现方式1.1 为枚举添加属性和构造方法二、http://www.cppcns.co

Elasticsearch 在 Java 中的使用教程

《Elasticsearch在Java中的使用教程》Elasticsearch是一个分布式搜索和分析引擎,基于ApacheLucene构建,能够实现实时数据的存储、搜索、和分析,它广泛应用于全文... 目录1. Elasticsearch 简介2. 环境准备2.1 安装 Elasticsearch2.2 J

Java中的String.valueOf()和toString()方法区别小结

《Java中的String.valueOf()和toString()方法区别小结》字符串操作是开发者日常编程任务中不可或缺的一部分,转换为字符串是一种常见需求,其中最常见的就是String.value... 目录String.valueOf()方法方法定义方法实现使用示例使用场景toString()方法方法

Java中List的contains()方法的使用小结

《Java中List的contains()方法的使用小结》List的contains()方法用于检查列表中是否包含指定的元素,借助equals()方法进行判断,下面就来介绍Java中List的c... 目录详细展开1. 方法签名2. 工作原理3. 使用示例4. 注意事项总结结论:List 的 contain

Java实现文件图片的预览和下载功能

《Java实现文件图片的预览和下载功能》这篇文章主要为大家详细介绍了如何使用Java实现文件图片的预览和下载功能,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一下... Java实现文件(图片)的预览和下载 @ApiOperation("访问文件") @GetMapping("

Spring Boot + MyBatis Plus 高效开发实战从入门到进阶优化(推荐)

《SpringBoot+MyBatisPlus高效开发实战从入门到进阶优化(推荐)》本文将详细介绍SpringBoot+MyBatisPlus的完整开发流程,并深入剖析分页查询、批量操作、动... 目录Spring Boot + MyBATis Plus 高效开发实战:从入门到进阶优化1. MyBatis