首页 > 其他分享 >一文让你彻底掌握ThreadLocal

一文让你彻底掌握ThreadLocal

时间:2023-08-01 16:02:34浏览次数:40  
标签:变量 彻底 Thread ThreadLocal 线程 threadLocals null 一文

本文分享自华为云社区《【高并发】一文带你彻底搞懂ThreadLocal》,作者: 冰 河。

我们都知道,在多线程环境下访问同一个共享变量,可能会出现线程安全的问题,为了保证线程安全,我们往往会在访问这个共享变量的时候加锁,以达到同步的效果,如下图所示。

一文让你彻底掌握ThreadLocal_子线程

对共享变量加锁虽然能够保证线程的安全,但是却增加了开发人员对锁的使用技能,如果锁使用不当,则会导致死锁的问题。而ThreadLocal能够做到在创建变量后,每个线程对变量访问时访问的是线程自己的本地变量

什么是ThreadLocal?

ThreadLocal是JDK提供的,支持线程本地变量。也就是说,如果我们创建了一个ThreadLocal变量,则访问这个变量的每个线程都会有这个变量的一个本地副本。如果多个线程同时对这个变量进行读写操作时,实际上操作的是线程自己本地内存中的变量,从而避免了线程安全的问题。

一文让你彻底掌握ThreadLocal_获取值_02

ThreadLocal使用示例

例如,我们使用ThreadLocal保存并打印相关的变量信息,程序如下所示。

public class ThreadLocalTest {

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

public static void main(String[] args){

//创建第一个线程

Thread threadA = new Thread(()->{

threadLocal.set("ThreadA:" + Thread.currentThread().getName());

System.out.println("线程A本地变量中的值为:" + threadLocal.get());

});

//创建第二个线程

Thread threadB = new Thread(()->{

threadLocal.set("ThreadB:" + Thread.currentThread().getName());

System.out.println("线程B本地变量中的值为:" + threadLocal.get());

});

//启动线程A和线程B

threadA.start();

threadB.start();

}

}

运行程序,打印的结果信息如下所示。

线程A本地变量中的值为:ThreadA:Thread-0

线程B本地变量中的值为:ThreadB:Thread-1

此时,我们为线程A增加删除ThreadLocal中的变量的操作,如下所示。

public class ThreadLocalTest {

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

public static void main(String[] args){

//创建第一个线程

Thread threadA = new Thread(()->{

threadLocal.set("ThreadA:" + Thread.currentThread().getName());

System.out.println("线程A本地变量中的值为:" + threadLocal.get());

threadLocal.remove();

System.out.println("线程A删除本地变量后ThreadLocal中的值为:" + threadLocal.get());

});

//创建第二个线程

Thread threadB = new Thread(()->{

threadLocal.set("ThreadB:" + Thread.currentThread().getName());

System.out.println("线程B本地变量中的值为:" + threadLocal.get());

System.out.println("线程B没有删除本地变量:" + threadLocal.get());

});

//启动线程A和线程B

threadA.start();

threadB.start();

}

}

此时的运行结果如下所示。

线程A本地变量中的值为:ThreadA:Thread-0

线程B本地变量中的值为:ThreadB:Thread-1

线程B没有删除本地变量:ThreadB:Thread-1

线程A删除本地变量后ThreadLocal中的值为:null

通过上述程序我们可以看出,线程A和线程B存储在ThreadLocal中的变量互不干扰,线程A存储的变量只能由线程A访问,线程B存储的变量只能由线程B访问。

ThreadLocal原理

首先,我们看下Thread类的源码,如下所示。

public class Thread implements Runnable {

/***********省略N行代码*************/

ThreadLocal.ThreadLocalMap threadLocals = null;

ThreadLocal.ThreadLocalMap inheritableThreadLocals = null;

/***********省略N行代码*************/

}

由Thread类的源码可以看出,在ThreadLocal类中存在成员变量threadLocals和inheritableThreadLocals,这两个成员变量都是ThreadLocalMap类型的变量,而且二者的初始值都为null。只有当前线程第一次调用ThreadLocal的set()方法或者get()方法时才会实例化变量。

这里需要注意的是:每个线程的本地变量不是存放在ThreadLocal实例里面的,而是存放在调用线程的threadLocals变量里面的。也就是说,调用ThreadLocal的set()方法存储的本地变量是存放在具体线程的内存空间中的,而ThreadLocal类只是提供了set()和get()方法来存储和读取本地变量的值,当调用ThreadLocal类的set()方法时,把要存储的值放入调用线程的threadLocals中存储起来,当调用ThreadLocal类的get()方法时,从当前线程的threadLocals变量中将存储的值取出来。

