[toc]

文章已收录我的仓库:Java学习笔记与免费书籍分享

synchronized底层原理

前言

在JDK1.5之前,synchronized的实现是依赖于操作系统的,采用的是一种悲观的机制,必须严格保证资源的安全性,因此无论是否存在并发问题,都必须严格的经过获取锁操作,获取锁必须切换至内核态,而当线程尝试获取失败后,必须挂起线程然后切换,休眠或切换线程也都必须切换至内核态由操作系统调度,这种操作是重量级的,然而研究者发现绝大多数情况下,并不会存在资源竞争问题,为此,JDK1.6之后对synchronized进行了大量的优化,线程初始抱着乐观的心态进行尝试(不借助OS),除非迫不得已,线程才会将其托管给操作系统。

本文基于JDK1.6之后的synchronized讲解,synchronized拥有如下几个阶段,其中无锁与偏向锁是同一级别的,常理上来说锁只能升级不能降级,但后面我们会说到这并不是绝对的:

使用过synchronized的朋友都知道,synchronized是基于对象锁定的,即使不传入任何参数,synchronized也会自动锁定this,研究synchronized之前有必要研究一下对象的内存布局,因为在对象头中,存在与synchronized相关的信息。

对象头(Object Head)主要分为两个部分,第一个部分是我们着重要研究的,它是实现synchronized的关键,被称作 “Mark Word”,第二部分记载着指向方法区对象类型的指针,这一部分称为 “Class Metdata”,这一部分并不是我们研究的终点。

synchronized底层原理 - 图1

请注意实际的对象头通常只有 32bit,这意味着 “Mark Word” 字段是复用的,字段修改将会覆盖原来的数据,你完全可以将他理解为C语言中的共用体。

不过,目前大多数机器都是64位的了,这意味着Mark Word字段为64bit,其中主要是线程ID增加到了54位,其余没有改变(1位占位)。

无锁

当锁标志位被设置成01且偏向为设置为0,此时对象处于无锁状态,你可能会觉得无锁阶段就是让线程不持有锁而去访问共享资源,但事实上并不是这样如此,无锁会产生并发问题,无锁仅仅是对象初始时的状态,即当对象未使用synchronized或其他并发语句时,对象处于无锁状态。

请注意,无锁与偏向锁是同一级别的,当开启了偏向锁后,新 new 出来的对象将不再是无锁状态,而是直接处于偏向锁状态(在JVM启动时有所不同,JVM启动时延迟开启偏向锁,这一段时间内对象处于无锁)。

偏向锁

偏向锁的工作原理

当只有一个线程工作时,自然不会发生并发问题,但诸如StringBuffer这样的类内部实现几乎每个函数都使用了synchronized标识,而我们通常使用的String内部也大量借助了StringBuffer类,在JDK1.6以前即使是单线程运行也会造成可怕的性能问题,偏向锁主要用于解决这个问题,即解决数据在无竞争情况下发生不必要的同步机制,从而提高程序性能。

偏向锁中的”偏向“意味着这个锁偏向于某一个线程,这个线程往往是第一个使用偏向锁的线程,在这之前,对象要么处于无锁状态,要么处于匿名偏向锁状态。如果在接下来的过程中,一直没有别的线程申请锁,那么持有偏向锁的线程将不用采用任何的同步机制。

通过引入偏向锁,在单线程内进行synchronized操作将不会陷入内核申请锁,在前面讲过初始状态下,对象处于匿名偏向状态,此时对象偏向于一个匿名的线程,当第一个线程A调用synchronized语句时,JVM发现对象头中的线程ID为匿名ID,于是JVM记录下该线程A的ID到对象头中,这标志着线程A持有了该对象偏向锁,现在该锁会偏向与线程A,只要是线程A申请锁,JVM会无条件直接放行,而无须由操作系统调度,这大大提高了效率。

