如何使用ThreadLocal来避免内存泄漏

电子说

1.2w人已加入

描述

本次给大家介绍重要的工具ThreadLocal。讲解内容如下,同时介绍什么场景下发生内存泄漏,如何复现内存泄漏,如何正确使用它来避免内存泄漏。

ThreadLocal是什么?有哪些用途?

ThreadLocal如何使用

ThreadLocal原理

ThreadLocal使用有哪些坑及注意事项

Part1ThreadLocal是什么?有哪些用途?

首先介绍Thread类中属性threadLocals:

/* ThreadLocal values pertaining to this thread.

This map is maintained * by the ThreadLocal class. */

ThreadLocal.ThreadLocalMap threadLocals = null;

我们发现Thread并没有提供成员变量threadLocals的设置与访问的方法,那么每个线程的实例threadLocals参数我们如何操作呢?这时我们的主角:ThreadLocal就登场了。

所以有那么一句总结:

ThreadLocal是线程Thread中属性threadLocals的管理者。

也就是说我们对于ThreadLocal的get, set,remove的操作结果都是针对当前线程Thread实例的threadLocals存,取,删除操作。类似于一个开发者的任务,产品经理左右不了,产品经理只能通过技术leader来给开发者分配任务。

下面再举个栗子,进一步说明他们之间的关系:

1. 每个人都一张银行卡

每个人每张卡都有一定的余额。

每个人获取银行卡余额都必须通过该银行的管理系统。

每个人都只能获取自己卡持有的余额信息,他人的不可访问。

映射到我们要说的ThreadLocal

card类似于Thread

card余额属性,卡号属性等类似于Treadlocal内部属性集合threadLocals

cardManager类似于ThreadLocal管理类

那ThreadLocal有哪些应用场景呢?

其实我们无意间已经时时刻刻在使用ThreadLocal提供的便利,如果说多数据源的切换你比较陌生,那么spring提供的声明式事务就再熟悉不过了,我们在研发过程中无时无刻不在使用,而spring声明式事务的重要实现基础就是ThreadLocal,只不过大家没有去深入研究spring声明式事务的实现机制。后面有机会我会给大家介绍spring声明式事务的原理及实现机制。

原来ThreadLocal这么强大,但应用开发者使用较少,同时有些研发人员对于ThreadLocal内存泄漏,等潜在问题,不敢试用,恐怕这是对于ThreadLocal最大的误解,后面我们将会仔细分析,只要按照正确使用方式,就没什么问题。如果ThreadLocal存在问题,岂不是spring声明式事务是我们程序最大的潜在危险吗?

Part2ThreadLocal如何使用

为了更直观的体会ThreadLocal的使用我们假设如下场景

我们给每个线程生成一个ID。

一旦设置,线程生命周期内不可变化。

容器活动期间不可以生成重复的ID

我们创建一个ThreadLocal管理类:

内存

测试程序如下:我们同一个线程不断get,测试id是否变化,同时测试完成后我们就将其释放掉。

内存

在主程序中我们开启多个线程测试不通线程之间是否会影响

内存

不出意外我们的结果为:

内存

结果:确实是不同线程间id不同,相同线程id相同。

Part3ThreadLocal原理

①ThreadLocal类结构及方法解析:

内存

上图可知:ThreadLocal三个方法get, set , remove以及内部类ThreadLocalMap

②ThreadLocal及Thread之间的关系:

内存

从这张图我们可以直观的看到Thread中属性threadLocals,作为一个特殊的Map,它的key值就是我们ThreadLocal实例,而value值这是我们设置的值。

③ThreadLocal的操作过程:

我们以get方法为例:

内存

其中getMap(t)返回的就上当前线程的threadlocals,如下图,然后根据当前ThreadLocal实例对象作为key获取ThreadLocalMap中的value,如果首次进来这调用setInitialValue()

内存

内存

set的过程也类似:

内存

注意:ThreadLocal中可以直接t.threadLocals是因为Thread与ThreadLocal在同一个包下,同样Thread可以直接访问ThreadLocal.ThreadLocalMap threadLocals = null;来进行声明属性。另外,欢迎关注公众号Java笔记虾,后台回复“后端面试”,送你一份面试题宝典!

Part4ThreadLocal使用有哪些坑及注意事项

我经常在网上看到骇人听闻的标题,ThreadLocal导致内存泄漏,这通常让一些刚开始对ThreadLocal理解不透彻的开发者,不敢贸然使用。越不用,越陌生。这样就让我们错失了更好的实现方案,所以敢于引入新技术,敢于踩坑,才能不断进步。

我们来看下为什么说ThreadLocal会引起内存泄漏,什么场景下会导致内存泄漏?

