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

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

最简单的东西,往往包含了最复杂的实现,因为需要为上层的存在提供一个稳定的基础,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 技术具有卓越的通用性、高效性、平台移植性和安全性。

    3186 引用 • 8212 回帖 • 1 关注
  • JVM

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

    180 引用 • 120 回帖 • 1 关注
  • 12 引用 • 8 回帖

相关帖子

欢迎来到这里!

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

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

推荐标签 标签

  • GitBook

    GitBook 使您的团队可以轻松编写和维护高质量的文档。 分享知识,提高团队的工作效率,让用户满意。

    3 引用 • 8 回帖 • 4 关注
  • MyBatis

    MyBatis 本是 Apache 软件基金会 的一个开源项目 iBatis,2010 年这个项目由 Apache 软件基金会迁移到了 google code,并且改名为 MyBatis ,2013 年 11 月再次迁移到了 GitHub。

    170 引用 • 414 回帖 • 383 关注
  • Git

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

    209 引用 • 358 回帖
  • 国际化

    i18n(其来源是英文单词 internationalization 的首末字符 i 和 n,18 为中间的字符数)是“国际化”的简称。对程序来说,国际化是指在不修改代码的情况下,能根据不同语言及地区显示相应的界面。

    8 引用 • 26 回帖
  • Jenkins

    Jenkins 是一套开源的持续集成工具。它提供了非常丰富的插件,让构建、部署、自动化集成项目变得简单易用。

    53 引用 • 37 回帖
  • 数据库

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

    338 引用 • 705 回帖
  • RYMCU

    RYMCU 致力于打造一个即严谨又活泼、专业又不失有趣,为数百万人服务的开源嵌入式知识学习交流平台。

    4 引用 • 6 回帖 • 53 关注
  • Latke

    Latke 是一款以 JSON 为主的 Java Web 框架。

    70 引用 • 533 回帖 • 778 关注
  • Ant-Design

    Ant Design 是服务于企业级产品的设计体系,基于确定和自然的设计价值观上的模块化解决方案,让设计者和开发者专注于更好的用户体验。

    17 引用 • 23 回帖
  • 程序员

    程序员是从事程序开发、程序维护的专业人员。

    565 引用 • 3532 回帖
  • 开源中国

    开源中国是目前中国最大的开源技术社区。传播开源的理念,推广开源项目,为 IT 开发者提供了一个发现、使用、并交流开源技术的平台。目前开源中国社区已收录超过两万款开源软件。

    7 引用 • 86 回帖
  • 小薇

    小薇是一个用 Java 写的 QQ 聊天机器人 Web 服务,可以用于社群互动。

    由于 Smart QQ 从 2019 年 1 月 1 日起停止服务,所以该项目也已经停止维护了!

    34 引用 • 467 回帖 • 741 关注
  • 禅道

    禅道是一款国产的开源项目管理软件,她的核心管理思想基于敏捷方法 scrum,内置了产品管理和项目管理,同时又根据国内研发现状补充了测试管理、计划管理、发布管理、文档管理、事务管理等功能,在一个软件中就可以将软件研发中的需求、任务、bug、用例、计划、发布等要素有序的跟踪管理起来,完整地覆盖了项目管理的核心流程。

    6 引用 • 15 回帖 • 127 关注
  • Mobi.css

    Mobi.css is a lightweight, flexible CSS framework that focus on mobile.

    1 引用 • 6 回帖 • 733 关注
  • WebComponents

    Web Components 是 W3C 定义的标准,它给了前端开发者扩展浏览器标签的能力,可以方便地定制可复用组件,更好的进行模块化开发,解放了前端开发者的生产力。

    1 引用 • 2 关注
  • Bootstrap

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

    18 引用 • 33 回帖 • 659 关注
  • Firefox

    Mozilla Firefox 中文俗称“火狐”(正式缩写为 Fx 或 fx,非正式缩写为 FF),是一个开源的网页浏览器,使用 Gecko 排版引擎,支持多种操作系统,如 Windows、OSX 及 Linux 等。

    8 引用 • 30 回帖 • 407 关注
  • 996
    13 引用 • 200 回帖 • 2 关注
  • Gitea

    Gitea 是一个开源社区驱动的轻量级代码托管解决方案,后端采用 Go 编写,采用 MIT 许可证。

    4 引用 • 16 回帖
  • Scala

    Scala 是一门多范式的编程语言,集成面向对象编程和函数式编程的各种特性。

    13 引用 • 11 回帖 • 123 关注
  • ZooKeeper

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

    59 引用 • 29 回帖 • 3 关注
  • 正则表达式

    正则表达式(Regular Expression)使用单个字符串来描述、匹配一系列遵循某个句法规则的字符串。

    31 引用 • 94 回帖 • 1 关注
  • OpenShift

    红帽提供的 PaaS 云,支持多种编程语言,为开发人员提供了更为灵活的框架、存储选择。

    14 引用 • 20 回帖 • 623 关注
  • 阿里巴巴

    阿里巴巴网络技术有限公司(简称:阿里巴巴集团)是以曾担任英语教师的马云为首的 18 人,于 1999 年在中国杭州创立,他们相信互联网能够创造公平的竞争环境,让小企业通过创新与科技扩展业务,并在参与国内或全球市场竞争时处于更有利的位置。

    43 引用 • 221 回帖 • 127 关注
  • 一些有用的避坑指南。

    69 引用 • 93 回帖
  • Ubuntu

    Ubuntu(友帮拓、优般图、乌班图)是一个以桌面应用为主的 Linux 操作系统,其名称来自非洲南部祖鲁语或豪萨语的“ubuntu”一词,意思是“人性”、“我的存在是因为大家的存在”,是非洲传统的一种价值观,类似华人社会的“仁爱”思想。Ubuntu 的目标在于为一般用户提供一个最新的、同时又相当稳定的主要由自由软件构建而成的操作系统。

    124 引用 • 169 回帖
  • MongoDB

    MongoDB(来自于英文单词“Humongous”,中文含义为“庞大”)是一个基于分布式文件存储的数据库,由 C++ 语言编写。旨在为应用提供可扩展的高性能数据存储解决方案。MongoDB 是一个介于关系数据库和非关系数据库之间的产品,是非关系数据库当中功能最丰富,最像关系数据库的。它支持的数据结构非常松散,是类似 JSON 的 BSON 格式,因此可以存储比较复杂的数据类型。

    90 引用 • 59 回帖 • 4 关注