接下来,我们分析下ThreadLocal类的set()、get()和remove()方法的实现逻辑。

set()方法

set()方法的源代码如下所示。

public void set(T value) {

//获取当前线程

Thread t = Thread.currentThread();

//以当前线程为Key,获取ThreadLocalMap对象

ThreadLocalMap map = getMap(t);

//获取的ThreadLocalMap对象不为空

if (map != null)

//设置value的值

map.set(this, value);

else

//获取的ThreadLocalMap对象为空,创建Thread类中的threadLocals变量

createMap(t, value);

}

在set()方法中,首先获取调用set()方法的线程,接下来,使用当前线程作为Key调用getMap(t)方法来获取ThreadLocalMap对象,getMap(Thread t)的方法源码如下所示。

ThreadLocalMap getMap(Thread t) {

return t.threadLocals;

}

可以看到,getMap(Thread t)方法获取的是线程变量自身的threadLocals成员变量。

在set()方法中,如果调用getMap(t)方法返回的对象不为空,则把value值设置到Thread类的threadLocals成员变量中,而传递的key为当前ThreadLocal的this对象,value就是通过set()方法传递的值。

如果调用getMap(t)方法返回的对象为空,则程序调用createMap(t, value)方法来实例化Thread类的threadLocals成员变量。

void createMap(Thread t, T firstValue) {

t.threadLocals = new ThreadLocalMap(this, firstValue);

}

也就是创建当前线程的threadLocals变量。

get()方法

get()方法的源代码如下所示。

public T get() {

//获取当前线程

Thread t = Thread.currentThread();

//获取当前线程的threadLocals成员变量

ThreadLocalMap map = getMap(t);

//获取的threadLocals变量不为空

if (map != null) {

//返回本地变量对应的值

ThreadLocalMap.Entry e = map.getEntry(this);

if (e != null) {

@SuppressWarnings("unchecked")

T result = (T)e.value;

return result;

}

}

//初始化threadLocals成员变量的值

return setInitialValue();

}

通过当前线程来获取threadLocals成员变量,如果threadLocals成员变量不为空,则直接返回当前线程绑定的本地变量,否则调用setInitialValue()方法初始化threadLocals成员变量的值。

private T setInitialValue() {

//调用初始化Value的方法

T value = initialValue();

Thread t = Thread.currentThread();

//根据当前线程获取threadLocals成员变量

ThreadLocalMap map = getMap(t);

if (map != null)

//threadLocals不为空,则设置value值

map.set(this, value);

else

//threadLocals为空,创建threadLocals变量

createMap(t, value);

return value;

}

其中,initialValue()方法的源码如下所示。

protected T initialValue() {

return null;

}

通过initialValue()方法的源码可以看出,这个方法可以由子类覆写,在ThreadLocal类中,这个方法直接返回null。

remove()方法

remove()方法的源代码如下所示。

public void remove() {

//根据当前线程获取threadLocals成员变量

ThreadLocalMap m = getMap(Thread.currentThread());

if (m != null)

//threadLocals成员变量不为空,则移除value值

m.remove(this);

}

remove()方法的实现比较简单,首先根据当前线程获取threadLocals成员变量,不为空,则直接移除value的值。

注意:如果调用线程一致不终止,则本地变量会一直存放在调用线程的threadLocals成员变量中,所以,如果不需要使用本地变量时,可以通过调用ThreadLocal的remove()方法,将本地变量从当前线程的threadLocals成员变量中删除,以免出现内存溢出的问题。

ThreadLocal变量不具有传递性

使用ThreadLocal存储本地变量不具有传递性,也就是说,同一个ThreadLocal在父线程中设置值后,在子线程中是无法获取到这个值的,这个现象说明ThreadLocal中存储的本地变量不具有传递性。

接下来,我们来看一段代码,如下所示。

public class ThreadLocalTest {

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

public static void main(String[] args){

//在主线程中设置值

threadLocal.set("ThreadLocalTest");

//在子线程中获取值

Thread thread = new Thread(new Runnable() {

@Override

public void run() {

System.out.println("子线程获取值:" + threadLocal.get());

}

});

//启动子线程

thread.start();

//在主线程中获取值

System.out.println("主线程获取值:" + threadLocal.get());

}

}

运行这段代码输出的结果信息如下所示。

主线程获取值:ThreadLocalTest

子线程获取值:null

通过上述程序,我们可以看出在主线程中向ThreadLocal设置值后,在子线程中是无法获取到这个值的。那有没有办法在子线程中获取到主线程设置的值呢?此时,我们可以使用InheritableThreadLocal来解决这个问题。