然而,一旦有其他线程尝试获取偏向锁,如果偏向锁处于非匿名状态,此时是真正意义上的并发环境,JVM会宣告偏向模式结束,如果此时对象未被锁定,即偏向的线程执行完毕未进入同步块,锁会被撤销为无锁状态,如果对象从偏向锁撤回至无锁状态,偏向锁将失效,下一个线程将直接申请轻量级锁;另一种情况,对象会仍然处于锁定状态,即线程A仍在同步语句内运行,此时JVM会将对象的锁标志位设置位”00“,进入轻量级锁,线程A默认持有该锁。

不考虑重偏向的情况下,偏向锁只能偏向一次,因此偏向锁一旦撤销为无锁或升级后,就再也不会进入偏向模式了。

如果此时线程A仍然处于运行状态,线程A必须跑到安全点才能停下来进行偏向锁的撤销(升级),安全点是会触发GC的必要条件,我没有真正理解为什么要到安全点处停下来,猜测升级锁的过程可能需要暂停所有线程或是需要触发GC(触发GC猜测是有根据的,查看下面打印出的对象头,锁升级时对象的分代年纪增加,由此判断必定发生GC),因此需要让线程在安全点处停下来。

我们借助JOL工具(可自行百度)来打印对象头信息,从而理解偏向锁,考虑如下代码,这里我们显示的添加了参数-XX:+UseBiasedLocking强制性要求JVM开启偏向锁:

  1. class A {
  2. boolean flag = false;
  3. }
  4. public class Test {
  5. public static void main(String[] args) {
  6. A a = new A();
  7. //该代码表示打印对象头信息,前提是引入了 JOL 依赖
  8. System.out.println(ClassLayout.parseInstance(a).toPrintable());
  9. synchronized (a) {
  10. System.out.println(ClassLayout.parseInstance(a).toPrintable());
  11. }
  12. synchronized (a) {
  13. System.out.println(ClassLayout.parseInstance(a).toPrintable());
  14. }
  15. var t = new Thread(new Runnable() {
  16. @Override
  17. public void run() {
  18. synchronized (a) {
  19. System.out.println(ClassLayout.parseInstance(a).toPrintable());
  20. }
  21. }
  22. });
  23. t.start();
  24. t.join();
  25. }
  26. }

我们直接来看打印出的结果,在此我只将 Mark Word信息展示出来:

第几次 说明 线程ID Epoch(时间戳) 分代年龄 是否可偏向 锁标志位
第一次 此时对象刚创建,处于匿名偏向锁状态,可以看到,当线程ID全为0时表示匿名状态 == 00 0000 1 01
第二次 此时线程被锁定,进入有名偏向,a对象保存该线程ID T1 00 0000 1 01
第三次 对象发现线程ID一致,直接允许线程进入同步代码块,而不陷入OS T1 00 0000 1 01
第四次 新的线程想要获取锁,JVM发现该锁处于有名偏向状态,撤销偏向锁,于是升级为轻量级锁(从理论上说,这里应该经历了 偏向锁->无锁->轻量级锁几个状态) T2 01 0110 0 00

重偏向

你可能注意到了,Epoch(时间戳)是干什么的?这里要引入重偏向的概念。

先思考一个问题,为什么要重偏向?答案是可以想到的,即使在多线程环境下,如果每个线程都是串行访问呢?在没有重偏向时,只要是多线程访问,就会升级为轻量级锁,即使可能多线程的访问是串行的,即没有并发冲突的。针对这种情况,我们希望线程可以重新持有偏向锁,而不是申请轻量级锁。

现在,线程如何判定自己处于串行状态呢?换句话说,该偏向锁是否还有其他线程占用呢?Epoch就是为了解决这个问题,Epoch 的翻译是时间戳,代表该偏向锁是否被其他线程占有。

进入 synchronized 和退出 synchronized 同步语句块其实都会自增与对象关联 Class 文件中的 MarkWorld 原型中的 Epoch 值,而其中的重点在于,一旦线程成功进入同步语句块,JVM 会将对象的 Epoch 更新为 Class 中最新的 Epoch 值,而退出时只会自增 Class 中的 Epoch,不会更新对象。

