LockSupport 线程工具类有啥用？

客官°小女子只卖身不卖艺 2022-10-07 15:51 51阅读 0赞

**点击关注公众号，Java干货****及时送达**![e9b4bfe1fb93a69ec7676aa804af4c6f.png][]

*本文转自公众号：程序猿阿星*

# 内容大纲 #

![3df57d588c3bbeef27da786991c4af07.png][]

# LockSupport基本概念 #

`LockSupport`是线程工具类，主要作用是阻塞和唤醒线程，底层实现依赖`Unsafe`，同时它还是锁和其他同步类实现的基础，`LockSupport`提供两类静态函数分别是`park`和`unpark`，即阻塞与唤醒线程，下面是两段代码示例

**示例-1**

public static void main(String[] agrs) throws InterruptedException {
            Thread th = new Thread(() -> {
                //阻塞当前线程
                LockSupport.park();
                System.out.println("子线程执行---------");
            });
            th.start();
            //睡眠2秒
            Thread.sleep(2000);
            System.out.println("主线程执行---------");
            //唤醒线程
            LockSupport.unpark(th);
        }
    }
    
    
    输出结果：
    主线程执行---------
    子线程执行---------

上述示例中，子线程`th`调用`LockSupport.park()`阻塞，主线程睡眠`2`秒后，执行`LockSupport.unpark(th)`唤醒`th`线程，先阻塞后唤醒非常好理解，接下来读者们再看下面的示例

**示例-2**

public static void main(String[] agrs) throws InterruptedException {
            Thread th = new Thread(() -> {
                //唤醒当前线程
                LockSupport.unpark(Thread.currentThread());
                //阻塞当前线程
                LockSupport.park();
                System.out.println("子线程执行---------");
            });
            th.start();
            //睡眠2秒
            Thread.sleep(2000);
            System.out.println("主线程执行---------");
    }
    
    
    
    输出结果：
    子线程执行---------
    主线程执行---------

嗯？先唤醒`th`线程，再阻塞`th`线程，最终`th`线程没有被阻塞，这是为什么？下面`LockSupport`的设计思路会为读者们解开疑惑，并更进一步明确是`park`和`unpark`的语义（**从广义上来说`park`和`unpark`代表阻塞和唤醒**）。

# 设计思路 #

`LockSupport`的设计思路是通过许可证来实现的，就像汽车上高速公路，入口处要获取通行卡，出口处要交出通行卡，如果没有通行卡你就无法出站，当然你可以选择补一张通行卡。

`LockSupport`会为使用它的线程关联一个许可证（`permit`）状态，`permit`的语义「是否拥有许可」，`0`代表否，`1`代表是，默认是`0`。

*  `LockSupport.unpark`：指定线程关联的`permit`直接更新为`1`，如果更新前的`permit<1`，唤醒指定线程
 *  `LockSupport.park`：当前线程关联的`permit`如果`>0`，直接把`permit`更新为`0`，否则阻塞当前线程

![0cef74c1d65adcae0680a4beedb80f9b.png][]

*  线程`A`执行`LockSupport.park`，发现`permit`为`0`，未持有许可证，阻塞线程`A`
 *  线程`B`执行`LockSupport.unpark`（入参线程`A`），为`A`线程设置许可证，`permit`更新为`1`，唤醒线程`A`
 *  线程`B`流程结束
 *  线程`A`被唤醒，发现`permit`为`1`，消费许可证，`permit`更新为`0`
 *  线程`A`执行临界区
 *  线程`A`流程结束

经过上面的分析得出结论`unpark`的语义明确为「**使线程持有许可证**」，`park`的语义明确为「**消费线程持有的许可**」，所以`unpark`与`park`的执行顺序没有强制要求，只要控制好使用的线程即可，`unpark=>park`执行流程如下

![97c29b08fab2bd210f08a83d4ad98906.png][]

*  `permit`默认是`0`，线程`A`执行`LockSupport.unpark`，`permit`更新为`1`，线程`A`持有许可证
 *  线程`A`执行`LockSupport.park`，此时`permit`是`1`，消费许可证，`permit`更新为`0`
 *  执行临界区
 *  流程结束

最后再补充下`park`注意点，因`park`阻塞的线程不仅仅会被`unpark`唤醒，还可能会被线程中断（`Thread.interrupt`）唤醒，而且不会抛出`InterruptedException`异常，所以建议在`park`后自行判断**线程中断状态**，来做对应的业务处理。

