JVM 源码分析之 Object.wait notify 实现

本贴最后更新于 2162 天前,其中的信息可能已经时移俗易

最简单的东西,往往包含了最复杂的实现,因为需要为上层的存在提供一个稳定的基础,Object 作为 java 中所有对象的基类,其存在的价值不言而喻,其中 wait 和 notify 方法的实现多线程协作提供了保证。

public class WaitNotifyCase {

public static void main(String[] args) {

    final Object lock = new Object();

    new Thread(new Runnable() {

        @Override

        public void run() {

            System.out.println("thread A is waiting to get lock");

            synchronized (lock) {

                try {

                    System.out.println("thread A get lock");

                    TimeUnit.SECONDS.sleep(1);

                    System.out.println("thread A do wait method");

                    lock.wait();

                    System.out.println("wait end");

                } catch (InterruptedException e) {

                    e.printStackTrace();

                }

            }

        }

    }).start();

    new Thread(new Runnable() {

        @Override

        public void run() {

            System.out.println("thread B is waiting to get lock");

            synchronized (lock) {

                System.out.println("thread B get lock");

                try {

                    TimeUnit.SECONDS.sleep(5);

                } catch (InterruptedException e) {

                    e.printStackTrace();

                }

                lock.notify();

                System.out.println("thread B do notify method");

            }

        }

    }).start();

}

}

执行结果:

thread A is waiting to get lock

thread A get lock

thread B is waiting to get lock

thread A do wait method

thread B get lock

thread B do notify method

wait end

前提:由同一个 lock 对象调用 wait、notify 方法。

1、当线程 A 执行 wait 方法时,该线程会被挂起;

2、当线程 B 执行 notify 方法时,会唤醒一个被挂起的线程 A;

lock 对象、线程 A 和线程 B 三者是一种什么关系?根据上面的结论,可以想象一个场景:

1、lock 对象维护了一个等待队列 list;

2、线程 A 中执行 lock 的 wait 方法,把线程 A 保存到 list 中;

3、线程 B 中执行 lock 的 notify 方法,从等待队列中取出线程 A 继续执行;

当然了,Hotspot 实现不可能这么简单。

上述代码中,存在多个疑问:

1、进入 wait/notify 方法之前,为什么要获取 synchronized 锁?

2、线程 A 获取了 synchronized 锁,执行 wait 方法并挂起,线程 B 又如何再次获取锁?

为什么要使用 synchronized?

static void Sort(int [] array) {

// synchronize this operation so that some other thread can't

// manipulate the array while we are sorting it. This assumes that other

// threads also synchronize their accesses to the array.

synchronized(array) {

    // now sort elements in array

}

}

synchronized 代码块通过 javap 生成的字节码中包含 ** monitorenter ** 和 ** monitorexit **指令。

执行 monitorenter 指令可以获取对象的 monitor,而 lock.wait()方法通过调用 native 方法 wait(0)实现,其中接口注释中有这么一句:

The current thread must own this object's monitor.

表示线程执行 lock.wait()方法时,必须持有该 lock 对象的 monitor,如果 wait 方法在 synchronized 代码中执行,该线程很显然已经持有了 monitor。

代码执行过程分析

1、在多核环境下,线程 A 和 B 有可能同时执行 monitorenter 指令,并获取 lock 对象关联的 monitor,只有一个线程可以和 monitor 建立关联,假设线程 A 执行加锁成功;

2、线程 B 竞争加锁失败,进入等待队列进行等待;

3、线程 A 继续执行,当执行到 wait 方法时,会发生什么?wait 接口注释:

This method causes the current thread to place itself in the wait set for this object and then to relinquish any and all synchronization claims on this object.

wait 方法会将当前线程放入 wait set,等待被唤醒,并放弃 lock 对象上的所有同步声明,意味着线程 A 释放了锁,线程 B 可以重新执行加锁操作,不过又有一个疑问:在线程 A 的 wait 方法释放锁,到线程 B 获取锁,这期间发生了什么?线程 B 是如何知道线程 A 已经释放了锁?好迷茫....

4、线程 B 执行加锁操作成功,对于 notify 方法,JDK 注释:notify 方法会选择 wait set 中任意一个线程进行唤醒;