所以只需要比较对象 Epoch 值和 Class 中的 Epoch 值是否相等就可以了。

如果相等,对象 Epoch 是最新的,一定是刚进入同步块还未出来,意味着当前偏向锁必定被持有;否则,一定出了同步块,意味着偏向锁过期,允许重偏向,线程可以利用 CAS 将线程 ID 替换为当前线程 ID,Class Epoch 自增,对象 Epoch 更新…..

不过要注意一旦发生了重偏向,该对象就再也不会偏向原先的线程了。

而当偏向锁撤销升级轻量级锁时,JVM 会在安全点执行这个操作,也会利用到 Epoch 字段检查偏向锁是否被当前线程持有,如果是的化,JVM 会扫描当前线程的栈帧(所以必须是安全点)查找锁记录,将锁记录利用 CAS 改为轻量级锁的锁记录,然后修改 MarkWorld,该线程将默认持有轻量级锁;

批量重偏向

重偏向是默认关闭的,只有触发阈值时才会开启重偏向。

class文件中存在一个计数器,每一次与之关联的对象进行升级或撤销时,都会自增该计数器,当达到阈值后(默认的是20次),JVM该类可能频繁的被其他线程访问,于是会开启重偏向,允许对象重新偏向一个线程。

  1. class A {
  2. boolean flag = false;
  3. }
  4. public class Test {
  5. public static void main(String[] args) throws InterruptedException {
  6. List<A> list = new ArrayList<>();
  7. var t1 = new Thread(new Runnable() {
  8. @Override
  9. public void run() {
  10. for (int i = 0; i < 30; i++) {
  11. A a = new A();
  12. list.add(a);
  13. synchronized (a) {
  14. System.out.println("t1::" + i + " == " + ClassLayout.parseInstance(a).toPrintable());
  15. }
  16. }
  17. }
  18. });
  19. t1.start();
  20. t1.join();
  21. var t2 = new Thread(new Runnable() {
  22. @Override
  23. public void run() {
  24. for (int i = 0; i < 25; i++) {
  25. A a = list.get(i);
  26. synchronized (a) {
  27. System.out.println("t2::" + i + " == " + ClassLayout.parseInstance(a).toPrintable());
  28. }
  29. }
  30. }
  31. });
  32. t2.start();
  33. t2.join();
  34. System.out.println(ClassLayout.parseInstance(list.get(28)).toPrintable());
  35. }
  36. }

上面代码中让t1执行20次,每次都创建一个新的对象,t1时所有对象都是偏向锁。

t2时,根据规则,偏向锁将会升级为轻量级锁。但注意,由于对象都关联倒一个A.class中,经历20次撤销后,会触发批量重偏向,通过实践发现t2中前20次确实升级了锁,但第21次倒第25次,又变回了偏向锁。并且,list[28]也被偏向了t2线程,即使t2还未占有它。

当然,如果是真正的发生了并发访问,必须要升级锁,批量重偏向和重偏向只是负担。为此,如果在一定时间内,计数器从批量重偏向的起点(20次)增加到了40次,触发新的阈值(默认为40),此时JVM认为对该类的访问可能真正存在并发问题,该类不适合偏向锁,JVM会自动关闭该类的偏向锁,同时会批量的对锁进行撤销。

其他规则

在前面我们说过Mark Word是复用的,这就意味着偏向锁中的线程ID会复写原先的对象哈希值等数据,这可怎么办呢?了解Java的朋友应该知道对象的哈希码只会被计算一次,然后被永久保存在对象头中,该部分数据是不允许丢失的,但哈希码的计算是延迟计算的,即等待需要时才会计算,这就给偏向锁增加了几条规则:1) 当对象的哈希值已经被计算了,该对象不允许进入偏向锁阶段,而是直接从无锁阶段升级为轻量级锁阶段;2)当对象正处于偏向阶段时,如果收到了计算哈希的请求,会立即撤回偏向锁,直接升级为重量锁,重量级锁中存在字段保存对象的哈希值。

