首页 > 编程语言 >[Java并发]ThreadLocal补充

[Java并发]ThreadLocal补充

时间:2024-08-09 20:54:50浏览次数:13  
标签:inheritableThreadLocals Java Thread value 并发 ThreadLocal 线程 null

ThreadLocal缺点及解决方案

每个Thread上都有一个threadLocals属性,它是一个ThreadLocalMap,里面存放着一个Entry数组,key是ThreadLocal类型的弱引用,value是对用的值。所有的操作都是基于这个ThreadLocalMap操作的。

但是它有一个局限性,就是不能在父子线程之间传递。 即在子线程中无法访问在父线程中设置的本地线程变量。 后来为了解决这个问题,引入了一个新的类InheritableThreadLocal。

使用该方法后,子线程可以访问在创建子线程时父线程当时的本地线程变量,其实现原理就是在父线程创建子线程时将父线程当前存在的本地线程变量拷贝到子线程的本地线程变量中。

public class InheritableThreadLocal extends ThreadLocal {
protected T childValue(T parentValue) {
return parentValue;
}
ThreadLocalMap getMap(Thread t) {
return t.inheritableThreadLocals;
}
void createMap(Thread t, T firstValue) {
t.inheritableThreadLocals = new ThreadLocalMap(this, firstValue);
}
}
从上面的结构中可以看出,它主要是重写了getMap、createMap方法。

Thread类中有两个重要的变量

ThreadLocal.ThreadLocalMap threadLocals = null;
ThreadLocal.ThreadLocalMap inheritableThreadLocals = null;

init()方法片段

Thread parent = currentThread();
.....
if (inheritThreadLocals && parent.inheritableThreadLocals != null)
this.inheritableThreadLocals = ThreadLocal.createInheritedMap(parent.inheritableThreadLocals);
子线程时通过在父线程通过调用new Thread()方法来创建子线程,Thread#init方法在Thread的构造方法中被调用。

主要是先获取当前线程对象,即待创建的线程的父线程
如果父线程的inheritableThreadLocals不为空,并且inheritThreadLocals为true(默认为true),则使用父线程的ingerit本地变量的值来创建子线程的inheritableThreadLocals结构,即将父线程中的本地变量复制到子线程中。

private Entry[] table;

private ThreadLocalMap(ThreadLocalMap parentMap) {
Entry[] parentTable = parentMap.table;
int len = parentTable.length;
setThreshold(len);
table = new Entry[len];

        for (int j = 0; j < len; j++) {
            Entry e = parentTable[j];
            if (e != null) {
                @SuppressWarnings("unchecked")
                ThreadLocal<Object> key = (ThreadLocal<Object>) e.get();
                if (key != null) {
                    Object value = key.childValue(e.value);
                    Entry c = new Entry(key, value);
                    int h = key.threadLocalHashCode & (len - 1);
                    while (table[h] != null)
                        h = nextIndex(h, len);
                    table[h] = c;
                    size++;
                }
            }
        }
    }

子线程默认拷贝父线程的方式是浅拷贝,如果需要使用深拷贝,如果需要使用深拷贝,需要使用自定义ThreadLocal,继承InheritThreadLocal并重写childValue方法。

而它的实现原理主要是在创建子线程时将父类线程中的本地变量值parent.inheritableThreadLocals复制到子线程,即复制的机会在创建子线程时。

但是它也有一种缺陷,就是在使用线程池的情况下,因为线程池是复用线程,不会重复创建,而上述的inheritableThreadLocals是在创建子线程时才会将父线程的值复制到子线程,但是在线程池中不会重复创建,所以多次使用后,仍然记录的是第一次提交任务时的外部线程的值,造成了数据的错误。

那如何解决这种现象呢?

只需在用户线程向线程池提交任务时复制父线程的上下文环境,就可以实现本地变量在线程池调用的透传。 基于这个思想,阿里提出了TransmittableThreadLocal类。

image

在提交任务时的Runable或者Callable必须封装成TtlRunable或者TtlCallable。TransmittableThreadLocal覆盖实现了ThreadLocal的set、get、remove,实际存储inheritableThreadLocal值的工作还是inheritableThreadLocal父类完成,TransmittableThreadLocal只是为每个使用它的Thread单独记录一份存储了哪些TransmittableThreadLocal对象。
public final void set(T value) {
super.set(value);
if (null == value) removeValue();
else addValue();
}
首先它会调用父类的InheritableThreadLocal的set方法,将value加入到Thread对象的inheritableThreadLocals变量中。
如果value为null,则调用removeValue()方法,否则调用addValue方法。

private void addValue() {
if (!holder.get().containsKey(this)) { // @1
holder.get().put(this, null); // WeakHashMap supports null value.
}
}
private void removeValue() {
holder.get().remove(this);
}
调用addValue方法,会将当前ThreadLocal存储到TransmittableThreadLocal的全局静态变量hodler。所有和Thread绑定的所有TransmittableThreadLocal对象都保存在这个holder中,holder只是为了记录当前Thread绑定了哪些TransmittableThreadLocal对象。

下面具体讲一下TtlRunable的原理。

private TtlRunnable(@Nonnull Runnable runnable, boolean releaseTtlValueReferenceAfterRun) {
this.capturedRef = new AtomicReference(capture());
this.runnable = runnable;
this.releaseTtlValueReferenceAfterRun = releaseTtlValueReferenceAfterRun;
}
先创建Map容器,用来存储父线程的本地线程变量,键为在父线程执行过程中的TransmittableLocal线程;将线程中的值存放在里面。默认是浅拷贝,需要深拷贝的话,要重写copyValue方法。

