1. 什么是ThreadLocal?
线程局部变量(通常,ThreadLocal变量是private static修饰的,此时ThreadLocal变量相当于成为了线程内部的全局变量)
2. 使用场景
变量在线程内部共享,线程间无关
再具体点,可以分为两类:
- 单例的对象中static属性,线程内共享,线程间无关;
- 工具类属性,线程内共享,线程间无关。
为什么这么说呢?下面看4个问题:
(1)对象为什么要是单例的?
如果对象不是单例的,那么大可以每次都new一个对象,然后对用到属性赋值就行,代码如下:
public class Service {
private String key;
void A() {
// 代码实现,中间用到key
}
void B() {
// 代码实现,中间用到key
}
// 省略get和set方法
}
在使用时,每个线程都new Service(),并对key赋值,然后调用其中的方法就行了,保证方法A和B用的key都是一个值。
(2)单例对象的属性共享
如果希望单例对象中的某个属性可以被共享,那么将属性声明为static就行了:
public class Service {
private static String key;
// 省略其他方法
}
上面的实现确实保证了所有方法都能使用key,然而,在多线程环境下,key是不安全的。
(3)单例对象在线程内属性共享,不同线程间相互不影响
这就轮到ThreadLocal上场了:
public class Service {
private static ThreadLocal<String> key = new ThreadLocal<String>() {
protected String initialValue() {
return Thread.currentThread().getName();
}
};
public void A() {
System.out.println("methodA: " + key.get());
key.set("methodA: " + key.get());
}
public void B() {
System.out.println("methodB: " + key.get());
}
}
使用方式:
public class ThreadLocalTest {
public static void main(String[] args) {
final Service service = new Service(); //模拟单例对象的使用
new Thread(new Runnable() {
@Override
public void run() {
service.A();
service.B();
}
}).start();
new Thread(new Runnable() {
@Override
public void run() {
service.A();
service.B();
}
}).start();
}
}
运行结果:
methodA: Thread-0
methodB: methodA: Thread-0
methodA: Thread-1
methodB: methodA: Thread-1
(4)工具类中线程共享,线程间无关
工具类的代码:
public final class XUtil {
private static ThreadLocal<String> key = new ThreadLocal<String>();
private XUtil() {
}
public static void A() {
// 实现
}
public static void B() {
// 实现
}
}
在使用XUtil时,每个线程中key可以使用,不同线程间不受影响。
3. ThreadLocal的实现原理
为什么一个static的变量(即:类变量)可以做到:线程内共享,线程间无关?
看下ThreadLocal中的get源码:
public T get() {
Thread t = Thread.currentThread();
ThreadLocalMap map = getMap(t);
if(map!=null) {
ThreadLocalMap.Entry e = map.getEntry(this);
if(e!=null)
return (T)e.value;
}
return setInitialValue();
}
关键就在getMap()方法:
ThreadLocalMap getMap(Thread t) {
return t.threadlocals;
}
取的是当前线程内部的threadLocals属性。
查看Thread类:
ThreadLocal.ThreadLocalMap threadLocals = null;
threadLocals是ThreadLocal类中自定义的一个HashMap类。
原来数据就存在当前线程内部,自然就能做到线程内共享,线程间无关了。
接着看下set的源码:
public void set(T value) {
Thread t = Thread.currentThread();
ThreadLocalMap map = getMap();
if(map != null)
map.set(this, value);
else
createMap(t,value);
}
无论是map.set(this, value)还是createMap(t, value),最后都是将数据保存到当前线程中的那个HashMap中:将ThreadLocal变量作为key,value就是要保存的数据。
4. ThreadLocal的内存泄露
在前面看到数据最终是存在线程内部的一个Map中的:
ThreadLocal.ThreadLocalMap threadLocals = null;
且key是ThreadLocal变量的引用,在get方法:
ThreadLocalMap.Entry e = map.getEntry(this); // this为当前对象的引用
当ThreadLocal变量被销毁时,而当前线程又持有ThreadLocal的引用,那么ThreadLocal就不会被回收,导致内存泄露。
然而,编写JDK的大牛们考虑到了这个问题,因此将ThreadLocalMap的key设置为弱引用:
static class ThreadLocalMap {
static class Entry extends WeakReference<ThreadLocal> {
Object value;
Entry(ThreadLocal k, Object v) {
super(k);
value = v;
}
}
}
对ThreadLocal变量的弱引用,在GC时,ThreadLocal变量就会被回收。
于是,在当前线程的本地变量HashMap中,原来ThreadLocal作为key的,现在变成null作为key了,该key-value变得不可访问了,如果当前线程一直不结束,那么value对应的对象就无法释放,也就是发生内存泄露了。
参考文献:
ThreadLocal的使用场景及实现原理的更多相关文章
-
etcd:从应用场景到实现原理的全方位解读 转自infoq
转自 infoq etcd:从应用场景到实现原理的全方位解读 http://www.infoq.com/cn/articles/etcd-interpretation-application-scen ...
-
[转帖]kafka入门:简介、使用场景、设计原理、主要配置及集群搭建
kafka入门:简介.使用场景.设计原理.主要配置及集群搭建 http://www.aboutyun.com/thread-9341-1-1.html 还没看完 感觉挺好的. 问题导读: 1.zook ...
-
ThreadLocal的使用场景分析
目录 一.ThreadLocal介绍 二.使用场景1——数据库事务问题 2.1 问题背景 2.2 方案1-修改接口传参 2.3 方案2-使用ThreadLocal 三.使用场景2——日志追踪问题 四. ...
-
volatile、ThreadLocal的使用场景和原理
并发编程中的三个概念 原子性 一个或多个操作.要么全部执行完成并且执行过程不会被打断,要么不执行.最常见的例子:i++/i--操作.不是原子性操作,如果不做好同步性就容易造成线程安全问题. 可见性 多 ...
-
Java并发编程原理与实战二十五:ThreadLocal线程局部变量的使用和原理
1.什么是ThreadLocal ThreadLocal顾名思义是线程局部变量.这种变量和普通的变量不同,这种变量在每个线程中通过get和set方法访问, 每个线程有自己独立的变量副本.线程局部变量不 ...
-
面试官:ThreadLocal的应用场景和注意事项有哪些?
前言 ThreadLocal主要有如下2个作用 保证线程安全 在线程级别传递变量 保证线程安全 最近一个小伙伴把项目中封装的日期工具类用在多线程环境下居然出了问题,来看看怎么回事吧 日期转换的一个工具 ...
-
kafka入门:简介、使用场景、设计原理、主要配置及集群搭建(转)
问题导读: 1.zookeeper在kafka的作用是什么? 2.kafka中几乎不允许对消息进行"随机读写"的原因是什么? 3.kafka集群consumer和producer状 ...
-
ThreadLocal的设计与使用(原理篇)
在jdk1.2推出时开始支持java.lang.ThreadLocal.在J2SE5.0中的声明为: public class ThreadLocal<T> exte ...
-
memcache的应用场景和实现原理
面临的问题 对于高并发高访问的 Web应用程序来说,数据库存取瓶颈一直是个令人头疼的问题.特别当你的程序架构还是建立在单数据库模式,而一个数据池连接数峰 值已经达到500的时候,那你的程序运行离崩溃的 ...
随机推荐
-
Beta阶段第四次Scrum Meeting
情况简述 Beta阶段第四次Scrum Meeting 敏捷开发起始时间 2016/12/13 24:00 敏捷开发终止时间 2016/12/14 24:00 会议基本内容摘要 进度平稳推进,分配新任 ...
-
用typedef自定义类型语法你真的会吗
关于typedef 我们学习typedef的时候,他的定义语法是:typedef+类型+别名,但是按照上面的格式,自定义数组怎么定义呢,是这样tepedef int a[10] 别名?还是这样tep ...
-
IDF实验室WORD隐写术
上帝也哭泣http://ctf.idf.cn/index.php?g=game&m=article&a=index&id=48 下载下来,发现是一个word文档,看来信息应该就 ...
-
vultr使用snapshots系统镜像备份安装vps
vultr vps提供免费的snapshots功能,把你的vps做成镜像备份,在必要的时候可以恢复.如果你要配置多台机器,使用Snapshots非常方便好用. vultr添加snapshots很简单, ...
-
Javascript中的 “&;” 和 “|” 你知多少?
.v-top { position: relative; top: -5px; font-size: 12px } 一.前言: 在文章开始之前,先出几个题目给大家看看: var num1 = 1 &a ...
-
通过cmd命令,杀掉占用端口号的进程
错误问题:[Error running public: Unable to open debugger port (127.0.0.1:53110): java.net.BindException & ...
-
es6 语法 (函数扩展)
//函数参数默认值(more值后不能有参数) { function test(x,y = 'world'){ console.log('默认值',x,y); } test('hello');// he ...
-
IndexedDB 教程
IndexedDB 教程 IndexedDB 是一个基于 JavaScript 的面向对象的事务型数据库.有了 LocalStorage 和 Cookies,为什么还要推出 indexedDB 呢?其 ...
-
M1/M2阶段总结
之前提问的博客 问题解答 问题 1 关于代码复审,复审者是否应该参与编码?如果复审者也参与编码的话,那么难免任务量较多,但如果不参与编码的话,工作分配的似乎不太均衡. 我们的团队项目在M1和M2阶段没 ...
-
Codeforces Round #529 (Div. 3) 题解
生病康复中,心情很不好,下午回苏州. 刷了一套题散散心,Div 3,全部是 1 A,感觉比以前慢了好多好多啊. 这几天也整理了一下自己要做的事情,工作上要努力... ... 晚上还是要认认真真背英语的 ...