先回顾下什么叫内存泄漏,对应的什么叫内存溢出

Memory overflow:内存溢出,没有足够的内存提供申请者使用。

Memory leak:内存泄漏,程序申请内存后,无法释放已申请的内存空间,内存泄漏的堆积终将导致内存溢出。

显然是TreadLocal在不规范使用的情况下导致了内存没有释放。

内存

红框里我们看到了一个特殊的类WeakReference,同样这个类,应用开发者也同样很少使用,这里简单介绍下吧

内存

既然WeakReference在下一次gc即将被回收,那么我们的程序为什么没有出问题呢?

①所以我们测试下弱引用的回收机制:

内存

这一种存在强引用不会被回收。

内存

这里没有强引用将会被回收。

上面演示了弱引用的回收情况,下面我们看下ThreadLocal的弱引用回收情况。

②ThreadLocal的弱引用回收情况

内存

如上图所示,我们在作为key的ThreadLocal对象没有外部强引用,下一次gc必将产生key值为null的数据,若线程没有及时结束必然出现,一条强引用链Threadref–》Thread–》ThreadLocalMap–》Entry,所以这将导致内存泄漏。

下面我们模拟复现ThreadLocal导致内存泄漏:

1.为了效果更佳明显我们将我们的treadlocals的存储值value设置为1万字符串的列表:

class ThreadLocalMemory {

// Thread local variable containing each thread‘s ID

public ThreadLocal《List《Object》》 threadId = new ThreadLocal《List《Object》》() {

@Override

protected List《Object》 initialValue() {

List《Object》 list = new ArrayList《Object》();

for (int i = 0; i 《 10000; i++) {

list.add(String.valueOf(i));

}

return list;

}

};

// Returns the current thread’s unique ID, assigning it if necessary

public List《Object》 get() {

return threadId.get();

}

// remove currentid

public void remove() {

threadId.remove();

}

}

测试代码如下:

public static void main(String[] args)

throws InterruptedException {

// 为了复现key被回收的场景,我们使用临时变量

ThreadLocalMemory memeory = new ThreadLocalMemory();

// 调用

incrementSameThreadId(memeory);

System.out.println(“GC前:key:” + memeory.threadId);

System.out.println(“GC前:value-size:” + refelectThreadLocals(Thread.currentThread()));

// 设置为null,调用gc并不一定触发垃圾回收,但是可以通过java提供的一些工具进行手工触发gc回收。

memeory.threadId = null;

System.gc();

System.out.println(“GC后:key:” + memeory.threadId);

System.out.println(“GC后:value-size:” + refelectThreadLocals(Thread.currentThread()));

// 模拟线程一直运行

while (true) {

}

}

此时我们如何知道内存中存在memory leak呢?

我们可以借助jdk提供的一些命令dump当前堆内存,命令如下:

jmap -dump:live,format=b,file=heap.bin 《pid》

然后我们借助MAT可视化分析工具,来查看对内存,分析对象实例的存活状态:

首先打开我们工具提示我们的内存泄漏分析:

这里我们可以确定的是ThreadLocalMap实例的Entry.value是没有被回收的。

最后我们要确定Entry.key是否还在?打开Dominator Tree,搜索我们的ThreadLocalMemory,发现并没有存活的实例。

以上我们复现了ThreadLocal不正当使用,引起的内存泄漏。

文中源码:

https://github.com/z-one/basictest/tree/master/src/main/java/com/spring/test/threadlocal

所以我们总结了使用ThreadLocal时会发生内存泄漏的前提条件:

ThreadLocal引用被设置为null,且后面没有set,get,remove操作。

线程一直运行,不停止。(线程池)

触发了垃圾回收。(Minor GC或Full GC)

我们看到ThreadLocal出现内存泄漏条件还是很苛刻的,所以我们只要破坏其中一个条件就可以避免内存泄漏,单但为了更好的避免这种情况的发生我们使用ThreadLocal时遵守以下两个小原则:

①ThreadLocal申明为private static final。

Private与final 尽可能不让他人修改变更引用,

Static 表示为类属性,只有在程序结束才会被回收。

②ThreadLocal使用后务必调用remove方法。

最简单有效的方法是使用后将其移除。

责任编辑:haq

打开APP阅读更多精彩内容
声明:本文内容及配图由入驻作者撰写或者入驻合作网站授权转载。文章观点仅代表作者本人,不代表电子发烧友网立场。文章及其配图仅供工程师学习之用,如有内容侵权或者其他违规问题,请联系本站处理。 举报投诉

全部0条评论

快来发表一下你的评论吧 !

×
20
完善资料,
赚取积分