java LockSupport实现原理示例解析

目录
  • 引言
  • LockSupport常见函数
    • LockSupport.park
    • LockSupport.unpark

引言

前文中了解到AQS借助LockSupport.park和LockSupport.unpark完成线程的阻塞和唤醒,那么LockSupport内部又是怎么实现的?这是一个什么类?

LockSupport是用于使用锁阻塞线程的基础实现,是其他同步类的基础,这个类为每个使用它的线程关联一个许可证(有点类似于Semaphore),如果许可证可用,线程调用park方法时会立即返回,线程正常执行,否则当前线程阻塞,直到有其他线程调用unpark使得许可证可用,此时线程被唤醒,再次尝试获取许可证,其内部定义的park和unpark方法提供了阻塞和解决阻塞的基本实现。

LockSupport常见函数

如下表所示:

函数名称 说明 备注
void park() 阻塞当前线程 在下列情况发生时唤醒: 1.调用unpark函数,释放该线程的许可; 2.该线程被中断; 3.设置的阻塞超时时间耗尽; 4.到达设置的指定时间
void park(Object blocker) 使用指定的blocker对象阻塞当前线程 唤醒条件,park中已说明
void parkNanos(long nanos) 阻塞当前线程直到超时时间耗尽,nanos为指定的超时时间 唤醒条件,park中已说明
void parkNanos(Object blocker, long nanos) 在超时时间耗尽前,使用指定的blocker对象阻塞当前线程,如果在到达超时时间后,许可仍不可用,则结束阻塞 唤醒条件,park中已说明
void parkUntil(long deadline) 在指定时间前,阻塞该线程,如果在到达指定时间后,许可仍不可用,则结束阻塞 唤醒条件,park中已说明
void parkUntil(Object blocker, long deadline) 在指定时间前,使用指定的对象阻塞该线程,如果在到达指定时间后,许可仍不可用,则结束阻塞 唤醒条件,park中已说明
void unpark(Thread thread) 用于唤醒传入的在阻塞中的线程 /
Object getBlocker(Thread t) 获取当前线程的阻塞对象 /
void setBlocker(Thread t, Object arg) 使用指定对象为线程设置阻塞对象 /

LockSupport.park

ReentrantLock中调用LockSupport.park代码如下所示:

 // AbstractQueuedSynchronizer.java
 private final boolean parkAndCheckInterrupt() {
     LockSupport.park(this);
     return Thread.interrupted();
 }

在LockSupport中,void park(Object blocker)实现代码如下:

 // LockSupport.java
 public static void park(Object blocker) {
     Thread t = Thread.currentThread();
     setBlocker(t, blocker);
     UNSAFE.park(false, 0L);
     setBlocker(t, null);
 }

可以看到在park流程中主要包含以下过程:

获取当前线程

将传入的对象设置为该线程的parkBlocker

setBlocker函数实现如下所示:

 private static void setBlocker(Thread t, Object arg) {
     // Even though volatile, hotspot doesn't need a write barrier here.
     UNSAFE.putObject(t, parkBlockerOffset, arg);
 }

可以看到这里新出现了UNSAFE和parkBlockerOffset两个标识,这两个是用来干嘛的?我们一起看看其声明的代码:

 private static final sun.misc.Unsafe UNSAFE;
 private static final long parkBlockerOffset;
 static {
     try {
         UNSAFE = sun.misc.Unsafe.getUnsafe();
         Class<?> tk = Thread.class;
         parkBlockerOffset = UNSAFE.objectFieldOffset
             (tk.getDeclaredField("parkBlocker"));
         .....
     } catch (Exception ex) { throw new Error(ex); }
 }

可以看到UNSAFE对象是通过Unsafe.getUnsafe()获取的,那么Unsafe这个类到底是干嘛的?

大家都知道Java对象在内存中创建,大多数情况下我们都是通过类的对象去修改和访问内存中的数据的,那么如果需要直接从内存修改某一对象的取值,应该怎么做呢?就是使用Unsafe类,该类只允许在JDK信任的类中调用(当前也可以用反射实例化该类对象)。

在Unsafe类中定义了两个重要函数park和unpark,其中park用于实现线程阻塞,unpark用于实现线程唤醒(Unsafe本质上是操作线程的Parker对象来完成线程阻塞和唤醒的,具体见参考链接,了解即可),上文中的parkBlockerOffset正是定义了Thread类的parkBlocker属性成员的内存偏移量,使用该值再结合Unsafe对象就可以实现直接操作内存中的parkBlocker值的目的,Thread类中的parkBlocker声明如下:

 // Thread.java
 volatile Object parkBlocker;

