Java并发 - LockSupport详解

2024-01-13 12:20
文章标签 java 详解 并发 locksupport

本文主要是介绍Java并发 - LockSupport详解，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

LockSupport是Java中用于实现线程阻塞和唤醒的工具类。它提供了一种基于线程的阻塞原语，能够在不需要持有锁的情况下实现线程的挂起和唤醒操作。

1. LockSupport是什么？

LockSupport是Java并发包（java.util.concurrent）中的一个工具类，用于实现线程的阻塞和唤醒操作。与传统的使用synchronized关键字或Object类的wait()和notify()方法不同，LockSupport使用更加灵活的方式来管理线程的阻塞状态。

2. LockSupport的主要作用？

LockSupport的主要作用是允许线程进行阻塞和唤醒，而且可以在任意位置对线程进行操作，而无需持有特定的锁。它提供了park()和unpark()两个静态方法，可以分别用于阻塞线程和唤醒线程。

  • park(): 阻塞当前线程。
  • unpark(Thread thread): 唤醒指定线程。

LockSupport不需要获取某个对象的锁来进行阻塞或唤醒，而是通过给线程分配一个许可证（permit）的方式来实现。

3. LockSupport核心函数

  • **park()：**使得当前线程进入阻塞状态，一直阻塞直到调用unpark(Thread thread)方法或被中断。
  • **unpark(Thread thread)：**用于唤醒通过park()方法被阻塞的线程。
  • **parkNanos(Object blocker, long nanos)：**阻塞当前线程，最多阻塞nanos纳秒，或直到被中断。
  • **parkUntil(Object blocker, long deadline)：**阻塞当前线程，直到deadline时间点或被中断。

4. LockSupport源码分析

LockSupport的核心方法是park()和unpark(Thread thread)，它们的实现比较简单。以下是简化的LockSupport源码：

public class LockSupport {public static void park(Object blocker) {// 获取当前线程Thread t = Thread.currentThread();// 设置BlockersetBlocker(t, blocker);// 获取许可UNSAFE.park(false, 0L);// 重新可运行后再此设置BlockersetBlocker(t, null);}public static void unpark(Thread thread) {if (thread != null)UNSAFE.unpark(thread);}public static void parkNanos(Object blocker, long nanos) {if (nanos > 0) { // 时间大于0// 获取当前线程Thread t = Thread.currentThread();// 设置BlockersetBlocker(t, blocker);// 获取许可，并设置了时间UNSAFE.park(false, nanos);// 设置许可setBlocker(t, null);}}public static void parkUntil(Object blocker, long deadline) {// 获取当前线程Thread t = Thread.currentThread();// 设置BlockersetBlocker(t, blocker);UNSAFE.park(true, deadline);// 设置Blocker为nullsetBlocker(t, null);}// ... 其他代码 ...// Unsafe实例private static final sun.misc.Unsafe UNSAFE;// 以下字段记录的是内存偏移地址private static final long parkBlockerOffset;private static final long SEED;private static final long PROBE;private static final long SECONDARY;static {try {// 获取UnSafe对象实例UNSAFE = sun.misc.Unsafe.getUnsafe();// 获取线程对象Class<?> tk = Thread.class;// 获取Thread类中的字段parkBlocker、threadLocalRandomSeed、threadLocalRandomProbe、threadLocalRandomSecondarySeed的内存偏移量。parkBlockerOffset = UNSAFE.objectFieldOffset(tk.getDeclaredField("parkBlocker"));SEED = UNSAFE.objectFieldOffset(tk.getDeclaredField("threadLocalRandomSeed"));PROBE = UNSAFE.objectFieldOffset(tk.getDeclaredField("threadLocalRandomProbe"));SECONDARY = UNSAFE.objectFieldOffset(tk.getDeclaredField("threadLocalRandomSecondarySeed"));} catch (Exception ex) {throw new Error(ex);}}// ... 其他代码 ...
}

5. LockSupport的应用场景

LockSupport的灵活性使得它在一些特定的场景中非常有用，如：

