LockSupport 介绍

LockSupport 的功能

LockSupport 是JDK 中提供的一个工具类,用来挂起和唤醒线程,这个类是 JDK 中所有同步类的基础,JDK 中 AQS 的实现也是基于此;
LockSupport 类是通过操作 Unsafe 类来实现的,而线程在使用时,被挂起和唤醒都是因为这个类的两个方法,即 park 方法和 unpark 方法,他们通过让线程是否关联一个许可证来实现的;
也就是说如果线程通过 LockSupport 类的方法调用,被关联了一个许可证那么线程会被唤醒,如果没有关联则会挂起等待;

方法功能介绍

park()

首先直接给出源码:

public static void park() {
        UNSAFE.park(false, 0L);
    }

park 方法是一个 static 方法,并且没有入参也没有返回值,它调用了 Unsafe 的方法,这个是一个 native 方法,并且当前线程与 LockSupport 类不会关联一个许可证;
当调用 park 方法后,由于默认是没有持有许可证,因此当前线程会被挂起阻塞;

unpark(Thread thread)

首先直接给出源码:

public static void unpark(Thread thread) {
        if (thread != null)
            UNSAFE.unpark(thread);
    }

unpark 方法也是一个 static 方法,它的入参是一个 Thread 对象返回值也为空,同样的也是调用了 Unsafe 类的方法,它会为入参线程和 LockSupport 类关联一个许可证;
当 unpark 方法被调用后,如果入参的 thread 线程没有和 LockSupport 类关联许可证,那么调用后就会被关联一个许可证,因此入参的 thread 线程会被唤醒;

测试 demo
public static void main(String[] args) {
        System.out.println("main start");
        Thread thread = new Thread(() -> {
            System.out.println("thread start");
            LockSupport.park();
            System.out.println("thread end");
        });
        thread.start();
        try {
            System.out.println("main sleep start test park");
            Thread.sleep(100);
            System.out.println("main sleep end test park");
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        LockSupport.unpark(thread);
        try {
            System.out.println("main sleep start test unpark");
            Thread.sleep(100);
            System.out.println("main sleep end test unpark");
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println("main end");
    }

结果

main start
main sleep start test park
thread start
main sleep end test park
main sleep start test unpark
thread end
main sleep end test unpark
main end

上面的代码,创建了一个线程 thread 在线程中调用了 park 方法,因此 thread 线程会被挂起,当在 main 线程中,调用了 unpark 后,thread 线程会被唤醒;

parkNanos(long nanos)

public static void parkNanos(long nanos) {
        if (nanos > 0)
            UNSAFE.park(false, nanos);
    }

和 park 方法功能一样,只是这个是带有时间,park 方法的时间传的 0,当线程没有和 LockSupport 关联许可证,一样会被挂起,不同的是它在被挂起 nanos 时间胡会返回,就是有一个超时时间,在达到时间后即使没有获得和 LockSupport 关联的许可证也会返回;

测试demo
 public static void main(String[] args) {
        System.out.println("start");
        LockSupport.parkNanos(10000000000L);
//        LockSupport.park();
        System.out.println("end");
    }

上面的代码分别测试了 parkNanos 和 park 方法,park 会一会阻塞,而 parkNanos 阻塞一定时间后就返回;

park(Object blocker) & getBlocker(Thread t)

public static void park(Object blocker) {
        Thread t = Thread.currentThread();
        //阻塞前设置blocker
        setBlocker(t, blocker);
        UNSAFE.park(false, 0L);
        //结束阻塞后把设置的blocker 设置为空
        setBlocker(t, null);
    }
//获取 Thread  类中变量 parkBlocker 的偏移量
Class<?> tk = Thread.class;
parkBlockerOffset = UNSAFE.objectFieldOffset(tk.getDeclaredField("parkBlocker"));
//通过Unsafe 类把 Thread 对象中偏移量为 parkBlockerOffset 的属性设置为 blocker
private static void setBlocker(Thread t, Object arg) {
        // Even though volatile, hotspot doesn't need a write barrier here.
        UNSAFE.putObject(t, parkBlockerOffset, arg);
    }

public static Object getBlocker(Thread t) {
        if (t == null)
            throw new NullPointerException();
        return UNSAFE.getObjectVolatile(t, parkBlockerOffset);
    }

首先来看 park(Object blocker) 方法,这个方法其实和 park 方法一样,都是调用了 Unsafe 类的 park 方法;
只是在调用前将入参的 blocker 对象设置到了当前线程的 parkBlocker 变量中(在线程的 Thread 类中有一个 volatile 的 变量 parkBlocker);
因此 park(Object blocker) 方法相对于 park() 方法的优势在于,它在当前线程中记录了 blocker 对象,而通常我们的 blocker 对象就是当前对象也就是 this;而这种方式也正是 JDK 推荐的方式;
通过 getBlocker(Thread t) 可以获取 线程 t 中属性 parkBlocker 的值;

测试demo
public static void main(String[] args) { 
        ThreadTest t = new ThreadTest();
        t.testBlocker();
    }
//直接将this传入即可
    public void testBlocker (){
        LockSupport.park(this);
    }

使用这种方式还有一个好处,就是当线程被阻塞后,通过 jstack 打印堆栈信息时,可以看到我们设置的 this 对象,也就能看到阻塞的对象,这样能在堆栈中查到更多信息,方便问题的定位及解决;

parkNanos(Object blocker, long nanos)

public static void parkNanos(Object blocker, long nanos) {
        if (nanos > 0) {
            Thread t = Thread.currentThread();
            setBlocker(t, blocker);
            UNSAFE.park(false, nanos);
            setBlocker(t, null);
        }
    }

这个方法和 park(Object blocker) 类似只是多了一个超时时间,但是如果时间小于等于0 将没有任何作用,因此使用时需要注意一些;

©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 220,458评论 6 513
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 94,030评论 3 396
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 166,879评论 0 358
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 59,278评论 1 295
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 68,296评论 6 397
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 52,019评论 1 308
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 40,633评论 3 420
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 39,541评论 0 276
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 46,068评论 1 319
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 38,181评论 3 340
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 40,318评论 1 352
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 35,991评论 5 347
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 41,670评论 3 331
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 32,183评论 0 23
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 33,302评论 1 272
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 48,655评论 3 375
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 45,327评论 2 358