可以得到这一环节主要是将AQS作为blocker设置到当前线程的parkBlocker成员属性上。

CAS底层也是通过Unsafe执行的

执行UNSAFE.park

结合上文可知,这步完成后,当前线程阻塞

设置线程的parkBlocker为null

第三步中线程处于阻塞状态,当然就不能执行设置parkBlocker为null的操作了,那么什么时候执行呢?当线程从阻塞状态唤醒时,执行该步骤,使得线程的parkBlocker对象恢复初始状态。

LockSupport.unpark

LockSupport.unpark代码如下所示:

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

可以看出当传入的线程不为空时,执行Unsafe的park函数唤醒当前线程,取消阻塞,此时继续执行park函数中的setBlocker(null),将parkBlocker成员设置为null。

参考链接  https://www.jb51.net/article/272073.htm

以上就是java LockSupport实现原理示例解析的详细内容,更多关于java LockSupport原理的资料请关注我们其它相关文章!

(0)

相关推荐

  • Java并发编程系列之LockSupport的用法

    目录 1.什么是LockSupport? 2.两类基本API 3.LockSupport本质 4.LockSupport例子 5.LockSupport源码 总结 1.什么是LockSupport? LockSupport是用于创建锁和其他同步类的基本线程阻塞原语 2.两类基本API LockSupport提供了两类最基本的API: block线程类:一般都是以pack开头的方法名,pack*(...) pack方法有两个重载的版本:blocker是一个对象,用于指定阻塞哪个对象.不知道的情况,

  • Java 多线程并发LockSupport

    目录 概览 源码分析 静态方法 Blocker unpark Unsafe 的 unpark 方法 park 不带 blocker 参数的分组 需要 blocker 参数的分组 park/unpark 和 Object 的 wait/notify 区别 概览 这部分内容来自于这个类的注释,简单翻译了下. LockSupport 类是用于创建锁和其他同步类的基本线程阻塞原语. 它的实现思想是给每个使用它的线程颁发一个许可,当许可是可用状态时(线程有许可),调用 park 方法会消耗一个许可,方法立

  • 教你如何使用Java多线程编程LockSupport工具类

    LockSupport类 用于创建锁和其他同步类的基本线程阻塞原语,此类与使用它的每个线程关联一个许可.如果获得许可,将立即返回对park的调用,并在此过程中消耗掉它:否则may会被阻止.调用unpark可使许可证可用(如果尚不可用).(不过与信号量不同,许可证不会累积.最多只能有一个.) 方法park和unpark提供了有效的阻塞和解阻塞线程的方法,这些线程不会遇到导致已弃用的方法Thread.suspend和Thread.resume无法用于以下问题:由于许可,在调用park的一个线程与试图

  • Java并发编程之LockSupport类详解

    一.LockSupport类的属性 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 SEC

  • 线程阻塞唤醒工具 LockSupport使用详解

    目录 LockSupport 简介 回顾 synchronized 和 Lock LockSupport 和 synchronized 和 Lock 的阻塞方式对比 LockSupport 的使用 LockSupport 注意事项 许可证提前发放 许可证不会累计 LockSupport 底层实现 结语 LockSupport 简介 LockSupport 是 Java 并发编程中一个非常重要的组件,我们熟知的并发组件 Lock.线程池.CountDownLatch 等都是基于 AQS 实现的,而

  • java LockSupport实现原理示例解析

    目录 引言 LockSupport常见函数 LockSupport.park LockSupport.unpark 引言 前文中了解到AQS借助LockSupport.park和LockSupport.unpark完成线程的阻塞和唤醒,那么LockSupport内部又是怎么实现的?这是一个什么类? LockSupport是用于使用锁阻塞线程的基础实现,是其他同步类的基础,这个类为每个使用它的线程关联一个许可证(有点类似于Semaphore),如果许可证可用,线程调用park方法时会立即返回,线程

  • Java环境配置原理全面解析

    Java环境配置原理详解 1.Jdk安装目录文件说明: 一般jdk安装目录及路径 \Java\jdk1.7.0_79\lib,里面主要包含以下文件夹. bin:主要存放的是java工具中常用命令如:java,javac等. db:安装java db的路径. include:一些平台特病的头文件. jre:运行java程序所需的jre环境. lib:jdk工具命令的实际存放位置,如:bin中javac命令,实际是lib中tools.jar\sun\tools\javac中的Main.class文件

  • Java中LinkedList原理代码解析

    本文研究的主要是Java中LinkedList原理的相关内容,具体介绍如下. 一句话概括,Java中的LinkedList其实就是使用双向链表,LinkedList的基本操作就是对双向链表的操作. 上面可以清晰的看出,链表中每个元素对应一个节点,节点里面包含三部分,一个是前一个节点的引用,一个是元素内容,一个是后一个节点的引用. 向链表中添加元素的过程就是在链表尾部追加一个节点 void linkLast(E e) { final Node<E> l = last; final Node<

  • Kotlin协程之Flow基础原理示例解析

    目录 引言 一.Flow的创建 二.Flow的消费 1.SafeFlow类 2.AbstractFlow类 3. SafeCollector类 4.消费过程中的挂起 引言 本文分析示例代码如下: launch(Dispatchers.Main) { flow { emit(1) emit(2) }.collect { delay(1000) withContext(Dispatchers.IO) { Log.d("liduo", "$it") } Log.d(&qu

  • go语言csrf库使用实现原理示例解析

    目录 引言 csrf小档案 一.CSRF及其实现原理 CSRF攻击示例 二.如何预防 三.CSRF包的使用及实现原理 csrf包的安装 基本使用 使用net/http包启动的服务 echo框架下使用csrf包 gin框架下使用csrf包 beego框架下使用csrf包 实现原理 csrf结构体 csrf包的工作流程 为什么GET.HEAD.OPTIONS.TRACE的请求方法不需要token验证 总结 引言 今天给大家推荐的是web应用安全防护方面的一个包:csrf.该包为Go web应用中常见

  • react fiber执行原理示例解析

    目录 为什么要使用fiber,要解决什么问题? fiber是什么? 数据结构 执行单元 浏览器工作: Fiber执行原理 workInProgress tree: currentFiber tree: Effects list: render阶段: 遍历节点过程: 收集effect list: commit阶段: 为什么commit必须是同步的操作的? 为什么要使用fiber,要解决什么问题? 在 react16 引入 Fiber 架构之前,react 会采用递归方法对比两颗虚拟DOM树,找出需

  • useReducer createContext代替Redux原理示例解析

    目录 前言 采用react-redux实现 采用react hooks模拟redux实现 异步action 总结 前言 最近看到很多采用useReducer + createContext 实现一个简易的redux的方案,今天亲自试了一下,发现还是会有一些区别的. 采用react-redux实现 这里使用react-redux 实现一个简单的状态管理例子. App.jsx根组件 import React from 'react'; import { Button } from './Button

  • flutter Bloc 实现原理示例解析

    目录 序言 1. 事件流 > 状态流 (中转) 2. 使用 BlocBuilder 实时监听状态变更, 如何实现的呢? 总结 扩展 序言 在flutter开发中,我们使用 bloc 框架,基于状态变更进行响应式开发.本篇文章,小轰将 bloc 核心业务块进行拆解简化,聊一聊它的实现思想,bloc 核心能力分为如下两点: 添加事件 event,将 '事件流' 转换为 '状态流' state 监听 bloc 流,每次 state 状态变更,通知 widget 更新 下面,用自定义Bloc的方式,来给

  • go sync Once实现原理示例解析

    目录 正文 Once 的实现 使用示例 Once 的一些工作机制 Once 详解 hotpath atomic.LoadUint32 atomic.StoreUint32 Mutex 总结 正文 在很多情况下,我们可能需要控制某一段代码只执行一次,比如做某些初始化操作,如初始化数据库连接等. 对于这种场景,go 为我们提供了 sync.Once 对象,它保证了某个动作只被执行一次. 当然我们也是可以自己通过 Mutex 实现 sync.Once 的功能,但是相比来说繁琐了那么一点, 因为我们不仅

  • 网页资源阻塞浏览器加载的原理示例解析

    目录 正文 测试前环境准备 图片会造成阻塞吗? CSS 加载阻塞 CSS 会阻塞后面 JS 的执行吗? JS 加载阻塞 defer 和 async 动态脚本会造成阻塞吗? DOMContentLoaded 和 onload DOMContentLoaded 遇到脚本 DOMContentLoaded 遇到样式 正文 一个页面允许加载的外部资源有很多,常见的有脚本.样式.字体.图片和视频等,对于这些外部资源究竟是如何影响整个页面的加载和渲染的呢?今天来一探究竟. 如何用 Chrome 定制网络加载

随机推荐