# 优点 #

为什么推荐使用`LockSupport`来做线程的阻塞与唤醒（**线程间协同工作**），因为它具备如下优点

*  以线程为操作对象更符合阻塞线程的直观语义
 *  操作更精准，可以准确地唤醒某一个线程（`notify`随机唤醒一个线程，`notifyAll`唤醒所有等待的线程）
 *  无需竞争锁对象（以线程作为操作对象），不会因竞争锁对象产生死锁问题
 *  `unpark`与`park`没有严格的执行顺序，不会因执行顺序引起死锁问题，比如「`Thread.suspend`和`Thread.resume`」没按照严格顺序执行，就会产生死锁

另外`LockSupport`还提供了`park`的重载函数，提升灵活性

*  `void parkNanos(long nanos)`：增加了超时机制
 *  `void parkUntil(long deadline)`：加入超时机制（指定到某个时间点，`1970`年到指定时间点的毫秒数）
 *  `void park(Object blocker)`：设置`blocker`对象，当线程没有许可证被阻塞时，该对象会被记录到该线程的内部，方便后续使用诊断工具进行问题排查
 *  `void parkNanos(Object blocker, long nanos)`：设置`blocker`对象，加入超时机制
 *  `void parkUntil(Object blocker, long deadline)`：设置`blocker`对象，加入超时机制（指定到某个时间点，`1970`年到指定时间点的毫秒数）

建议使用时，传入`blocker`对象，至于超时根据业务场景选择

# 实践 #

使用`LockSupport`来完成一道阿里经典的多线程协同工作面试题。

有`3`个独立的线程，一个只会输出`A`，一个只会输出`B`，一个只会输出`C`，在三个线程启动的情况下，请用合理的方式让他们按顺序打印`ABCABC`。

思路如下

*  准备`3`个线程，分别固定打印`A、B、C`
 *  线程输出完`A、B、C`后需要阻塞等待唤醒
 *  额外准备第`4`个线程，作为另外`3`个线程的调度器，有序的控制`3`个线程执行

是不是很简单，下面通过代码来实践