值得一提的是,轻量级锁也是可重入的,仅仅只是比偏向锁多了些操作罢了,但偏向锁在引入重偏向或批量重偏向后也变的不是那么简单,在JDK15之后,官方决定移除偏向锁。

轻量级锁

初衷

偏向锁对于被偏向的线程来说,没有采用任何的同步方式,因此获取锁的成本几乎为零,但偏向锁只能消除单线程环境下不必要的并发同步语句,在真正的多线程环境下却无能为力,必须升级为轻量级锁,轻量级锁能够维护并发安全,同时具有一定的性能。

轻量级锁设计的思想是:研究者们发现即使处于多线程环境中,发生竞争的可能性也是很小的,一个线程可能很快甚至立即就能获取到锁,既然如此,一旦线程获取锁失败,则没必要让其陷入休眠,可以让线程多等等,因为线程很快就能获取锁。

既然不用让线程进入休眠,这意味着我们无须借助操作系统调度的功能(JVM不具备让休眠/唤醒线程的功能,Java中的线程都是被1:1映射到操作系统的线程中,关于线程调度的操作需要依赖OS),也就是说轻量级锁的所有功能都可以由JVM自己实现,这就避免了使用操作系统互斥量和调度线程的性能消耗。

CAS

在介绍轻量级锁实现之前,有必要介绍CAS操作,因为JVM必须要自己实现一个锁以避免并发问题,而JVM肯定不能借助synchronized实现锁,否则就套娃了,因此必须要借助硬件的支持(可参考线程间的同步方式),CAS是目前大多数主流CPU都提供的一种原语,正如它的全称(比较并交换; Compare And Swag)一样,CAS的C代码大概如下所示:

  1. int CompareAndSwap(int *ptr, int expected, int new) {
  2. int actual = *ptr;
  3. if (actual == expected) {
  4. *ptr = new;
  5. }
  6. return actual;
  7. }

CAS的魅力在于它无须获得锁,而是直接进行尝试,如果原数据与期望值相同,则更新数据,否则不更新数据,更新数据失败后,线程可以重新尝试,这样说可能难以理解,假设有全局变量volatile int num = 1,假定多条线程都在访问该变量,其中有一条线程想要将num + 10,来看下面C代码,该线程可以这样做:

  1. int currentNum;
  2. do {
  3. currentNum = num;
  4. } while (CompareAndSwap(&num, currentNum, currentNum + 10) != currentNum);

理解为什么这样做不会发生并发问题,如果真的发现并发问题,只可能在执行完第3行后线程被切换,来分析一下这个过程,假设初始时num = 1,线程A执行完第三行后 currentNum = 1,此时线程B强入,线程B修改num = 520,然后回到线程A,线程执行原语CAS,CAS不允许被强入,CAS执行阶段发现 num(520) 与 currentNum(1) 不相等,此时线程明白该值已经被其他线程修改,变”脏“了,于是不更新num的值,然后返回 520,520 != 1,线程继续尝试,直到正确执行。CAS是一种乐观的并发策略,线程总是假设马上就能成功甚至立即可以成功而不会发生并发问题,测试发现,多个线程同一时间并发竞争某一资源时,只有一个能成功,而其余都将失败。

CAS使真正的无锁编程称为可能,在valHandle类中,CAS操作已经正式对用户开放了,未来可能真正将会进入无锁编程时代,但这里我们仅将CAS作为实现轻量级锁的一种方式。要注意,CAS也是有缺点的,例如CAS可能会导致线程饿死;例如CAS不断自旋可能会导致CPU飙升;又例如CAS存在”ABA“问题,即值从A变为B,又从B变为A,对于线程来说,该值好像从来没有变化,一直为A,解决这个问题的办法是引入版本号,但这无疑增加了复杂度。

具体实现

现在,我们开始研究轻量级锁的具体实现,在偏向锁中,我们谈到一旦哈希值被计算,它必须要被保存下来,基于此,轻量级锁实现中,线程会复制一份原先的Mark Word存放在自己的栈帧中,然后再覆盖哈希值的数据。称复制品占用的空间为锁记录(Lock Record)空间。

