参考链接:
LockSupport使用场景及原理详解
AQS的引入
LockSupport是一个工具类,提供了基本的线程阻塞和唤醒功能,它是创建锁和其他同步组件的基础工具,内部是使用sun.misc.Unsafe类实现的。LockSupport和使用它的线程都会关联一个许可,park方法表示消耗一个许可,调用park方法时,如果许可可用则park方法返回,如果没有许可则一直阻塞直到许可可用。unpark方法表示增加一个许可,多次调用并不会积累许可,因为许可数最大值为1。
其次,注意:某个线程可以先被unpark(这时,该线程就获得了一个许可),然后这个线程调用LockSupport.park()时,此时,发现有许可可用,则使用此许可而不会阻塞。
LockSupport会为每个线程设置一个permit值,也就是许可。1代表许可可用,0代表许可不可用。permit的最大值是1,最小值是0,当调用park()方法时,如果permit为1,则减为0,继续执行。如果permit已经为0,则阻塞。同理,unpark()方法会消耗一个许可,如果permit的值为0,则增加为1,代表发放许可,如果permit的值已经为1,则不在增加,也就是多次方法许可,并不会累加。当然这里所讲的permit在LockSupport的代码当中没有体现,需要到HotSpot的源码当中查看,以下为截图供查看:
1、/share/vm/runtime/park.hpp中许可的定义字段_counter

2、park()的实现(部分截图)

3、unpark()实现

package com.zzhua;import java.util.concurrent.locks.LockSupport;public class TestABC {private void printA(Thread thread) {System.out.println("A");LockSupport.unpark(thread);}private void printB(Thread thread) {LockSupport.park();System.out.println("B");LockSupport.unpark(thread);}private void printC() {LockSupport.park();System.out.println("C");}public static void main(String[] args) {/* 无论下面哪个线程先被执行,当B和C未获得它们的许可时,都会被阻塞掉,一直到获得许可。或者,它们在它们执行顺先前面的线程执行完后,先给了它们许可后,它们再在park时,再消费此许可这样就可以保证它们的打印顺序LockSupport的存在目的就是为了替换掉jdk自带的wait-notify等待唤醒机制(它只能结合synchronized使用,并且只能唤醒一个或全部唤醒,不够灵活) */TestABC testABC = new TestABC();Thread tC = new Thread(() -> {testABC.printC();});Thread tB = new Thread(() -> {testABC.printB(tC);});Thread tA = new Thread(() -> {testABC.printA(tB);});tC.start();tB.start();tA.start();}}
LockSupport.park()方法可以阻塞当前线程,阻塞的过程中,是可以正常响应中断的(如下面例子)。而jdk自带的synchornized当处于阻塞时,是不会响应中断的。
package com.zzhua;import java.util.concurrent.locks.LockSupport;public class TestPark {public static void main(String[] args) {Thread mainThread = Thread.currentThread();new Thread(() -> {try {Thread.sleep(3000L);mainThread.interrupt();} catch (InterruptedException e) {e.printStackTrace();}}).start();LockSupport.park();System.out.println("main....");// 3s后,正常输出main....// 说明park()方法可正常响应中断}}
jdk自带的synchronized在阻塞期间是不会响应中断的,以下示例,在10s后,正常输出main…
package com.zzhua;public class TestPark {public static void main(String[] args) throws InterruptedException {Thread mainThread = Thread.currentThread();new Thread(() -> {try {Thread.sleep(3000L);mainThread.interrupt();System.out.println("尝试中断main线程...(但是main线程没反应)");} catch (InterruptedException e) {e.printStackTrace();}}).start();new Thread(() -> {try {synchronized (TestPark.class) {Thread.sleep(10000L);}} catch (InterruptedException e) {e.printStackTrace();}}).start();Thread.sleep(50L);System.out.println("要进入synchronized了");synchronized (TestPark.class) {System.out.println("main....");}}}