【JUC】十六、LockSupport类实现线程等待与唤醒

2023-11-30 06:36

本文主要是介绍【JUC】十六、LockSupport类实现线程等待与唤醒,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

文章目录

  • 1、LockSupport
  • 2、wait和notify存在的问题
  • 3、await和signal存在的问题
  • 4、park和unpark方法
  • 5、LockSupport用法示例
  • 6、Permit不会累积
  • 7、面试

在这里插入图片描述

1、LockSupport

线程等待和唤醒的方式有:

  • 使用Object的wait方法让对象上活动的线程等待,使用notify方法来唤醒线程
  • 使用JUC报中Condition的await方法让线程等待,使用signal方法来唤醒线程
  • LockSupport类来阻塞当前线程以及唤醒指定被阻塞的线程

在这里插入图片描述

LockSupport是一个线程阻塞工具类,所有方法都是静态的。可以让线程在任意位置阻塞,阻塞之后也有对应的唤醒方法,归根结底,LockSupport调用的Unsafe中的native代码。

  • LockSupport提供park和unpark方法实现阻塞线程和解除阻塞
  • LockSupport和每个使用它的线程都有一个许可permit关联
  • 每个线程都有一个相关的permit,permit最多只有一个,重复调用unpark也不会积累凭证
  • LockSupport就是通过Permit (许可)的概念来做到阻塞和唤阻线程的功能

2、wait和notify存在的问题

正常使用wait和notify如下:

public class LockSupport1 {public static void main(String[] args) {Object o = new Object();new Thread(() -> {synchronized (o){System.out.println(Thread.currentThread().getName() + "\t come in...");try {o.wait();} catch (InterruptedException e) {e.printStackTrace();}System.out.println(Thread.currentThread().getName() + "\t 被唤醒");}},"t1").start();//歇200mstry { TimeUnit.MILLISECONDS.sleep(200); } catch (InterruptedException e) { e.printStackTrace(); }new Thread(() -> {synchronized (o){System.out.println(Thread.currentThread().getName() + "\t come in ...");o.notify();System.out.println(Thread.currentThread().getName() + "\t 发出唤醒通知");}},"t2").start();}
}

此时一切正常:

在这里插入图片描述

问题1:去掉syncyronized

在这里插入图片描述

问题2:先唤醒再等待

在这里插入图片描述

可以发现,将notify先于wait执行,等待被唤醒的线程会陷入无限等待中,就像叫你起床的人,先走了,你睡着以后没人再叫你了。

问题点总结:

  • wait和notify方法必须要在同步块或者同步方法里面,且成对出现和使用
  • 必须先wait再notify,反之唤醒失败

3、await和signal存在的问题

常规用法:

public class LockSupport1 {public static void main(String[] args) {Lock lock = new ReentrantLock();Condition condition = lock.newCondition();new Thread(() -> {lock.lock();System.out.println(Thread.currentThread().getName() + "\t come in...");try {condition.await();} catch (InterruptedException e) {e.printStackTrace();} finally {lock.unlock();}System.out.println(Thread.currentThread().getName() + "\t 被唤醒");},"t1").start();//歇200mstry { TimeUnit.MILLISECONDS.sleep(200); } catch (InterruptedException e) { e.printStackTrace(); }new Thread(() -> {lock.lock();try {System.out.println(Thread.currentThread().getName() + "\t come in...");condition.signal();System.out.println(Thread.currentThread().getName() + "\t 发出唤醒通知");} finally {lock.unlock();}},"t2").start();}}

在这里插入图片描述

问题1:去掉锁

在这里插入图片描述

可以看到去掉lock和unlock加解锁,await和signal都触发了IllegalMonitorStateException异常。

异常2:先唤醒再等待

在这里插入图片描述

可以看到,前两种线程等待和唤醒的方式,都有使用限制:

  • 线程必须先持有锁(synchronized或者lock)
  • 必须先等待后唤醒,才能唤醒成功

4、park和unpark方法

基于前面两种方式的缺陷,LockSupport提供了新的实现思路来解决 ⇒凭证 。通过park()和unpark(thread)来实现阻塞和唤醒线程。

//阻塞当前线程
park()
//阻塞传入的具体线程
park(Thread thread)

当调用park方法时:

  • 如果线程有凭证,则直接消耗掉这个凭证然后正常往下执行
  • 如果线程没有凭证,就必须阻塞等待到凭证可用

看下源码,第二个参数就是用来指定多久放行的,默认0,即没许可证不放行,直到别的线程给当前线程发放permit:

在这里插入图片描述

unpark(Thread thread)

当调用unpark方法时:

  • 给传入的线程发一个凭证
  • 自动唤醒之前阻塞的LockSupport.park()
  • 但凭证最多只有一个,多次调用不会累加

5、LockSupport用法示例

开两个线程t2给t1发通行证:

public class LockSupport2 {public static void main(String[] args) {Thread t1 = new Thread(() -> {System.out.println(Thread.currentThread().getName() + "\t ---com in: " + System.currentTimeMillis());LockSupport.park();System.out.println(Thread.currentThread().getName() + "\t ---被唤醒: " + System.currentTimeMillis());}, "t1");t1.start();try { TimeUnit.MILLISECONDS.sleep(200); } catch (InterruptedException e) { e.printStackTrace(); }new Thread(() -> {System.out.println(Thread.currentThread().getName() + "\t ---com in");System.out.println(Thread.currentThread().getName() + "给t1线程发了permit");LockSupport.unpark(t1);},"t2").start();}
}

等待唤醒成功,可以发现不用锁块了,也没有synchronized或者lock了。

在这里插入图片描述

再看先发许可证会不会被成功唤醒:

public class LockSupport2 {public static void main(String[] args) {Thread t1 = new Thread(() -> {//休息两秒,让t2先执行try { TimeUnit.MILLISECONDS.sleep(2000); } catch (InterruptedException e) { e.printStackTrace(); }System.out.println(Thread.currentThread().getName() + "\t ---com in: " + System.currentTimeMillis());LockSupport.park();System.out.println(Thread.currentThread().getName() + "\t ---被唤醒: " + System.currentTimeMillis());}, "t1");t1.start();//try { TimeUnit.MILLISECONDS.sleep(200); } catch (InterruptedException e) { e.printStackTrace(); }new Thread(() -> {System.out.println(Thread.currentThread().getName() + "\t ---com in");System.out.println(Thread.currentThread().getName() + "给t1线程发了permit");LockSupport.unpark(t1);},"t2").start();}
}

在这里插入图片描述

先发permit,再LockSupport.park(),就像持证上岗,或者高速公路的ETC,提前缴费买了通行证后走高速,遇到关卡一路通畅,此时park形同虚设

6、Permit不会累积

验证一个线程醉倒一个Permit,许可证不会累积:

public class LockSupport3 {public static void main(String[] args) {Thread t1 = new Thread(() -> {//先让发许可证的线程执行try { TimeUnit.MILLISECONDS.sleep(2000); } catch (InterruptedException e) { e.printStackTrace(); }System.out.println(Thread.currentThread().getName() + "\t ---come in");LockSupport.park();LockSupport.park();System.out.println(Thread.currentThread().getName() + "\t ---被唤醒");}, "t1");t1.start();new Thread(() -> {LockSupport.unpark(t1);LockSupport.unpark(t1);LockSupport.unpark(t1);LockSupport.unpark(t1);}).start();}
}

可以看到多次unpark也不能过两个park:

在这里插入图片描述

稍微再改一下,一个凭证用完后,自己再给自己发一个,就可以通过了。

在这里插入图片描述

7、面试

Q1:为什么LockSupport可以突破wait/notify原有的调用顺序限制?

A1:因为unpark后线程t获得了一个凭证,之后线程t再调用park,就凭证消费,畅通无阻

Q2:为什么唤醒两次后再阻塞两次,最终结果还是阻塞?

A2:因为凭证的数量最多为1,连续调用两次unpark并不会有两个凭证,而调用两次park却要消耗两个凭证,凭证不够,不能放行。

这篇关于【JUC】十六、LockSupport类实现线程等待与唤醒的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/435979

相关文章

使用zip4j实现Java中的ZIP文件加密压缩的操作方法

《使用zip4j实现Java中的ZIP文件加密压缩的操作方法》本文介绍如何通过Maven集成zip4j1.3.2库创建带密码保护的ZIP文件,涵盖依赖配置、代码示例及加密原理,确保数据安全性,感兴趣的... 目录1. zip4j库介绍和版本1.1 zip4j库概述1.2 zip4j的版本演变1.3 zip4

python生成随机唯一id的几种实现方法

《python生成随机唯一id的几种实现方法》在Python中生成随机唯一ID有多种方法,根据不同的需求场景可以选择最适合的方案,文中通过示例代码介绍的非常详细,需要的朋友们下面随着小编来一起学习学习... 目录方法 1:使用 UUID 模块(推荐)方法 2:使用 Secrets 模块(安全敏感场景)方法

Spring StateMachine实现状态机使用示例详解

《SpringStateMachine实现状态机使用示例详解》本文介绍SpringStateMachine实现状态机的步骤,包括依赖导入、枚举定义、状态转移规则配置、上下文管理及服务调用示例,重点解... 目录什么是状态机使用示例什么是状态机状态机是计算机科学中的​​核心建模工具​​,用于描述对象在其生命

Spring Boot 结合 WxJava 实现文章上传微信公众号草稿箱与群发

《SpringBoot结合WxJava实现文章上传微信公众号草稿箱与群发》本文将详细介绍如何使用SpringBoot框架结合WxJava开发工具包,实现文章上传到微信公众号草稿箱以及群发功能,... 目录一、项目环境准备1.1 开发环境1.2 微信公众号准备二、Spring Boot 项目搭建2.1 创建

IntelliJ IDEA2025创建SpringBoot项目的实现步骤

《IntelliJIDEA2025创建SpringBoot项目的实现步骤》本文主要介绍了IntelliJIDEA2025创建SpringBoot项目的实现步骤,文中通过示例代码介绍的非常详细,对大家... 目录一、创建 Spring Boot 项目1. 新建项目2. 基础配置3. 选择依赖4. 生成项目5.

Linux线程之线程的创建、属性、回收、退出、取消方式

《Linux线程之线程的创建、属性、回收、退出、取消方式》文章总结了线程管理核心知识:线程号唯一、创建方式、属性设置(如分离状态与栈大小)、回收机制(join/detach)、退出方法(返回/pthr... 目录1. 线程号2. 线程的创建3. 线程属性4. 线程的回收5. 线程的退出6. 线程的取消7.

Linux下进程的CPU配置与线程绑定过程

《Linux下进程的CPU配置与线程绑定过程》本文介绍Linux系统中基于进程和线程的CPU配置方法,通过taskset命令和pthread库调整亲和力,将进程/线程绑定到特定CPU核心以优化资源分配... 目录1 基于进程的CPU配置1.1 对CPU亲和力的配置1.2 绑定进程到指定CPU核上运行2 基于

Linux下删除乱码文件和目录的实现方式

《Linux下删除乱码文件和目录的实现方式》:本文主要介绍Linux下删除乱码文件和目录的实现方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录linux下删除乱码文件和目录方法1方法2总结Linux下删除乱码文件和目录方法1使用ls -i命令找到文件或目录

SpringBoot+EasyExcel实现自定义复杂样式导入导出

《SpringBoot+EasyExcel实现自定义复杂样式导入导出》这篇文章主要为大家详细介绍了SpringBoot如何结果EasyExcel实现自定义复杂样式导入导出功能,文中的示例代码讲解详细,... 目录安装处理自定义导出复杂场景1、列不固定,动态列2、动态下拉3、自定义锁定行/列,添加密码4、合并

mybatis执行insert返回id实现详解

《mybatis执行insert返回id实现详解》MyBatis插入操作默认返回受影响行数,需通过useGeneratedKeys+keyProperty或selectKey获取主键ID,确保主键为自... 目录 两种方式获取自增 ID:1. ​​useGeneratedKeys+keyProperty(推