  1. 替代传统的wait()和notify()：LockSupport可以在任意位置进行线程的阻塞和唤醒，而不需要在特定的同步块内调用。
  2. 实现自定义的线程同步机制：LockSupport可以作为构建自定义锁或同步工具的基础组件，提供更灵活的线程控制。
  3. 线程的挂起和唤醒：LockSupport可以用于实现一些需要线程挂起和唤醒的场景，例如线程池中的工作者线程。

6. LockSupport示例

public class LockSupportExample {public static void main(String[] args) {Thread thread = new Thread(() -> {System.out.println("Thread is going to be parked");LockSupport.park(); // 阻塞当前线程System.out.println("Thread is unparked");});thread.start();try {Thread.sleep(2000); // 等待2秒} catch (InterruptedException e) {e.printStackTrace();}LockSupport.unpark(thread); // 唤醒线程}
}

Thread is going to be parked
Thread is unparked

在这个例子中，线程启动后会被阻塞，然后主线程等待2秒后调用LockSupport.unpark()方法唤醒被阻塞的线程。

问：先调用park再调用unpark 跟 先调用unpark再调用park有什么区别

在调用unpark之后，线程调用LockSupport.park()，由于之前已经被唤醒，所以它不会被阻塞，可以继续执行之后的代码。

7. LockSupport的深入理解

LockSupport中的park和unpark方法与wait和notify方法都用于线程之间的协作，但有一些重要的区别。

7.1 粒度和使用方式

  • park和unpark：
    • park和unpark是用于线程级别的协作，不需要在特定的同步块内调用。
    • 可以在任意地方调用park和unpark，并且不需要持有某个对象的锁。
  • wait和notify：
    • wait和notify是基于对象级别的协作，必须在同步块内使用，通常使用synchronized关键字。
    • 调用wait和notify之前需要获取对象的锁。

7.2 唤醒方式：

  • park和unpark：
    • unpark可以在park之前调用，也可以在park之后调用。多次调用unpark不会积累许可，每个线程最多有一个许可。
    • unpark可以指定唤醒特定线程。
  • wait和notify：
    • notify必须在wait之后调用，且只能唤醒等待同一对象锁的某一个线程。
    • notifyAll唤醒等待同一对象锁的所有线程。

7.3 中断响应：

  • park和unpark：
    • park可以响应中断，线程在被中断时会立即返回。
    • unpark不会受到中断的影响。
  • wait和notify：
    • wait在等待期间被中断会抛出InterruptedException。
    • notify不受中断的影响。

7.4 条件等待：

  • park和unpark：
    • park和unpark本身不提供条件等待的机制，但可以通过配合使用其他条件来实现。
  • wait和notify：
    • wait和notify通常与while循环一起使用，以检查特定条件是否满足。

7.5 示例代码对比

使用LockSupport的示例：

请看上述示例

使用wait和notify的示例：

public class WaitNotifyExample {private static final Object lock = new Object();public static void main(String[] args) {Thread thread = new Thread(() -> {synchronized (lock) {System.out.println("Thread is going to wait");try {lock.wait(); // 阻塞当前线程} catch (InterruptedException e) {e.printStackTrace();}System.out.println("Thread is notified");}});thread.start();try {Thread.sleep(2000); // 等待2秒System.out.println("sleep end");} catch (InterruptedException e) {e.printStackTrace();}synchronized (lock) {lock.notify(); // 唤醒线程System.out.println("thread is notify");}}
}

Thread is going to wait
sleep end
thread is notify
Thread is notified

这篇关于Java并发 - LockSupport详解的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/601436。

相关文章

Redis中6种缓存更新策略详解

Redis中6种缓存更新策略详解

《Redis中6种缓存更新策略详解》Redis作为一款高性能的内存数据库,已经成为缓存层的首选解决方案,然而,使用缓存时最大的挑战在于保证缓存数据与底层数据源的一致性,本文将介绍Redis中6种缓存更... 目录引言策略一：Cache-Aside（旁路缓存）策略工作原理代码示例优缺点分析适用场景策略二：Re
阅读更多...
SpringBoot中四种AOP实战应用场景及代码实现

SpringBoot中四种AOP实战应用场景及代码实现

《SpringBoot中四种AOP实战应用场景及代码实现》面向切面编程(AOP)是Spring框架的核心功能之一,它通过预编译和运行期动态代理实现程序功能的统一维护,在SpringBoot应用中,AO... 目录引言场景一：日志记录与性能监控业务需求实现方案使用示例扩展：MDC实现请求跟踪场景二：权限控制与
阅读更多...
Java NoClassDefFoundError运行时错误分析解决

Java NoClassDefFoundError运行时错误分析解决

《JavaNoClassDefFoundError运行时错误分析解决》在Java开发中,NoClassDefFoundError是一种常见的运行时错误,它通常表明Java虚拟机在尝试加载一个类时未能... 目录前言一、问题分析二、报错原因三、解决思路检查类路径配置检查依赖库检查类文件调试类加载器问题四、常见
阅读更多...
Java注解之超越Javadoc的元数据利器详解

Java注解之超越Javadoc的元数据利器详解

《Java注解之超越Javadoc的元数据利器详解》本文将深入探讨Java注解的定义、类型、内置注解、自定义注解、保留策略、实际应用场景及最佳实践,无论是初学者还是资深开发者,都能通过本文了解如何利用... 目录什么是注解？注解的类型内置注编程解自定义注解注解的保留策略实际用例最佳实践总结在 Java 编程
阅读更多...
MySQL数据库约束深入详解

MySQL数据库约束深入详解

《MySQL数据库约束深入详解》：本文主要介绍MySQL数据库约束,在MySQL数据库中,约束是用来限制进入表中的数据类型的一种技术,通过使用约束,可以确保数据的准确性、完整性和可靠性,需要的朋友... 目录一、数据库约束的概念二、约束类型三、NOT NULL 非空约束四、DEFAULT 默认值约束五、UN
阅读更多...
Python使用Matplotlib绘制3D曲面图详解

Python使用Matplotlib绘制3D曲面图详解

《Python使用Matplotlib绘制3D曲面图详解》：本文主要介绍Python使用Matplotlib绘制3D曲面图,在Python中,使用Matplotlib库绘制3D曲面图可以通过mpl... 目录准备工作绘制简单的 3D 曲面图绘制 3D 曲面图添加线框和透明度控制图形视角Matplotlib
阅读更多...
MySQL中的分组和多表连接详解

MySQL中的分组和多表连接详解

《MySQL中的分组和多表连接详解》：本文主要介绍MySQL中的分组和多表连接的相关操作,本文通过实例代码给大家介绍的非常详细,感兴趣的朋友一起看看吧... 目录mysql中的分组和多表连接一、MySQL的分组（group javascriptby ）二、多表连接（表连接会产生大量的数据垃圾）MySQL中的
阅读更多...
Java 实用工具类Spring 的 AnnotationUtils详解

Java 实用工具类Spring 的 AnnotationUtils详解

《Java实用工具类Spring的AnnotationUtils详解》Spring框架提供了一个强大的注解工具类org.springframework.core.annotation.Annot... 目录前言一、AnnotationUtils 的常用方法二、常见应用场景三、与 JDK 原生注解 API 的
阅读更多...
Java controller接口出入参时间序列化转换操作方法(两种)

Java controller接口出入参时间序列化转换操作方法(两种)

《Javacontroller接口出入参时间序列化转换操作方法(两种)》：本文主要介绍Javacontroller接口出入参时间序列化转换操作方法,本文给大家列举两种简单方法,感兴趣的朋友一起看... 目录方式一、使用注解方式二、统一配置场景：在controller编写的接口，在前后端交互过程中一般都会涉及
阅读更多...
Java中的StringBuilder之如何高效构建字符串

Java中的StringBuilder之如何高效构建字符串

《Java中的StringBuilder之如何高效构建字符串》本文将深入浅出地介绍StringBuilder的使用方法、性能优势以及相关字符串处理技术,结合代码示例帮助读者更好地理解和应用,希望对大家... 目录关键点什么是 StringBuilder？为什么需要 StringBuilder？如何使用 St
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2