Wakes up a single thread that is waiting on this object's monitor. If any threads are waiting on this object, one of them is chosen to be awakened. The choice is arbitrary and occurs at the discretion of the implementation

notifyAll 方法的注释:notifyAll 方法会唤醒 monitor 的 wait set 中所有线程。

Wakes up all threads that are waiting on this object's monitor.

5、执行完 notify 方法,并不会立马唤醒等待线程,在 notify 方法后面加一段 sleep 代码就可以看到效果,如果线程 B 执行完 notify 方法之后 sleep 5s,在这段时间内,线程 B 依旧持有 monitor,线程 A 只能继续等待;

那么 wait set 的线程什么时候会被唤醒?

想要解答这些疑问, 需要分析 jvm 的相关实现,本文以 HotSpot 虚拟机 1.7 版本为例

什么是 monitor?

在 HotSpot 虚拟机中,monitor 采用 ObjectMonitor 实现。

每个线程都有两个 ObjectMonitor 对象列表,分别为 free 和 used 列表,如果当前 free 列表为空,线程将向全局 global list 请求分配 ObjectMonitor。

ObjectMonitor 对象中有两个队列:_WaitSet 和 _EntryList,用来保存 ObjectWaiter 对象列表;_owner 指向获得 ObjectMonitor 对象的线程。

**_WaitSet ** :处于 wait 状态的线程,会被加入到 wait set;

_EntryList:处于等待锁 block 状态的线程,会被加入到 entry set;

ObjectWaiter

ObjectWaiter 对象是双向链表结构,保存了_thread(当前线程)以及当前的状态 TState 等数据, 每个等待锁的线程都会被封装成 ObjectWaiter 对象。

wait 方法实现

lock.wait()方法最终通过 ObjectMonitor 的 void wait(jlong millis, bool interruptable, TRAPS);实现:

1、将当前线程封装成 ObjectWaiter 对象 node;

2、通过 ObjectMonitor::AddWaiter 方法将 node 添加到_WaitSet 列表中;

3、通过 ObjectMonitor::exit 方法释放当前的 ObjectMonitor 对象,这样其它竞争线程就可以获取该 ObjectMonitor 对象。

4、最终底层的 park 方法会挂起线程;

notify 方法实现

lock.notify()方法最终通过 ObjectMonitor 的 void notify(TRAPS)实现:

1、如果当前_WaitSet 为空,即没有正在等待的线程,则直接返回;

2、通过 ObjectMonitor::DequeueWaiter 方法,获取_WaitSet 列表中的第一个 ObjectWaiter 节点,实现也很简单。

这里需要注意的是,在 jdk 的 notify 方法注释是随机唤醒一个线程,其实是第一个 ObjectWaiter 节点

3、根据不同的策略,将取出来的 ObjectWaiter 节点,加入到_EntryList 或则通过 Atomic::cmpxchg_ptr 指令进行自旋操作 cxq,具体代码实现有点长,这里就不贴了,有兴趣的同学可以看 objectMonitor::notify 方法;

notify ALL 方法实现

lock.notifyAll()方法最终通过 ObjectMonitor 的 void notifyAll(TRAPS)实现:

通过 for 循环取出_WaitSet 的 ObjectWaiter 节点,并根据不同策略,加入到_EntryList 或则进行自旋操作。

从 JVM 的方法实现中,可以发现:notify 和 notifyAll 并不会释放所占有的 ObjectMonitor 对象,其实真正释放 ObjectMonitor 对象的时间点是在执行 monitorexit 指令,一旦释放 ObjectMonitor 对象了,entry set 中 ObjectWaiter 节点所保存的线程就可以开始竞争 ObjectMonitor 对象进行加锁操作了。

  • Java

    Java 是一种可以撰写跨平台应用软件的面向对象的程序设计语言,是由 Sun Microsystems 公司于 1995 年 5 月推出的。Java 技术具有卓越的通用性、高效性、平台移植性和安全性。

    3187 引用 • 8213 回帖
  • JVM

    JVM(Java Virtual Machine)Java 虚拟机是一个微型操作系统,有自己的硬件构架体系,还有相应的指令系统。能够识别 Java 独特的 .class 文件(字节码),能够将这些文件中的信息读取出来,使得 Java 程序只需要生成 Java 虚拟机上的字节码后就能在不同操作系统平台上进行运行。

    180 引用 • 120 回帖
  • 12 引用 • 8 回帖