public void run() {
Object captured = capturedRef.get();
if (captured == null || releaseTtlValueReferenceAfterRun && !capturedRef.compareAndSet(captured, null)) {
throw new IllegalStateException("TTL value reference is released after run!");
}
Object backup = replay(captured);
try {
runnable.run();
} finally {
restore(backup);
}
}
TtlRunable是实现于Runable,所以线程池执行的是TtlRunable,但是在TtlRunnable run方法中国会执行Runable run方法。

TtlRunable构造方法中,调用了capture()获取当前线程中所有的上下文,并存储在AtomicReference中。

当线程执行时,调用TtlRunable run方法, TtlRunable会从AtomicReference中获取出调用线程中的上下文,并把上下文利用replay方法把上下文复制到当前线程,并把上下文备份。

当线程执行完,调用restore把备份的上下文传入,恢复备份的上下文传入,把后面新增的上下文删除,并重新把上下文复制到当前线程。本次执行并不会污染线程池中线程原先的上下文环境。

标签:inheritableThreadLocals,Java,Thread,value,并发,ThreadLocal,线程,null
From: https://www.cnblogs.com/DCFV/p/18351494

相关文章

  • 2024年华为OD机试真题-求幸存数之和-(C++/Java/python)-OD统一考试(C卷D卷)
    2024华为OD机试真题目录-(B卷C卷D卷)-【C++JavaPython】_华为od机试csdn-CSDN博客 题目描述给一个正整数数列nums,一个跳数jump,及幸存数量left。运算过程为:从索引0的位置开始向后跳,中间跳过J个数字,命中索引为J+1的数字,该数被敲出,并从该点起跳,以此类推,直到幸存le......
  • Java基础语法:变量与数据类型
    变量1.概念:变量是用来存储数据的命名容器并在程序的不同部分使用它。2.语法:数据类型变量名称=初始值;可以这样理解:**数据类型:**鱼缸**变量名称:**鱼的名字**变量的值:**鱼缸里装的鱼或数量数量数据类型基本数据类型-整型:1.byte:8位,有符号整数(-128到127)2.short:......
  • IDEA发生“Error:java: 错误: 不支持发行版本 5”错误的解决方案
    1、问题描述如上图所示,使用IDEA创建了一个maven项目,在运行时发生“Error:java:错误:不支持发行版本5”的报错。原因分析:该错误是由于IDEA的各个配置项存在JDK版本冲突导致的。2、解决方案一2.1、设置Maven的JDK插件如上图所示,在pom.xml文件中,设置一个编译插......
  • [Java异常]OOM
    小伙伴们,有没有遇到过程序突然崩溃,然后抛出一个OutOfMemoryError的异常?这就是我们俗称的OOM,也就是内存溢出。简单来说,就是你的Java应用想要的内存超过了JVM愿意给的极限,就会抛出这个错误。那么为什么会出现OOM呢?一般都是由这些问题引起:分配过少:JVM初始化内存小,业务使用了大......
  • Java 基于微信小程序的学校心理咨询聊天室系统 uniapp毕业设计
    文末获取资源,收藏关注不迷路文章目录项目介绍功能需求技术介绍项目界面关键代码目录项目介绍该课题旨在创建一个专门针对大学生心理健康的知识科普平台,其受众包含大学生与其父母,包含知识科普,自我筛查,在线咨询,与匿名倾诉(包含父母与大学生)四个大点。全方位的对大学生......
  • Java基于微信小程序的琴房管理系统 uniapp 毕业设计
    文末获取资源,收藏关注不迷路文章目录项目介绍用户需求分析学生用户管理员用户技术介绍项目界面关键代码目录项目介绍随着互联网技术的发发展,计算机技术广泛应用在人们的生活中,逐渐成为日常工作、生活不可或缺的工具,钢琴培训企业各种管理系统层出不穷,为钢琴培训企......
  • java基础学习笔记1
    Java编程规范命名风格1.【强制】代码中的命名均不能以下划线或美元符号开始,也不能以下划线或美元符号结束。反例:_name/__name/$name/name_/name$/name__2.【强制】代码中的命名严禁使用拼音与英文混合的方式,更不允许直接使用中文的方式。说明:正确的英文拼写......
  • java io
    packagecom.io;importjava.io.BufferedReader;importjava.io.FileInputStream;importjava.io.IOException;importjava.io.InputStreamReader;importjava.nio.charset.StandardCharsets;publicclassBufferedReaderDemo01{publicstaticvoidmain(Str......
  • java集合
    packagecom.jihe;importjava.util.ArrayList;publicclassArrayListDemo1{publicstaticvoidmain(String[]args){//创建一个ArrayList实例ArrayList<String>fruits=newArrayList<>();//添加元素fruits.add(&quo......
  • Java毕业设计-基于ssm框架开发的车辆管理系统-毕业论文(附毕设源代码)
    文章目录前言一、毕设成果演示(源代码在文末)二、毕设摘要展示1、开发说明2、需求/流程分析3、系统功能结构三、系统实现展示1、个人中心2、员工管理3、用户管理4、基础数据管理5、车辆管理6、保养登记管理7、事故登记管理8、维修登记管理9、违章登记管理四、毕设内容和......