InheritableThreadLocal使用示例

InheritableThreadLocal类继承自ThreadLocal类,它能够让子线程访问到在父线程中设置的本地变量的值,例如,我们将ThreadLocalTest类中的threadLocal静态变量改写成InheritableThreadLocal类的实例,如下所示。

public class ThreadLocalTest {

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

public static void main(String[] args){

//在主线程中设置值

threadLocal.set("ThreadLocalTest");

//在子线程中获取值

Thread thread = new Thread(new Runnable() {

@Override

public void run() {

System.out.println("子线程获取值:" + threadLocal.get());

}

});

//启动子线程

thread.start();

//在主线程中获取值

System.out.println("主线程获取值:" + threadLocal.get());

}

}

此时,运行程序输出的结果信息如下所示。

主线程获取值:ThreadLocalTest

子线程获取值:ThreadLocalTest

可以看到,使用InheritableThreadLocal类存储本地变量时,子线程能够获取到父线程中设置的本地变量。

InheritableThreadLocal原理

首先,我们来看下InheritableThreadLocal类的源码,如下所示。

public class InheritableThreadLocal<T> extends ThreadLocal<T> {

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);

}

}

由InheritableThreadLocal类的源代码可知,InheritableThreadLocal类继承自ThreadLocal类,并且重写了ThreadLocal类的childValue()方法、getMap()方法和createMap()方法。也就是说,当调用ThreadLocal的set()方法时,创建的是当前Thread线程的inheritableThreadLocals成员变量而不再是threadLocals成员变量。

这里,我们需要思考一个问题:InheritableThreadLocal类的childValue()方法是何时被调用的呢? 这就需要我们来看下Thread类的构造方法了,如下所示。

public Thread() {

init(null, null, "Thread-" + nextThreadNum(), 0);

}

public Thread(Runnable target) {

init(null, target, "Thread-" + nextThreadNum(), 0);

}

Thread(Runnable target, AccessControlContext acc) {

init(null, target, "Thread-" + nextThreadNum(), 0, acc, false);

}

public Thread(ThreadGroup group, Runnable target) {

init(group, target, "Thread-" + nextThreadNum(), 0);

}

public Thread(String name) {

init(null, null, name, 0);

}

public Thread(ThreadGroup group, String name) {

init(group, null, name, 0);

}

public Thread(Runnable target, String name) {

init(null, target, name, 0);

}

public Thread(ThreadGroup group, Runnable target, String name) {

init(group, target, name, 0);

}

public Thread(ThreadGroup group, Runnable target, String name,

long stackSize) {

init(group, target, name, stackSize);

}

可以看到,Thread类的构造方法最终调用的是init()方法,那我们就来看下init()方法,如下所示。

private void init(ThreadGroup g, Runnable target, String name,

long stackSize, AccessControlContext acc,

boolean inheritThreadLocals) {

/************省略部分源码************/

if (inheritThreadLocals && parent.inheritableThreadLocals != null)

this.inheritableThreadLocals =

ThreadLocal.createInheritedMap(parent.inheritableThreadLocals);

/* Stash the specified stack size in case the VM cares */

this.stackSize = stackSize;

/* Set thread ID */

tid = nextThreadID();

}

可以看到,在init()方法中会判断传递的inheritThreadLocals变量是否为true,同时父线程中的inheritableThreadLocals是否为null,如果传递的inheritThreadLocals变量为true,同时,父线程中的inheritableThreadLocals不为null,则调用ThreadLocal类的createInheritedMap()方法。

static ThreadLocalMap createInheritedMap(ThreadLocalMap parentMap) {

return new ThreadLocalMap(parentMap);

}

在createInheritedMap()中,使用父线程的inheritableThreadLocals变量作为参数创建新的ThreadLocalMap对象。然后在Thread类的init()方法中会将这个ThreadLocalMap对象赋值给子线程的inheritableThreadLocals成员变量。

接下来,我们来看看ThreadLocalMap的构造函数都干了啥,如下所示。

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) {

//调用重写的childValue方法

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++;

}

}

}

}

在ThreadLocalMap的构造函数中,调用了InheritableThreadLocal类重写的childValue()方法。而InheritableThreadLocal类通过重写getMap()方法和createMap()方法,让本地变量保存到了Thread线程的inheritableThreadLocals变量中,线程通过InheritableThreadLocal类的set()方法和get()方法设置变量时,就会创建当前线程的inheritableThreadLocals变量。此时,如果父线程创建子线程,在Thread类的构造函数中会把父线程中的inheritableThreadLocals变量里面的本地变量复制一份保存到子线程的inheritableThreadLocals变量中。