相关帖子

欢迎来到这里!

我们正在构建一个小众社区,大家在这里相互信任,以平等 • 自由 • 奔放的价值观进行分享交流。最终,希望大家能够找到与自己志同道合的伙伴,共同成长。

注册 关于
请输入回帖内容 ...

推荐标签 标签

  • Git

    Git 是 Linux Torvalds 为了帮助管理 Linux 内核开发而开发的一个开放源码的版本控制软件。

    209 引用 • 358 回帖
  • Mac

    Mac 是苹果公司自 1984 年起以“Macintosh”开始开发的个人消费型计算机,如:iMac、Mac mini、Macbook Air、Macbook Pro、Macbook、Mac Pro 等计算机。

    166 引用 • 595 回帖
  • API

    应用程序编程接口(Application Programming Interface)是一些预先定义的函数,目的是提供应用程序与开发人员基于某软件或硬件得以访问一组例程的能力,而又无需访问源码,或理解内部工作机制的细节。

    77 引用 • 430 回帖 • 2 关注
  • Bootstrap

    Bootstrap 是 Twitter 推出的一个用于前端开发的开源工具包。它由 Twitter 的设计师 Mark Otto 和 Jacob Thornton 合作开发,是一个 CSS / HTML 框架。

    18 引用 • 33 回帖 • 660 关注
  • PWA

    PWA(Progressive Web App)是 Google 在 2015 年提出、2016 年 6 月开始推广的项目。它结合了一系列现代 Web 技术,在网页应用中实现和原生应用相近的用户体验。

    14 引用 • 69 回帖 • 154 关注
  • PWL

    组织简介

    用爱发电 (Programming With Love) 是一个以开源精神为核心的民间开源爱好者技术组织,“用爱发电”象征开源与贡献精神,加入组织,代表你将遵守组织的“个人开源爱好者”的各项条款。申请加入:用爱发电组织邀请帖
    用爱发电组织官网:https://programmingwithlove.stackoverflow.wiki/

    用爱发电组织的核心驱动力:

    • 遵守开源守则,体现开源&贡献精神:以分享为目的,拒绝非法牟利。
    • 自我保护:使用适当的 License 保护自己的原创作品。
    • 尊重他人:不以各种理由、各种漏洞进行未经允许的抄袭、散播、洩露;以礼相待,尊重所有对社区做出贡献的开发者;通过他人的分享习得知识,要留下足迹,表示感谢。
    • 热爱编程、热爱学习:加入组织,热爱编程是首当其要的。我们欢迎热爱讨论、分享、提问的朋友,也同样欢迎默默成就的朋友。
    • 倾听:正确并恳切对待、处理问题与建议,及时修复开源项目的 Bug ,及时与反馈者沟通。不抬杠、不无视、不辱骂。
    • 平视:不诋毁、轻视、嘲讽其他开发者,主动提出建议、施以帮助,以和谐为本。只要他人肯努力,你也可能会被昔日小看的人所超越,所以请保持谦虚。
    • 乐观且活跃:你的努力决定了你的高度。不要放弃,多年后回头俯瞰,才会发现自己已经成就往日所仰望的水平。积极地将项目开源,帮助他人学习、改进,自己也会获得相应的提升、成就与成就感。
    1 引用 • 487 回帖
  • 新人

    让我们欢迎这对新人。哦,不好意思说错了,让我们欢迎这位新人!
    新手上路,请谨慎驾驶!

    52 引用 • 228 回帖
  • 数据库

    据说 99% 的性能瓶颈都在数据库。

    340 引用 • 708 回帖
  • Kotlin

    Kotlin 是一种在 Java 虚拟机上运行的静态类型编程语言,由 JetBrains 设计开发并开源。Kotlin 可以编译成 Java 字节码,也可以编译成 JavaScript,方便在没有 JVM 的设备上运行。在 Google I/O 2017 中,Google 宣布 Kotlin 成为 Android 官方开发语言。

    19 引用 • 33 回帖 • 63 关注
  • WebSocket

    WebSocket 是 HTML5 中定义的一种新协议,它实现了浏览器与服务器之间的全双工通信(full-duplex)。

    48 引用 • 206 回帖 • 333 关注
  • Java

    Java 是一种可以撰写跨平台应用软件的面向对象的程序设计语言,是由 Sun Microsystems 公司于 1995 年 5 月推出的。Java 技术具有卓越的通用性、高效性、平台移植性和安全性。

    3187 引用 • 8213 回帖
  • SEO

    发布对别人有帮助的原创内容是最好的 SEO 方式。

    35 引用 • 200 回帖 • 22 关注
  • 安装

    你若安好,便是晴天。

    132 引用 • 1184 回帖
  • Hadoop

    Hadoop 是由 Apache 基金会所开发的一个分布式系统基础架构。用户可以在不了解分布式底层细节的情况下,开发分布式程序。充分利用集群的威力进行高速运算和存储。

    86 引用 • 122 回帖 • 625 关注
  • Thymeleaf

    Thymeleaf 是一款用于渲染 XML/XHTML/HTML5 内容的模板引擎。类似 Velocity、 FreeMarker 等,它也可以轻易的与 Spring 等 Web 框架进行集成作为 Web 应用的模板引擎。与其它模板引擎相比,Thymeleaf 最大的特点是能够直接在浏览器中打开并正确显示模板页面,而不需要启动整个 Web 应用。

    11 引用 • 19 回帖 • 354 关注
  • ZooKeeper

    ZooKeeper 是一个分布式的,开放源码的分布式应用程序协调服务,是 Google 的 Chubby 一个开源的实现,是 Hadoop 和 HBase 的重要组件。它是一个为分布式应用提供一致性服务的软件,提供的功能包括:配置维护、域名服务、分布式同步、组服务等。

    59 引用 • 29 回帖 • 5 关注
  • V2Ray
    1 引用 • 15 回帖
  • Elasticsearch

    Elasticsearch 是一个基于 Lucene 的搜索服务器。它提供了一个分布式多用户能力的全文搜索引擎,基于 RESTful 接口。Elasticsearch 是用 Java 开发的,并作为 Apache 许可条款下的开放源码发布,是当前流行的企业级搜索引擎。设计用于云计算中,能够达到实时搜索,稳定,可靠,快速,安装使用方便。

    117 引用 • 99 回帖 • 211 关注
  • PHP

    PHP(Hypertext Preprocessor)是一种开源脚本语言。语法吸收了 C 语言、 Java 和 Perl 的特点,主要适用于 Web 开发领域,据说是世界上最好的编程语言。

    179 引用 • 407 回帖 • 488 关注
  • Sphinx

    Sphinx 是一个基于 SQL 的全文检索引擎,可以结合 MySQL、PostgreSQL 做全文搜索,它可以提供比数据库本身更专业的搜索功能,使得应用程序更容易实现专业化的全文检索。

    1 引用 • 211 关注
  • 资讯

    资讯是用户因为及时地获得它并利用它而能够在相对短的时间内给自己带来价值的信息,资讯有时效性和地域性。

    55 引用 • 85 回帖
  • 大数据

    大数据(big data)是指无法在一定时间范围内用常规软件工具进行捕捉、管理和处理的数据集合,是需要新处理模式才能具有更强的决策力、洞察发现力和流程优化能力的海量、高增长率和多样化的信息资产。

    93 引用 • 113 回帖
  • 开源

    Open Source, Open Mind, Open Sight, Open Future!

    408 引用 • 3574 回帖
  • Sublime

    Sublime Text 是一款可以用来写代码、写文章的文本编辑器。支持代码高亮、自动完成,还支持通过插件进行扩展。

    10 引用 • 5 回帖
  • jsoup

    jsoup 是一款 Java 的 HTML 解析器,可直接解析某个 URL 地址、HTML 文本内容。它提供了一套非常省力的 API,可通过 DOM,CSS 以及类似于 jQuery 的操作方法来取出和操作数据。

    6 引用 • 1 回帖 • 478 关注
  • ZeroNet

    ZeroNet 是一个基于比特币加密技术和 BT 网络技术的去中心化的、开放开源的网络和交流系统。

    1 引用 • 21 回帖 • 637 关注
  • CSS

    CSS(Cascading Style Sheet)“层叠样式表”是用于控制网页样式并允许将样式信息与网页内容分离的一种标记性语言。

    198 引用 • 550 回帖