public static void main(String[] agrs) throws InterruptedException {
    
            LockSupportMain lockSupportMain = new LockSupportMain();
            
            //定义线程t1、t2、t3执行的函数方法
            Consumer<String> consumer = str -> {
                while (true) {
                    //线程消费许可证，并传入blocker，方便后续排查问题
                    LockSupport.park(lockSupportMain);
                    //防止线程是因中断操作唤醒
                    if (Thread.currentThread().isInterrupted()){
                        throw new RuntimeException("线程被中断，异常结束");
                    }
                    System.out.println(Thread.currentThread().getName() + ":" + str);
                }
            };
            
            /**
             * 定义分别输出A、B、C的线程
             */
            Thread t1 = new Thread(() -> {
                consumer.accept("A");
            },"T1");
            Thread t2 = new Thread(() -> {
                consumer.accept("B");
            },"T2");
            Thread t3 = new Thread(() -> {
                consumer.accept("C");
            },"T3");
    
            
            /**
             * 定义调度线程
             */
            Thread dispatch = new Thread(() -> {
                int i=0;
                try {
                    while (true) {
                        if((i%3)==0) {
                            //线程t1设置许可证，并唤醒线程t1
                            LockSupport.unpark(t1);
                        }else if((i%3)==1) {
                            //线程t2设置许可证，并唤醒线程t2
                            LockSupport.unpark(t2);
                        }else {
                            //线程t3设置许可证，并唤醒线程t3
                            LockSupport.unpark(t3);
                        }
                        i++;
                        TimeUnit.MILLISECONDS.sleep(500);
                    }
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            });
    
            //启动相关线程
            t1.start();
            t2.start();
            t3.start();
            dispatch.start();
            
    }
    
    
    输出内容：
    T1:A
    T2:B
    T3:C
    T1:A
    T2:B
    T3:C
    T1:A
    T2:B
    T3:C

最后再留个题目给读者们思考，使用包含但不限于`Synchronized`、`ReentrantLock`来完成这个功能。另外，关注公众号Java技术栈，在后台回复：面试，可以获取我整理的 Java 多线程系列面试题和答案，非常齐全。

![a1524637f74e32c52cf7ee2d536dec62.gif][]

![985cb7b87d5e4567c170b20d89bea00c.png][]

[![ad5a08ad28c95866aad5c991c82de69b.png][]][ad5a08ad28c95866aad5c991c82de69b.png 1]

[![8f11ee095f0ec68ef2689bf7d654f3ac.png][]][8f11ee095f0ec68ef2689bf7d654f3ac.png 1]

[![c790e48d1371c2bc0e3023096b7b39b3.png][]][c790e48d1371c2bc0e3023096b7b39b3.png 1]

[![4ea1cf8becf7bc4706d11773b3fd6cbd.png][]][4ea1cf8becf7bc4706d11773b3fd6cbd.png 1]

[![a148ec8af5d40589e14f4bd78c263e26.png][]][a148ec8af5d40589e14f4bd78c263e26.png 1]

**关注Java技术栈看更多干货**

![21fbe11bcff1394f76706214abb035f2.png][]

![2aaa3c5e5d40af672f8fc5d77971ebff.gif][]

获取 Spring Boot 实战笔记！

[e9b4bfe1fb93a69ec7676aa804af4c6f.png]: /images/20221005/6ca89e512ec844bc87e1727b9a0892ae.png
[3df57d588c3bbeef27da786991c4af07.png]: /images/20221005/4b83f64119594928b0f611e97b76f25b.png
[0cef74c1d65adcae0680a4beedb80f9b.png]: /images/20221005/589a9c4c7f144803a464775623f372b0.png
[97c29b08fab2bd210f08a83d4ad98906.png]: /images/20221005/9e7b1f8160254f6fa912d19d1a5a5215.png
[a1524637f74e32c52cf7ee2d536dec62.gif]: /images/20221005/4cec2694621e4b86973fd1c9633ad81d.png
[985cb7b87d5e4567c170b20d89bea00c.png]: /images/20221005/10eacd64b2354a8593af75fa8a66b555.png
[ad5a08ad28c95866aad5c991c82de69b.png]: /images/20221005/f1db6b4bcd254edc99a9ee9b019ca4ed.png
[ad5a08ad28c95866aad5c991c82de69b.png 1]: https://mp.weixin.qq.com/s?__biz=MzI3ODcxMzQzMw%3D%3D&idx=1&mid=2247531800&scene=21&sn=b47b1b1b2b6fab46f3e98d971c39be0c#wechat_redirect
[8f11ee095f0ec68ef2689bf7d654f3ac.png]: /images/20221005/630cb8f3aaab4297b30a7ec2e337799e.png
[8f11ee095f0ec68ef2689bf7d654f3ac.png 1]: https://mp.weixin.qq.com/s?__biz=MzI3ODcxMzQzMw%3D%3D&idx=1&mid=2247533498&scene=21&sn=acb5be75763dd7c53a11111d9ee9925b#wechat_redirect
[c790e48d1371c2bc0e3023096b7b39b3.png]: /images/20221005/e9550ff912574a99bbf5cade09206e02.png
[c790e48d1371c2bc0e3023096b7b39b3.png 1]: https://mp.weixin.qq.com/s?__biz=MzI3ODcxMzQzMw%3D%3D&idx=1&mid=2247530418&scene=21&sn=e6a0138c7c2f9a9ff6a8b4c878386211#wechat_redirect
[4ea1cf8becf7bc4706d11773b3fd6cbd.png]: /images/20221005/09d2817acbec48a7887b4ea3860d987a.png
[4ea1cf8becf7bc4706d11773b3fd6cbd.png 1]: https://mp.weixin.qq.com/s?__biz=MzI3ODcxMzQzMw%3D%3D&idx=1&mid=2247524153&scene=21&sn=6c53d1287b640350cf7eeea7f04773c1#wechat_redirect
[a148ec8af5d40589e14f4bd78c263e26.png]: /images/20221005/f625958ddc1445988b03d7dd21d57e2a.png
[a148ec8af5d40589e14f4bd78c263e26.png 1]: https://mp.weixin.qq.com/s?__biz=MzI3ODcxMzQzMw%3D%3D&idx=1&mid=2247530007&scene=21&sn=39f404a41d5f7f814cbd796b84de17d1#wechat_redirect
[21fbe11bcff1394f76706214abb035f2.png]: /images/20221005/bf3f9710837147e3a207b396f8bedf47.png
[2aaa3c5e5d40af672f8fc5d77971ebff.gif]: /images/20221005/c184b6654be048d5a2685070bfea5350.png