点击关注,第一时间了解华为云新鲜技术~


标签:变量,彻底,Thread,ThreadLocal,线程,threadLocals,null,一文
From: https://blog.51cto.com/u_15214399/6923381

相关文章

  • 一文让你彻底掌握ThreadLocal
    本文分享自华为云社区《【高并发】一文带你彻底搞懂ThreadLocal》,作者:冰河。我们都知道,在多线程环境下访问同一个共享变量,可能会出现线程安全的问题,为了保证线程安全,我们往往会在访问这个共享变量的时候加锁,以达到同步的效果,如下图所示。对共享变量加锁虽然能够保证线程的安......
  • 面试再也不怕问ThreadLocal了
    要解决多线程并发问题,常见的手段无非就几种。加锁,如使用synchronized,ReentrantLock,加锁可以限制资源只能被一个线程访问;CAS机制,如AtomicInterger,AtomicBoolean等原子类,通过自旋的方式来尝试修改资源;还有本次我们要介绍的ThreadLocal类,通过为每个线程维护一个变量副本,每个线程都......
  • 谈⼀谈ThreadLocal
     ThreadLocal是线程共享变量。ThreadLoacl有⼀个静态内部类ThreadLocalMap,其Key是ThreadLocal对象,值是Entry对象,ThreadLocalMap是每个线程私有的。set给ThreadLocalMap设置值。get获取ThreadLocalMap。remove删除ThreadLocalMap类型的对象。存在的问题:对于线程......
  • 教你一文教你使用自己的域名远程访问内网群晖NAS+6.X【内网穿透】
    文章目录使用自己的域名远程访问内网群晖NAS6.X【内网穿透】使用自己的域名远程访问内网群晖NAS6.X【内网穿透】在之前的文章中,我们向大家演示了如何使用cpolar,创建一条固定的、能够在公共互联网登录内网群晖NAS的数据隧道。这条隧道已经能够应对大多数情况。不过我们能看到,在......
  • 一文帮你全面认识方天视窗引擎
    2023年5月份,openEuler正式成立FangTianSIG。FangTianSIG聚焦FangTian视窗引擎,包含显示服务,窗口管理,图形绘制、合成、送显等模块,同时推出新型FT显示协议,探索解决Linux桌面环境体验不佳的问题。经过2个多月的开发、调试,FangTianSIG已在设备上流畅地运行Demo应用。本文将为大家介......
  • 一文讲解API网关核心功能——就是nginx,无非加入了安全、流控、转换、版本控制等功能
    一文讲解API网关核心功能【编者的话】本文详细讲解了API网关的基础概念,使用场景和核心功能,以及基于API网关核心引擎做的API全生命周期管理功能扩展等,最好再介绍下当前主流的开源API网关引擎。API网关概述在微服务架构体系里面,我们一般会使用到微服务网关或叫API网关。大家都比较清......
  • 彻底搞定MySQL索引(从底层到应用)
    读者忠告由于本文内容篇幅较长,涵盖了大家学习上、工作上的绝大多数索引,建议大家每一小节都认真阅读并理解透彻,如有疑问可在评论区留言探讨;二、索引2.1索引概述索引是帮助数据库快速查询数据的一种数据结构,在数据库中,数据库系统除了存储数据之外还维护着一种特殊的数据结构,这种数据......
  • 稳扎稳打,坚定前行 | 一文带你回顾 StoneDB 的 2022 年
    2022年6月29号,StoneDB正式宣布开源,自开源以来,StoneDB开源团队在用心打磨产品的同时,也在积极地拥抱开源社区,与万千数据库开发者共同成长,我们从day1就励志要做一款立足中国、面向全球的开源数据库,内核代码已经在Github上完全开源,欢迎大家前往关注:https://github.com/stone......
  • 一文带你搞定Maven全功能
    在一次需求迭代中,同事要求我把写好的RPC接口打好包上传到公司私服上,我人直接当场懵逼住了。突然发现自己对于Maven仅仅是处于最基础的使用阶段,不仅不知道背后的一些原理,甚至连一些常见的概念都不是很清晰,仅仅会使用Maven构建项目,引入依赖,打包等最基础的操作,所以连忙补补课,成功完成......
  • 深入研究java.lang.ThreadLocal类
    Synchronized用于线程间的数据共享,而ThreadLocal则用于线程间的数据隔离。一、概述ThreadLocal是什么呢?其实ThreadLocal并非是一个线程的本地实现版本,它并不是一个Thread,而是threadlocalvariable(线程局部变量)。也许把它命名为ThreadLocalVar更加合适。线程局部变量(ThreadLocal)......