写给小白看的LockSupport

前言

Java并发编程系列第三篇LockSupport,上一篇Synchronized文章中有提过,不推荐读者们使用Objectwait、notify、notifyAll等函数做多线程间的通信协同,使用LockSupport会是更好的选择,本篇就来谈谈LockSupport,也正好为下篇的A Q S(AbstractQueuedSynchronized)打基础。

内容大纲

LockSupport基本概念

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

示例-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的设计思路会为读者们解开疑惑,并更进一步明确是parkunpark的语义(从广义上来说parkunpark代表阻塞和唤醒)。

设计思路

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

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

  • LockSupport.unpark:指定线程关联的permit直接更新为1,如果更新前的permit<1,唤醒指定线程

  • LockSupport.park:当前线程关联的permit如果>0,直接把permit更新为0,否则阻塞当前线程

  • 线程A执行LockSupport.park,发现permit0,未持有许可证,阻塞线程A

  • 线程B执行LockSupport.unpark(入参线程A),为A线程设置许可证,permit更新为1,唤醒线程A

  • 线程B流程结束

  • 线程A被唤醒,发现permit1,消费许可证,permit更新为0

  • 线程A执行临界区

  • 线程A流程结束

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

  • permit默认是0,线程A执行LockSupport.unparkpermit更新为1,线程A持有许可证

  • 线程A执行LockSupport.park,此时permit1,消费许可证,permit更新为0

  • 执行临界区

  • 流程结束

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

优点

为什么推荐使用LockSupport来做线程的阻塞与唤醒(线程间协同工作),因为它具备如下优点

  • 以线程为操作对象更符合阻塞线程的直观语义

  • 操作更精准,可以准确地唤醒某一个线程(notify随机唤醒一个线程,notifyAll唤醒所有等待的线程)

  • 无需竞争锁对象(以线程作为操作对象),不会因竞争锁对象产生死锁问题

  • unparkpark没有严格的执行顺序,不会因执行顺序引起死锁问题,比如「Thread.suspendThread.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

 最后再留个题目给读者们思考,使用包含但不限于SynchronizedReentrantLock来完成这个功能

版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。

相关推荐


学习编程是顺着互联网的发展潮流,是一件好事。新手如何学习编程?其实不难,不过在学习编程之前你得先了解你的目的是什么?这个很重要,因为目的决定你的发展方向、决定你的发展速度。
IT行业是什么工作做什么?IT行业的工作有:产品策划类、页面设计类、前端与移动、开发与测试、营销推广类、数据运营类、运营维护类、游戏相关类等,根据不同的分类下面有细分了不同的岗位。
女生学Java好就业吗?女生适合学Java编程吗?目前有不少女生学习Java开发,但要结合自身的情况,先了解自己适不适合去学习Java,不要盲目的选择不适合自己的Java培训班进行学习。只要肯下功夫钻研,多看、多想、多练
Can’t connect to local MySQL server through socket \'/var/lib/mysql/mysql.sock问题 1.进入mysql路径
oracle基本命令 一、登录操作 1.管理员登录 # 管理员登录 sqlplus / as sysdba 2.普通用户登录
一、背景 因为项目中需要通北京网络,所以需要连vpn,但是服务器有时候会断掉,所以写个shell脚本每五分钟去判断是否连接,于是就有下面的shell脚本。
BETWEEN 操作符选取介于两个值之间的数据范围内的值。这些值可以是数值、文本或者日期。
假如你已经使用过苹果开发者中心上架app,你肯定知道在苹果开发者中心的web界面,无法直接提交ipa文件,而是需要使用第三方工具,将ipa文件上传到构建版本,开...
下面的 SQL 语句指定了两个别名,一个是 name 列的别名,一个是 country 列的别名。**提示:**如果列名称包含空格,要求使用双引号或方括号:
在使用H5混合开发的app打包后,需要将ipa文件上传到appstore进行发布,就需要去苹果开发者中心进行发布。​
+----+--------------+---------------------------+-------+---------+
数组的声明并不是声明一个个单独的变量,比如 number0、number1、...、number99,而是声明一个数组变量,比如 numbers,然后使用 nu...
第一步:到appuploader官网下载辅助工具和iCloud驱动,使用前面创建的AppID登录。
如需删除表中的列,请使用下面的语法(请注意,某些数据库系统不允许这种在数据库表中删除列的方式):
前不久在制作win11pe,制作了一版,1.26GB,太大了,不满意,想再裁剪下,发现这次dism mount正常,commit或discard巨慢,以前都很快...
赛门铁克各个版本概览:https://knowledge.broadcom.com/external/article?legacyId=tech163829
实测Python 3.6.6用pip 21.3.1,再高就报错了,Python 3.10.7用pip 22.3.1是可以的
Broadcom Corporation (博通公司,股票代号AVGO)是全球领先的有线和无线通信半导体公司。其产品实现向家庭、 办公室和移动环境以及在这些环境...
发现个问题,server2016上安装了c4d这些版本,低版本的正常显示窗格,但红色圈出的高版本c4d打开后不显示窗格,
TAT:https://cloud.tencent.com/document/product/1340