当前位置:网站首页>为什么 ThreadLocal 可以做到线程隔离?
为什么 ThreadLocal 可以做到线程隔离?
2022-07-28 07:16:00 【JavaShark】
对于 ThreadLocal 我们都不陌生,它的作用如同它的名字——用于存放「线程本地」变量。
先通过一个小例子感受一下:
private static final ThreadLocal<String> threadLocal = new ThreadLocal<>();
public static void main(String[] args) throws Throwable {
Thread threadOne = new Thread(()->{
threadLocal.set("ThreadOne:" + Thread.currentThread().getName());
log.info("线程 One 本地变量值为:{}", threadLocal.get());
threadLocal.remove();
log.info("线程 One remove 后本地变量值为:{}", threadLocal.get());
});
Thread threadTwo = new Thread(()->{
threadLocal.set("ThreadTwo:" + Thread.currentThread().getName());
log.info("线程 Two 本地变量值为:{}", threadLocal.get());
});
threadOne.start();
threadTwo.start();
}运行结果:
线程 One 本地变量值为:ThreadOne:Thread-0
线程 One remove 后本地变量值为:null
线程 Two 本地变量值为:ThreadTwo:Thread-1
OK,从效果上看,ThreadLocal 确实是线程隔离的,那么,它是如何做到线程隔离的呢?下面我们扒一扒源码,看看它是如何做到的:
public void set(T value) {
Thread t = Thread.currentThread();
ThreadLocalMap map = getMap(t);
if (map != null)
map.set(this, value);
else
createMap(t, value);
}set() 方法的逻辑如下:
- 获取当前线程
- 根据当前线程获取一个 ThreadLocalMap 对象
- 如果 map 不为 null 则保存
- 如果 map 为 null 则创建一个 map
getMap() 和 createMap() 方法都干了啥呢?我们点进去看:
ThreadLocalMap getMap(Thread t) {
return t.threadLocals;
}
void createMap(Thread t, T firstValue) {
t.threadLocals = new ThreadLocalMap(this, firstValue);
}进入到两个方法内部后发现,不管执行哪个分支,最终是把值保存到了当前线程的 threadLocals 属性中。
查看 Thread 类的源码,你会发现类中定义了一个 threadLocals 属性,且初始值为 null,其类型为ThreadLocal.ThreadLocalMap。
public class Thread implements Runnable {
// ...
ThreadLocal.ThreadLocalMap threadLocals = null;
// ...
}到此,我们发现了,原来 ThreadLocal 就是把我们要传递的对象放到了当前线程的 threadLocals 属性中。也就是说每个线程在用 ThreadLocal 保存对象时,其实就是将对象放到了当前线程实例对象的 threadLocals 属性里面。这样一来线程之间自然就是互相独立的啦。
再看看 get() 方法:
public T get() {
Thread t = Thread.currentThread();
ThreadLocalMap map = getMap(t);
if (map != null) {
ThreadLocalMap.Entry e = map.getEntry(this);
if (e != null) {
@SuppressWarnings("unchecked")
T result = (T)e.value;
return result;
}
}
return setInitialValue();
}
private T setInitialValue() {
T value = initialValue();
Thread t = Thread.currentThread();
ThreadLocalMap map = getMap(t);
if (map != null)
map.set(this, value);
else
createMap(t, value);
return value;
}ThreadLocal 的 get() 方法其实和 set() 方法逻辑很相似,先从当前线程的 threadLocals 属性中取,如果该属性为 null,那么就初始化。
当线程结束时,会调用当前线程实例的 exit() 方法,将 threadLocals 设置为 null,以便垃圾回收器将其回收掉。
// THread 类中的方法
private void exit() {
// ...
threadLocals = null;
// ...
}最后,有一点需要格外注意:用完 ThreadLocal 一定要记得手动调用 remove() 方法,否则可能会产生脏数据甚至产生内存泄漏。
为啥呢?上面不是说线程结束时,会将 threadLocals 置为 null 吗?
是的,线程结束时,确实会做清理工作。
但,如果线程一直不结束呢?如果线程会被复用呢?比如使用了线程池。
所以,使用 ThreadLocal 一定要手动 remove()。
边栏推荐
- Characteristics of EMC EMI beads
- Pyflink connecting iceberg practice
- MySQL how to add users and set permissions?
- Js继承方法
- Three different numbers with 0 in leetcode/ array
- 中标捷报!南大通用GBase 8s中标南瑞集团2022年数据库框架项目
- Day112.尚医通:手机验证码登录功能
- tkMapper的使用-超详细
- Analysis of model predictive control (MPC) (IX): numerical solution of quadratic programming (II)
- Simple use of unity queue
猜你喜欢
随机推荐
Use of namespaces
半桥BUCK电路—记录篇
C轮融资已完成!思迈特软件领跑国内BI生态赋能,产品、服务竿头一步
说透缓存一致性与内存屏障
pyflink连接iceberg 实践
tkMapper的使用-超详细
Mysql-怎么添加用户和设置权限?
Pyspark writes data to iceberg
postgresql查询【表字段类型】和库中【所有序列】
GBASE亮相联通云巡展(四川站) 以专业赋能云生态
Vk1620 temperature controller / smart meter LED digital display driver chip 3/4-wire interface with built-in RC oscillator to provide technical support
The current value of uniapp's swiper dynamic setting does not take effect solution
JS inheritance method
5张图告诉你:同样是职场人,差距怎么这么大?
leetcode/数组中和为0的三个不同数
Hcip day 9_ BGP experiment
Shell编程规范与变量
优炫数据库导入和导出方法
本人男,27岁技术经理,收入太高,心头慌得一比
Uniapp ---- detailed steps to obtain the longitude and latitude of the current position and other information (including applet)
![[mindspire YiDianTong robot-01] you may have seen many Knowledge Q & A robots, but this is a little different](/img/d1/c2c2e4a605deddd0073a05d528733f.jpg)








