【JUC进阶】13. InheritableThreadLocal

目录

1、前言

2、回顾ThreadLocal

3、InheritableThreadLocal

4、实现原理

5、线程池中的问题

6、小结


1、前言

在《【JUC基础】14. ThreadLocal》一文中,介绍了ThreadLocal主要是用于每个线程持有的独立变量。通俗的说就是ThreadLocal是每个线程独有的一份内存,且各个线程间是独立、隔离的。但是随之而来的便会带来如下问题:

  • 如果项目实际场景中,确实需要子线程与父线程共享或复用变量时候,就无法满足。

上面问题的一个解法就是我们今天要介绍的InheritableThreadLocal。

2、回顾ThreadLocal

static ThreadLocal<String> threadLocal = new ThreadLocal<>();

public static void main(String[] args) {
    threadLocal.set("我是主线程的threadlocal变量");
    System.out.println("-----> 主线程" + Thread.currentThread() + " <----- 获取threadlocal变量:" + threadLocal.get());

    new Thread(() -> {
        System.out.println("-----> 子线程" + Thread.currentThread() + " <----- 获取threadlocal变量:" + threadLocal.get());
    }, "son-thread").start();

}

执行结果:

可以看出子线程想要获取父线程的threadlocal变量,是获取不到的。

3、InheritableThreadLocal

前面介绍了背景,那么InheritableThreadLocal是啥呢?他可以做一些啥?从类注释上可以看出InheritableThreadLocal实现了ThreadLocal的扩展,以提供从父线程到子线程的值继承。当创建子线程时,子线程接收父线程有值的所有可继承的线程局部变量的初始值。当在变量中维护每线程属性(例如,User ID)时,优先使用可继承的线程局部变量,而不是普通的线程局部变量。

我们将上面ThreadLocal的demo中,ThreadLocal改为InheritableThreadLocal试下:

static InheritableThreadLocal<String> threadLocal = new InheritableThreadLocal<>();

public static void main(String[] args) {
    threadLocal.set("我是主线程的threadlocal变量");
    System.out.println("-----> 主线程" + Thread.currentThread() + " <----- 获取threadlocal变量:" + threadLocal.get());

    new Thread(() -> {
        System.out.println("-----> 子线程" + Thread.currentThread() + " <----- 获取threadlocal变量:" + threadLocal.get());
    }, "son-thread").start();

}

执行结果:

可以发现,主线程的变量成功穿透到子线程中。

4、实现原理

结果都看到了,但是我们肯定不能只满足于结果,我们来探究一下他是如何实现的。我们点进去InheritableThreadLocal可以看到,他是ThreadLocal的扩展,且重新实现了childValue(),getMap(),createMap()三个方法。

我们查看createMap()方法,可以看到inheritableThreadLocals变量其实是Thread内部定义的用于线程间共享(inheritable英译:遗传)的变量。

void createMap(Thread t, T firstValue) {
    t.inheritableThreadLocals = new ThreadLocalMap(this, firstValue);
}

Thread.java:

/*
 * InheritableThreadLocal values pertaining to this thread. This map is
 * maintained by the InheritableThreadLocal class.
 */
ThreadLocal.ThreadLocalMap inheritableThreadLocals = null;

接着查看inheritableThreadLocals是从哪里赋值的:

重点关注画圈的部分,点进去java.lang.Thread#init(java.lang.ThreadGroup, java.lang.Runnable, java.lang.String, long, java.security.AccessControlContext, boolean),查看代码420行:

...
// 判断inheritThreadLocals为true,我们创建线程new Thread会进入初始化init方法,默认是true
// 且判断parent.inheritableThreadLocals不为空
if (inheritThreadLocals && parent.inheritableThreadLocals != null)
    // 进入该判断,将父线程的inheritableThreadLocals变量赋值给当前线程的inheritableThreadLocals
    this.inheritableThreadLocals =
        ThreadLocal.createInheritedMap(parent.inheritableThreadLocals);
...

以上的源码就是InheritableThreadLocal如何实现父子线程变量共享的实现原理了。

5、线程池中的问题

其实不难看出,InheritableThreadLocal只是解决了父子线程共享,或者变量传递的问题。接下来我们改造一下代码,我们通过线程管理多个线程试试看,然后把threadlocal的赋值操作放在创建线程之后:

static ThreadLocal<String> threadLocal = new InheritableThreadLocal<>();

// 定义线程池,核心线程数为1,方便线程复用
static ExecutorService executorService = Executors.newSingleThreadExecutor();