那么对象又如何直到该锁记录所在位置呢?在对象的Mark Word中,记录着指向该行记录的指针,同时,行记录中存放着指向对象头的指针(这一点我不理解),如下图所示:

synchronized底层原理 - 图2

现在来具体理解一下实现原理,当线程想要获取轻量级锁时,无外乎就两种情况:

  1. 锁的状态为偏向锁(开启偏向锁时),但偏向的是其他线程或锁的状态为无锁状态(偏向锁不可用)。此时锁会升级为轻量级锁,JVM首先在当前线程栈帧中创建锁记录,然后利用CAS操作将对象中的Mark Word指针修改为执行锁记录的位置,如果修改成功则线程成功持有轻量级锁;否则,一旦CAS失败,上面讲过肯定存在另一个线程成功的强入,此时线程将自旋并且重试(进入情况2)。
  2. 锁的状态已经为轻量级锁。此时JVM会检查Mark Word中的指针是否指向当前栈帧,如果是则复制一份空的锁记录到栈帧中(计数作用),然后直接放行(这也是为什么说synchronized是可重入的原因),否则进行自旋不断尝试,若条件符合情况1,则重试CAS操作;若条件符合情况2,则重新判断Mark Word中的指针是否指向当前栈帧。

现在来考虑线程释放轻量级锁的操作,释放锁也存在两种情况:

  1. 轻量级锁未升级。当轻量级锁未升级时,此时为正常状态,线程利用CAS操作将原来的Mark Word复制回去,对象恢复偏向或无锁状态,其他线程可获取轻量级锁。
  2. 轻量级锁已升级。我们在之前讨论过CAS的缺点,当自旋过多或线程过多时,CAS反而降低效率,为此,JVM制定了一些规则来升级轻量级锁:
    1)等待线程自旋次数超过一定次数时(默认为10次,可以添加参数-XX:PreBlockSpin=val来修改),升级为重量级锁;
    2)当正在等待的线程不只一个时,升级为重量级锁。
    3)正在持有轻量级锁时,如果收到重新计算哈希值的请求,升级为重量级锁。
    当升级时,JVM修改Mark Word中的数据,并且使所有等待线程陷入休眠,JVM并不会强制性要求持有轻量级锁线程释放。由于Mark Word数据已被修改,当轻量级锁释放时,指向CAS操作必然会失败,此时线程意识到锁已升级,此时它必须利用Mark Word中指向重量级锁的指针来唤醒正在休眠的线程。

重量级锁

当锁升级为重量级锁时,此时必须依赖于操作系统实现,Java中封装了一层抽象,每一个对象与Class都有与之关联的监听器Monitor,重量级锁对象中指针便是指向了对应的Monitor对象。

Monitor利用操作系统的Mutex(互斥量)维护了一系列的变量,例如正在持有锁的线程ID、线程Mark Word等,其中最主要的是一个int类型的数量值,当该值为0时,意味着线程可以持有锁,此时线程登记自己的信息,递增该值;当线程发现线程ID是自己时,自增该变量,并继续持有锁;当该值不为0时,线程需要陷入休眠等待该值为0。而当线程释放锁时,需要自减该值,并唤醒等待队列中的全部线程,让线程非公平的竞争锁(依赖于具体OS的实现)。

熟悉并发的朋友们很快就能发现整个操作的逻辑十分类似于采用条件变量(可参考线程间的同步方式),事实上Monitor就是采用条件变量实现的,而条件变量必要的三要素:互斥锁、休眠、唤醒都是基于操作系统实现的,此时的锁是重量级的。

在jdk1.6之前,synchronized语句块反编译出的字节码会用monitorentermonitorexit包括代码块,monitorenter指令表示线程必须持有对象的锁才能进入代码块,monitorexit指令则是表示释放该锁。不过在jdk1.6之后,指令的语义已经变了,会根据不同的锁以生成不同的策略。