Monitor是 Java中用以实现线程之间的互斥与协作的主要手段,它可以看成是对象或者 Class的锁。每一个对象都有,也仅有一个 monitor。上面这个图,描述了线程和 Monitor之间关系,以及线程的状态转换图。
进入区(Entrt Set):表示线程通过synchronized要求获取对象的锁。如果对象未被锁住,则迚入拥有者;否则则在进入区等待。一旦对象锁被其他线程释放,立即参与竞争。
拥有者(The Owner):表示某一线程成功竞争到对象锁。
等待区(Wait Set):表示线程通过对象的wait方法,释放对象的锁,并在等待区等待被唤醒。
从图中可以看出,一个 Monitor在某个时刻,只能被一个线程拥有,该线程就是 “Active Thread”,而其它线程都是 “Waiting Thread”,分别在两个队列 “ Entry Set”和 “Wait Set”里面等候。在 “Entry Set”中等待的线程状态是 “Waiting for monitor entry”,而在 “Wait Set”中等待的线程状态是 “in Object.wait()”。 先看 “Entry Set”里面的线程。我们称被 synchronized保护起来的代码段为临界区。当一个线程申请进入临界区时,它就进入了 “Entry Set”队列。
synchronized
是依赖于JVM
来实现同步的,在同步方法和代码块的原理有点区别。
我们在代码块加上synchronized
关键字
public void synSay() { synchronized (object) { System.out.println("synSay----" + Thread.currentThread().getName()); }
}
编译之后,我们利用反编译命令javap -v xxx.class
查看对应的字节码,这里为了减少篇幅,我就只粘贴对应的方法的字节码。
public void synSay();descriptor: ()Vflags: ACC_PUBLICCode:stack=3, locals=3, args_size=10: aload_01: getfield #2 // Field object:Ljava/lang/String;4: dup5: astore_16: monitorenter7: getstatic #3 // Field java/lang/System.out:Ljava/io/PrintStream;10: new #4 // class java/lang/StringBuilder13: dup14: invokespecial #5 // Method java/lang/StringBuilder."":()V17: ldc #6 // String synSay----19: invokevirtual #7 // Method java/lang/StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;22: invokestatic #8 // Method java/lang/Thread.currentThread:()Ljava/lang/Thread;25: invokevirtual #9 // Method java/lang/Thread.getName:()Ljava/lang/String;28: invokevirtual #7 // Method java/lang/StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;31: invokevirtual #10 // Method java/lang/StringBuilder.toString:()Ljava/lang/String;34: invokevirtual #11 // Method java/io/PrintStream.println:(Ljava/lang/String;)V37: aload_138: monitorexit39: goto 4742: astore_243: aload_144: monitorexit45: aload_246: athrow47: returnException table:from to target type7 39 42 any42 45 42 anyLineNumberTable:line 21: 0line 22: 7line 23: 37line 24: 47LocalVariableTable:Start Length Slot Name Signature0 48 0 this Lcn/T1;StackMapTable: number_of_entries = 2frame_type = 255 /* full_frame */offset_delta = 42locals = [ class cn/T1, class java/lang/Object ]stack = [ class java/lang/Throwable ]frame_type = 250 /* chop */offset_delta = 4
可以发现synchronized
同步代码块是通过加monitorenter
和monitorexit
指令实现的。
每个对象都有个监视器锁(monitor) ,当monitor
被占用的时候就代表对象处于锁定状态,而monitorenter
指令的作用就是获取monitor
的所有权,monitorexit
的作用是释放monitor
的所有权,这两者的工作流程如下:
monitorenter:
monitor
的进入数为0,则线程进入到monitor
,然后将进入数设置为1
,该线程称为monitor
的所有者。monitor
(即monitor
进入数不为0),然后该线程又重新进入monitor
,则将monitor
的进入数+1
,这个即为锁的重入。monitor
,则该线程进入到阻塞状态,知道monitor的进入数为0,该线程再去重新尝试获取monitor的所有权。monitorexit:
执行该指令的线程必须是monitor
的所有者,指令执行时,monitor
进入数-1
,如果-1
后进入数为0
,那么线程退出monitor
,不再是这个monitor
的所有者。这个时候其它阻塞的线程可以尝试获取monitor
的所有权。
mointorenter对应2个monitorexit,一个正常退出exit,一个是出现异常的时候退出exit。
在方法上加上synchronized
关键字
synchronized public void synSay() { System.out.println("synSay----" + Thread.currentThread().getName());
}
编译之后,我们利用反编译命令javap -v xxx.class
查看对应的字节码,这里为了减少篇幅,我就只粘贴对应的方法的字节码。
public synchronized void synSay();descriptor: ()Vflags: ACC_PUBLIC, ACC_SYNCHRONIZEDCode:stack=3, locals=1, args_size=10: getstatic #2 // Field java/lang/System.out:Ljava/io/PrintStream;3: new #3 // class java/lang/StringBuilder6: dup7: invokespecial #4 // Method java/lang/StringBuilder."":()V10: ldc #5 // String synSay----12: invokevirtual #6 // Method java/lang/StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;15: invokestatic #7 // Method java/lang/Thread.currentThread:()Ljava/lang/Thread;18: invokevirtual #8 // Method java/lang/Thread.getName:()Ljava/lang/String;21: invokevirtual #6 // Method java/lang/StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;24: invokevirtual #9 // Method java/lang/StringBuilder.toString:()Ljava/lang/String;27: invokevirtual #10 // Method java/io/PrintStream.println:(Ljava/lang/String;)V30: returnLineNumberTable:line 20: 0line 21: 30LocalVariableTable:Start Length Slot Name Signature0 31 0 this Lcn/T1;
从字节码上看,加有synchronized
关键字的方法,常量池中比普通的方法多了个ACC_SYNCHRONIZED
标识,JVM
就是根据这个标识来实现方法的同步。
当调用方法的时候,调用指令会检查方法是否有ACC_SYNCHRONIZED
标识,有的话线程需要先获取monitor,获取成功才能继续执行方法,方法执行完毕之后,线程再释放monitor,同一个monitor同一时刻只能被一个线程拥有。
synchronized
同步代码块的时候通过加入字节码monitorenter
和monitorexit
指令来实现monitor
的获取和释放,也就是需要JVM通过字节码显式的去获取和释放monitor实现同步,而synchronized同步方法的时候,没有使用这两个指令,而是检查方法的ACC_SYNCHRONIZED
标志是否被设置,如果设置了则线程需要先去获取monitor,执行完毕了线程再释放monitor,也就是不需要JVM去显式的实现。
这两个同步方式实际都是通过获取monitor和释放monitor来实现同步的,而monitor的实现依赖于底层操作系统的mutex互斥原语,而操作系统实现线程之间的切换的时候需要从用户态转到内核态,这个转成过程开销比较大。
线程获取、释放monitor
的过程如下:
线程尝试获取monitor
的所有权,如果获取失败说明monitor
被其他线程占用,则将线程加入到的同步队列中,等待其他线程释放monitor
,当其他线程释放monitor后,有可能刚好有线程来获取monitor的所有权,那么系统会将monitor的所有权给这个线程,而不会去唤醒同步队列的第一个节点去获取,所以synchronized是非公平锁。如果线程获取monitor
成功则进入到monitor
中,并且将其进入数+1
。
到这里我们也清楚了synchronized
的语义底层是通过一个monitor
的对象完成,其实wait
、notiyf
和notifyAll
等方法也是依赖于monitor
对象来完成的,这也就是为什么需要在同步方法或者同步代码块中调用的原因(需要先获取对象的锁,才能执行),否则会抛出java.lang.IllegalMonitorStateException的异常
我们知道了线程要访问同步方法、代码块的时候,首先需要取得锁,在退出或者抛出异常的时候又必须释放锁,那么锁到底是什么?又储存在哪里?
为了解开这个疑问,我们需要进入Java虚拟机(JVM) 的世界。在HotSpot
虚拟机中,Java
对象在内存中储存的布局可以分为3
块区域:对象头、实例数据、对齐填充。synchronized使用的锁对象储存在对象头中
对象头的数据长度在32
位和64
位(未开启压缩指针)的虚拟机中分别为32bit
和64bit
。对象头由以下三个部分组成:
GC
分代年龄、锁标志位、线程持有的锁、偏向线程ID
、偏向时间戳、对象分代年龄等。注意这个Mark Word结构并不是固定的,它会随着锁状态标志的变化而变化,而且里面的数据也会随着锁状态标志的变化而变化,这样做的目的是为了节省空间。在32
位虚拟机下,Mark Word
的结构和数据可能为以下5
种中的一种。
在64
位虚拟机下,Mark Word
的结构和数据可能为以下2
种中的一种。
这里重点注意是否偏向锁和锁标志位,这两个标识和synchronized
的锁膨胀息息相关。
储存着对象的实际数据,也就是我们在程序中定义的各种类型的字段内容。
HotSpot
虚拟机的对齐方式为8
字节对齐,即一个对象必须为8
字节的整数倍,如果不是,则通过这个对齐填充来占位填充。
从JDK1.6版本之后,synchronized本身也在不断优化锁的机制,有些情况下他并不会是⼀个很重量级的锁。优化机制包括⾃适应锁、⾃旋锁、锁消除、锁粗化、偏向锁、轻量级锁。
上文介绍的 “synchronized
实现原理” 实际是synchronized实现重量级锁的原理,那么上文频繁提到monitor
对象和对象又存在什么关系呢,或者说monitor
对象储存在对象的哪个地方呢?
在对象的对象头中,当锁的状态为重量级锁的时候,它的指针即指向monitor对象,如图:
那锁的状态为其它状态的时候是不是就没用上monitor
对象?答案:是的。
这也是JVM
对synchronized
的优化,我们知道重量级锁的实现是基于底层操作系统的mutex
(mi de s)互斥原语的,这个开销是很大的。所以JVM
对synchronized
做了优化,JVM
先利用对象头实现锁的功能,如果线程的竞争过大则会将锁升级(膨胀)为重量级锁,也就是使用monitor
对象。当然JVM
对锁的优化不仅仅只有这个,还有引入适应性自旋、锁消除、锁粗化、轻量级锁、偏向锁等。
那么锁的是怎么进行膨胀的或者依据什么来膨胀,这也就是本篇需要介绍的重点,首先我们需要了解几个概念。
自旋:当有个线程A
去请求某个锁的时候,这个锁正在被其它线程占用,但是线程A
并不会马上进入阻塞状态,而是循环请求锁(自旋)。这样做的目的是因为很多时候持有锁的线程会很快释放锁的,线程A
可以尝试一直请求锁,没必要被挂起放弃CPU
时间片,因为线程被挂起然后到唤醒这个过程开销很大,当然如果线程A
自旋指定的时间还没有获得锁,仍然会被挂起。
自适应性自旋:自适应性自旋是自旋的升级、优化,自旋的时间不再固定,而是由前一次在同一个锁上的自旋时间及锁的拥有者的状态决定。例如线程如果自旋成功了,那么下次自旋的次数会增多,因为JVM
认为既然上次成功了,那么这次自旋也很有可能成功,那么它会允许自旋的次数更多。反之,如果对于某个锁,自旋很少成功,那么在以后获取这个锁的时候,自旋的次数会变少甚至忽略,避免浪费处理器资源。有了自适应性自旋,随着程序运行和性能监控信息的不断完善,JVM
对程序锁的状况预测就会变得越来越准确,JVM
也就变得越来越聪明。
锁消除是指虚拟机即时编译器在运行时,对一些代码上要求同步,但是被检测到不可能存在共享数据竞争的锁进行消除。
在使用锁的时候,需要让同步块的作用范围尽可能小,这样做的目的是为了使需要同步的操作数量尽可能小,如果存在锁竞争,那么等待锁的线程也能尽快拿到锁。
所谓轻量级锁是相对于使用底层操作系统mutex
互斥原语实现同步的重量级锁而言的,因为轻量级锁同步的实现是基于对象头的Mark Word。那么轻量级锁是怎么使用对象头来实现同步的呢,我们看看具体实现过程。
获取锁过程:
Mark Word
拷贝到线程的锁记录(Lock Recored)中。CAS
操作尝试将对象的Mark Word更新为指向Lock Record的指针。如果这个更新成功了,则执行步骤4
,否则执行步骤5
。Mark Word
是否指向当前线程的栈帧,如果是就说明当前线程已经拥有了这个对象的锁,可以直接进入同步块继续执行,否则说明这个锁对象已经被其其它线程抢占了。进行自旋执行步骤3,如果自旋结束仍然没有获得锁,轻量级锁就需要膨胀为重量级锁,锁标志位状态值变为”10”,Mark Word中储存就是指向monitor对象的指针,当前线程以及后面等待锁的线程也要进入阻塞状态。释放锁的过程:
CAS
操作将对象当前的Mark Word
和线程中复制的Displaced Mark Word
替换回来(依据Mark Word
中锁记录指针是否还指向本线程的锁记录),如果替换成功,则执行步骤2
,否则执行步骤3
。偏向锁的目的是消除数据在无竞争情况下的同步原语,进一步提高程序的运行性能。如果说轻量级锁是在无竞争的情况下使用CAS
操作区消除同步使用的互斥量,那么偏向锁就是在无竞争的情况下把整个同步都消除掉,连CAS
操作都不用做了。偏向锁默认是开启的,也可以关闭。可以⽤过设置-XX:+UseBiasedLocking开启偏向锁。
偏向锁”偏”,就是”偏心”的”偏”,它的意思是这个锁会偏向于第一个获得它的程序,如果在接下来的执行过程中,该锁没有被其他的线程获取,则持有偏向锁的线程将永远不需要再进行同步。
获取锁的过程:
Mark Word
是否为可偏向锁的状态,即是否偏向锁即为1即表示支持可偏向锁,否则为0表示不支持可偏向锁。3
。Mark Word
的ID
不是本线程的ID
,则通过CAS
操作去修改线程ID
修改成本线程的ID
,如果修改成功则执行同步代码块,否则执行步骤4
。锁释放的过程:
Mark Word
的锁记录指针改成当前线程的锁记录,锁升级为轻量级锁状态(00)。锁主要存在4
种状态,级别从低到高依次是:无锁状态、偏向锁状态、轻量级锁状态和重量级锁状态,这几个状态会随着竞争的情况逐渐升级,这几个锁只有重量级锁是需要使用操作系统底层mutex
互斥原语来实现,其他的锁都是使用对象头来实现的。需要注意锁可以升级,但是不可以降级。
首先简单说下偏向锁、轻量级锁、重量级锁三者各自的应用场景:
锁膨胀过程:
上图跟下面这个解析基本相同:
偏向所锁,轻量级锁都是乐观锁,重量级锁是悲观锁。
一个对象刚开始实例化的时候,没有任何线程来访问它的时候。它是可偏向的,意味着,它现在认为只可能有一个线程来访问它,所以当第一个线程来访问它的时候,它会偏向这个线程,此时,对象持有偏向锁。偏向第一个线程,这个线程在修改对象头成为偏向锁的时候使用CAS操作,并将对象头中的ThreadID改成自己的ID,之后再次访问这个对象时,只需要对比ID,不需要再使用CAS在进行操作。
一旦有第二个线程访问这个对象,因为偏向锁不会主动释放,所以第二个线程可以看到对象时偏向状态,这时表明在这个对象上已经存在竞争了,检查原来持有该对象锁的线程是否依然存活,如果挂了,则可以将对象变为无锁状态,然后重新偏向新的线程,如果原来的线程依然存活,则马上执行那个线程的操作栈,检查该对象的使用情况,如果仍然需要持有偏向锁,则偏向锁升级为轻量级锁,( 偏向锁就是这个时候升级为轻量级锁的)。如果不存在使用了,则可以将对象回复成无锁状态,然后重新偏向。
轻量级锁认为竞争存在,但是竞争的程度很轻,一般两个线程对于同一个锁的操作都会错开,或者说稍微等待一下(自旋),另一个线程就会释放锁。 但是当自旋超过一定的次数,或者一个线程在持有锁,一个在自旋,又有第三个来访时,轻量级锁膨胀为重量级锁,重量级锁使除了拥有锁的线程以外的线程都阻塞,防止CPU空转。