public static void main(String[] args) throws InterruptedException {

    // 线程池执行子线程
    executorService.submit(() -> {
        System.out.println("-----> 子线程" + Thread.currentThread() + " <----- 获取threadlocal变量:" + threadLocal.get());
    });

    // 主线程睡眠3s,模拟运行
    Thread.sleep(3000);
    // 将变量修改为11111
    threadLocal.set("我是主线程的threadlocal变量,变量值为:11111");

    // 这里线程池重新执行线程任务
    executorService.submit(() -> {
        System.out.println("-----> 子线程" + Thread.currentThread() + " <----- 获取threadlocal变量:" + threadLocal.get());
    });

    // 线程池关闭
    executorService.shutdown();

}

执行结果:

怎么又拿不到了?没错,上面提到InheritableThreadLocal实现值传递主要是根据父线程的map是否有值,再决定要不要赋值给子线程。而父线程的map是通过init一个Thread的时候赋值的。如果我们新创建一个线程,那么肯定会出发创建的初始化方法,必然会进行赋值操作。但是线程池由于线程复用,重复使用的线程在执行异步任务时可能无需再执行创建方法了,因此也就不会再传递父线程的TLMap给子线程了。自然后面获取到的就是null了。

总而言之,就是InheritableThreadLocal进行传递的必须是线程创建的时候赋值的才可以,如果是异步任务中进行赋值的一样是获取不到。如果是线上环境,那么此类问题一般都是偶发的,很容易把你搞脱发。

看到这,我知道你很急,但是你别急。太阳底下无新鲜事,我们不是第一个遇到此类问题的人,别人肯定也遇到过,看看业界是如何实现的。这就是我们接下来要介绍的TransmittableThreadLocal。欲知后事如何,请听下回分解~

6、小结

JUC编程中,往往遇到的问题都不是必现的,具备一定的JUC相关技术基础,可以给你在排障的路上减少一些阻碍。一起学习进步吧。

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:/a/302543.html

如若内容造成侵权/违法违规/事实不符,请联系我们进行投诉反馈qq邮箱809451989@qq.com,一经查实,立即删除!

相关文章

基于ssm的双减后初小教育课外学习生活活动平台的设计与实现论文

双减后初小教育课外学习生活活动平台的设计与实现 摘 要 当下&#xff0c;正处于信息化的时代&#xff0c;许多行业顺应时代的变化&#xff0c;结合使用计算机技术向数字化、信息化建设迈进。以前学校对于课外学习活动信息的管理和控制&#xff0c;采用人工登记的方式保存相关…

Spring——基于注解的AOP配置

基于注解的AOP配置 1.创建工程 1.1.pom.xml <?xml version"1.0" encoding"UTF-8"?> <project xmlns"http://maven.apache.org/POM/4.0.0"xmlns:xsi"http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation"…

多功能环境模拟试验系统

1、模拟自然条件下的气候环境、海洋环境、工业环境&#xff1b; 2、人工气候环境下各种工程材料、结构的耐久性试验&#xff1b; 3、人工气候环境混凝土结构热学性能及早期特性试验&#xff1b; 4、人工气候环境混凝土结构裂缝控制研究&#xff1b; 5、海洋环境下工程材料、…

模式识别实验三

实验三 一  实验名称 感知器设计 二 目的和意义 使用感知器完成线性分类任务 三 操作步骤或算法结构 数据预处理。载入数据文件&#xff08; iris.csv 文件&#xff09;中的数据&#xff0c;并将其分成样本向量矩阵X和样本分类结果向量 G \bf G G。 给 4 4 4 列向量的…

Objective-C中使用STL标准库Queue队列

1.修改.m文件为mm 2.导入queue头 #include<queue> 3.使用&#xff1a; #import <Foundation/Foundation.h> #include <cmath> #include <queue> using namespace std;int main(int argc, const char * argv[]) {autoreleasepool {NSLog("C标准…

软件测试|Python中的变量与关键字详解

简介 在Python编程中&#xff0c;变量和关键字是非常重要的概念。它们是构建和控制程序的基本要素。本文将深入介绍Python中的变量和关键字&#xff0c;包括它们的定义、使用方法以及一些常见注意事项。 变量 变量的定义 变量是用于存储数据值的名称。在Python中&#xff0…

RT-Thread: CPU 使用率应用

关键词&#xff1a;RT-Thread cpu使用率&#xff0c;cpuusage.c , cpuusage.h 说明&#xff1a;使用 RT-Thread 希望知道 mcu 计算能力的使用率或cpu使用率。 注意&#xff1a;在调试CUP使用率时&#xff0c;根据参考资料移植了 cpuusage.c , cpuusage.h ,也调用了 void cpu_…

【C/C++】轻量级跨平台 开源串口库 CSerialPort

文章目录 1、简介2、支持的平台3、已经支持的功能4、Linux下使用5、使用vcpkg安装CSerialPort6、交叉编译7、效果图8、基于CSerialPort的应用8.1、CommMaster通信大师8.2、CommLite串口调试器 1、简介 Qt 的QSerialPort 已经是跨平台的解决方案&#xff0c;但Qt开发后端需要 Q…

面试算法100:三角形中最小路径之和

