[Java并发]ThreadLocal补充

news/2024/11/17 3:37:49/文章来源:https://www.cnblogs.com/DCFV/p/18351494

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把备份的上下文传入,恢复备份的上下文传入,把后面新增的上下文删除,并重新把上下文复制到当前线程。本次执行并不会污染线程池中线程原先的上下文环境。

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

如若内容造成侵权/违法违规/事实不符,请联系编程知识网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

NuminaMath 是如何荣膺首届 AIMO 进步奖的?

今年,Numina 和 Hugging Face 合作角逐 AI 数学奥林匹克 (AI Math Olympiad,AIMO) 的首届进步奖。此次比赛旨在对开放 LLM 进行微调,以使其能解决高中难度的国际数学奥林匹克训练题。我们很高兴向大家报告: 我们的模型 - NuminaMath 7B TIR - 在比赛中脱颖而出,成功解决了私…

【题解】ABC365(A~E)

前四题30min切,然后T5死磕70min+几发小唐错,距离比赛结束还有16s交最后一发,AC了。 目录A. Leap Year题目描述思路代码B. Second Best题目描述思路代码C. Transportation Expenses题目描述思路代码D. AtCoder Janken 3题目描述思路代码E. Xor Sigma Problem题目描述思路代码…

洛谷 P3870 开关之线段树板子

洛谷P3870题解传送锚点摸鱼环节 [TJOI2009] 开关 题目描述 现有 \(n\) 盏灯排成一排,从左到右依次编号为:\(1\),\(2\),……,\(n\)。然后依次执行 \(m\) 项操作。 操作分为两种:指定一个区间 \([a,b]\),然后改变编号在这个区间内的灯的状态(把开着的灯关上,关着的灯打开…

OI学习笔记(C++)

一些蒟蒻整理的OI笔记笔记完整版链接(洛谷)——暂无,正在维护 笔记完整版链接(博客) 参照 oi.wiki 整理的一些笔记: 学习笔记+模板(Adorable_hly) (自己结合网络和做题经验总结的,dalao勿喷) 第一大板块:DP 动态规划适用场景: 1. 最优化原理:若该问题所包含的子问…

静电场 恒定电流场 知识梳理

最近琢磨了一下Markdown插入LaTeX数学公式,感觉效果确实很不错🧐刚好最近比较闲,正想把新概念物理电磁学仔细看一遍,那就拿它来练手好了。下面主要把自己不太熟悉的知识详细解释了一下,比较简单的就一笔带过了。前言 最近琢磨了一下Markdown插入LaTeX数学公式,感觉效果确…

MR开发恐龙项目总结

在拥有权限的情况下读取安卓和windows的任意文件路径 TArray<FString> ULoadGallery::GetPngFilesInOculusDirectory() {TArray<FString> FilesArray;IFileManager& FileManager = IFileManager::Get();FString DirectoryPath;#if PLATFORM_ANDROIDDirectoryPa…

(自用) 化学假期作业8讲评

T16 (1)根据图可知,起始相对能量高于末态相对能量,说明反应放热,$\Delta\ H_1>0 $ 根据决速步骤定义,决速步骤是反应机制中具有最高活化能的反应步骤,所以由图可知,决速步骤为 $$\ H_2COO^* \ +\ 2H_2 \ = \ H_2 \ + \frac{3}{2} \ H_2$$ 相对应活化能即为\(\ H_2COO^* \ + …

代码随想录Day10

232.用栈实现队列 请你仅使用两个栈实现先入先出队列。队列应当支持一般队列支持的所有操作(push、pop、peek、empty): 实现 MyQueue 类: void push(int x) 将元素 x 推到队列的末尾 int pop() 从队列的开头移除并返回元素 int peek() 返回队列开头的元素 boolean empty() …

瞎猫碰到死耗子,安卓nt_qq数据库密钥算法

这个我实际上弄了很久了,一开始更新的时候,发现数据库操作都是在so里,那时候是在libkernel.so里直接hook sqlcipher的密钥函数拿到的密钥,32位字符串,很容易让人联想到md5,但是没有找到在哪里计算的最近又想着做一下,这时打开数据库的so就变了,这是easyFrida的sofileop…

[米联客-安路飞龙DR1-FPSOC] UDP通信篇连载-06 UDP层程序设计

软件版本:Anlogic -TD5.9.1-DR1_ES1.1 操作系统:WIN10 64bit 硬件平台:适用安路(Anlogic)FPGA 实验平台:米联客-MLK-L1-CZ06-DR1M90G开发板 板卡获取平台:https://milianke.tmall.com/ 登录"米联客"FPGA社区 http://www.uisrc.com 视频课程、答疑解惑! 3.5 UDP…

[米联客-安路飞龙DR1-FPSOC] UDP通信篇连载-02 MAC层程序设计

软件版本:Anlogic -TD5.9.1-DR1_ES1.1 操作系统:WIN10 64bit 硬件平台:适用安路(Anlogic)FPGA 实验平台:米联客-MLK-L1-CZ06-DR1M90G开发板 板卡获取平台:https://milianke.tmall.com/ 登录"米联客"FPGA社区 http://www.uisrc.com 视频课程、答疑解惑! 3 程序设…