题目 在一个由数字组成的三角形中&#xff0c;第1行有1个数字&#xff0c;第2行有2个数字&#xff0c;以此类推&#xff0c;第n行有n个数字。例如&#xff0c;下图是一个包含4行数字的三角形。如果每步只能前往下一行中相邻的数字&#xff0c;请计算从三角形顶部到底部的路径经…

高级RAG(五):TruLens 评估-扩大和加速LLM应用程序评估

之前我们介绍了&#xff0c;RAGAs评估&#xff0c;今天我们再来介绍另外一款RAG的评估工具:TruLens , trulens是TruEra公司的一款开源软件工具&#xff0c;它可帮助您使用反馈功函数客观地评估基于 LLM 的应用程序的质量和有效性。反馈函数有助于以编程方式评估输入、输出和中间…

java 创建一个可执行的jar包小程序

第1步&#xff1a;写好代码 public class Main {public static void main(String[] args) {String str "hahah";if (StringUtils.isBlank(str)) {System.out.println(str);}System.out.println("Hello world!");} }第2步&#xff1a;设置 Artifact 选择入…

多模态推荐系统综述:二、特征交互 Fusion

二、Fusion 融合不同的多模态信息&#xff0c;与bridge相比&#xff0c;融合更关注项目之间的多模态内部关系。 它可以灵活地融合不同权重和焦点的多模态信息。 注意机制是应用最为广泛的特征融合。 2.1 粗粒度注意力。 一些模型应用注意力机制在粗粒度级别融合来自多种模式…

游客管理+导航系统(地图显示并实时更新线路)——MySQL数据库+javase+GUI+迪杰斯特拉算法

记录大二上学期——数据结构项目实训&#xff0c;要求实现求得两点的最短路径&#xff08;无向赋权图&#xff09; 本人—hl—一人完成代码的实现&#xff0c;废话不多说直接看功能 所需技术&#xff1a;javase数据库迪杰斯特拉GUI 统一工具&#xff1a;idea编辑器&#xff0c…

编程语言的语法糖,你了解多少?

什么是语法糖 语法糖是一种编程语言的特性&#xff0c;通常是一些简单的语法结构或函数调用&#xff0c;它可以通过隐藏底层的复杂性&#xff0c;并提供更高级别的抽象&#xff0c;从而使代码更加简洁、易读和易于理解&#xff0c;但它并不会改变代码的执行方式。 为什么需要语…

Day1Qt

1、实现登录窗口界面 头文件 #ifndef MAINWINDOW_H #define MAINWINDOW_H#include <QMainWindow> #include <QIcon>//图标 #include <QLabel>//标签类 #include <QMovie>//动态类 #include <QLineEdit>//行编辑类 #include <QPushButton>…

有趣的前端知识(二)

推荐阅读 智能化校园&#xff1a;深入探讨云端管理系统设计与实现&#xff08;一&#xff09; 智能化校园&#xff1a;深入探讨云端管理系统设计与实现&#xff08;二&#xff09; 文章目录 推荐阅读HTML元素元素属性头部元素列表元素区块元素表单元素 颜色字符实体 HTML元素 …

过流继电器 GL-11/5 整定电流3.5A,动作时限0.5S josef约瑟

系列型号&#xff1a; GL-11过流继电器; GL-12过流继电器; GL-13过流继电器; GL-14过流继电器; GL-15过流继电器; GL-16过流继电器; GL-17过流继电器; GL-11/10过流继电器; GL-15/10过流继电器; GL-17/10过流继电器; GL-11/5过流继电器; GL-15/5过流继电器; GL-17/5过流继电器;…

Open3D 基于统计滤波去除噪点(5)

Open3D 基于统计滤波去除噪点&#xff08;5&#xff09; 一、什么是统计滤波二、具体实现1.代码 一、什么是统计滤波 统计滤波是一种常用的点云滤波方法&#xff0c;用于去除噪声和异常点。在统计滤波中&#xff0c;通过计算每个点邻域内的统计特征&#xff08;如平均值和标准…

C#之反编译之路(二)

先阅读C#之反编译之路(一)可以增加文章连续性 阅读C#之反编译之路(一) 如何快速定位代码位置 用一个小小的例子举例,用户反馈新能源车牌号无法录入,燃油车牌正常,查看日志报如下错误 拿到关键字车牌号长度错误直接反编译代码 打开dnSpy.exe→加载项目→CtrlF打开搜索框→输入…

ThreadLocal内存泄漏与解决

目录 什么是Threadlocal&#xff1f; Threadlocal的基本使用 ThreadLocal的内存泄漏举例 场景1 场景2 场景3 场景4 内存泄漏原因分析 总结 什么是Threadlocal&#xff1f; ThreadLocal 是 Java 中的一个类&#xff0c;它提供了线程本地变量的支持。线程本地变量是指被…