ThreadLocal導(dǎo)致JVM內(nèi)存泄漏原因探究
為什么要使用ThreadLocal
在一整個(gè)業(yè)務(wù)邏輯流程中,為了在不同的地方或者不同的方法中使用同一個(gè)對(duì)象,但是又不想在方法形參中加這個(gè)對(duì)象,那么就可以使用ThreadLocal來(lái)保存
ThreadLocal最大的應(yīng)用場(chǎng)景就是跨方法進(jìn)行參數(shù)傳遞
ThreadLocal可以給每一個(gè)線程綁定一個(gè)變量的副本
使用ThreadLocal
ThreadLocal常用的方法其實(shí)也就下面幾個(gè)
// 返回當(dāng)前線程所對(duì)應(yīng)的線程局部變量。
public T get() {}
// 設(shè)置當(dāng)前線程的線程局部變量的值。
public void set(T value) {}
// 移除,當(dāng)線程結(jié)束后,該線程thread對(duì)象中的局部變量將在下一次gc時(shí)回收,如果顯示的調(diào)用此方法只是可以加快內(nèi)存回收的速度
// 所以javase開(kāi)發(fā) 普通new Thread()方式中,這個(gè)方法并不是必須要調(diào)用的
// 但是javaWeb開(kāi)發(fā)中就必須顯示調(diào)用,因?yàn)閖avaweb都是使用的線程池,并不是一個(gè)客戶端來(lái)一個(gè)請(qǐng)求,thread線程對(duì)象用完就刪除,而是會(huì)放回線程池中。
public void remove() {}
// 返回該線程局部變量的一個(gè)初始化
// protected方法,顯然是為了讓子類覆蓋而設(shè)計(jì)的。這個(gè)方法在第一次調(diào)用 get()或 set(Object)時(shí)才執(zhí)行,并且僅執(zhí)行 1 次
protected T initialValue() {}
在具體使用的時(shí)候,我們ThreadLocal對(duì)象一定會(huì)定義成靜態(tài)的,如果不定義成靜態(tài)的那么其他地方如何通過(guò)這個(gè)ThreadLocal實(shí)例去Map中拿數(shù)據(jù)嘞?
而且如果是多個(gè)線程保存一個(gè)變量的副本,一個(gè)靜態(tài)的ThreadLocal也足夠了,因?yàn)樗亲鳛槎鄠€(gè)map中的key存在的
簡(jiǎn)單使用案例
/**
* @Description: 在一個(gè)方法中調(diào)用set()方法存值,在另一個(gè)方法中調(diào)用get()方法取值
*/
public class UseThreadLocalTest {
public static ThreadLocal<String> threadLocal = new ThreadLocal<>();
/**
* 創(chuàng)建一個(gè)線程類
*/
public static class ThreadTest extends Thread{
private Integer id;
ThreadTest(Integer id){
this.id = id;
}
@Override
public void run() {
threadLocal.set(Thread.currentThread().getName() + ":" + id);
print();
}
public void print(){
System.out.println(threadLocal.get());
}
}
/**
* 開(kāi)三個(gè)線程
*/
public static void main(String[] args) {
for (int i = 0; i < 3; i++) {
new ThreadTest(i).start();
}
}
}
// 輸入結(jié)果如下
Thread-0:0
Thread-1:1
Thread-2:2
具體實(shí)現(xiàn)
ThreadLocal底層set()和get()方法的源碼如下
// 存值時(shí) map最終是存儲(chǔ)在當(dāng)前線程Thread t = Thread.currentThread()中的,是thread的一個(gè)成員變量
// map的key是當(dāng)前threadLocal對(duì)象實(shí)例,value是要存的值
public void set(T value) {
Thread t = Thread.currentThread();
ThreadLocalMap map = getMap(t);
if (map != null)
map.set(this, value);
else
createMap(t, value);
}
// 取值時(shí)也是也是先從當(dāng)前線程Thread對(duì)象中取出map
// 然后在從map中根據(jù)當(dāng)前threadLocal對(duì)象實(shí)例作為key獲取到entry對(duì)象
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();
}
為了提高性能,才沒(méi)有采用加鎖的方式,而是將map和各個(gè)線程thread對(duì)象進(jìn)行關(guān)聯(lián),這樣就避免了產(chǎn)生線程安全問(wèn)題,也避免了加鎖,提高了性能
我們接下來(lái)再來(lái)看看ThreadLocalMap它的實(shí)現(xiàn),它類似于jdk1.7版本的hashmap,底層存儲(chǔ)的是一個(gè)Entry對(duì)象的數(shù)組,初始容量也是16,存值時(shí)先用hash結(jié)果和數(shù)組長(zhǎng)度取余得到數(shù)組下標(biāo)位置,然后判斷是否產(chǎn)生了hash沖突,然后使用開(kāi)發(fā)定址法來(lái)處理。根據(jù)算法的不同又可以分為線性探測(cè)再散列、二次探測(cè)再散列、偽隨機(jī)探測(cè)再散列。ThreadLocalMap它是使用的線性探測(cè)再散列法,如下所示
private static int nextIndex(int i, int len) {
return ((i + 1 < len) ? i + 1 : 0);
}
Entry對(duì)象中的key它是一個(gè)弱引用,Entry繼承了WeakReference類,弱引用跟沒(méi)引用差不多,GC會(huì)直接回收掉,不管內(nèi)存是否足夠都會(huì)回收
static class Entry extends WeakReference<ThreadLocal<?>> {
Object value;
Entry(ThreadLocal<?> k, Object v) {
super(k);
value = v;
}
}
引發(fā)內(nèi)存泄漏的原因
上面再介紹ThreadLocal基本使用api方法的時(shí)候也提到了,如果只是創(chuàng)建一個(gè)普通的線程Thread對(duì)象,是不會(huì)產(chǎn)生內(nèi)存泄漏問(wèn)題的。因?yàn)閙ap是存儲(chǔ)在Thread對(duì)象中,一個(gè)普通線程執(zhí)行完了,那么這個(gè)線程的局部變量也就會(huì)被gc回收。
但如果結(jié)合到了線程池,一個(gè)Thread線程對(duì)象用完后放回線程池中,如果這個(gè)時(shí)候我們程序不顯示的調(diào)用remove()方法,那么就會(huì)造成內(nèi)存泄漏問(wèn)題了。
因?yàn)镋ntry對(duì)象中的Key的弱引用,但是value還會(huì)存在,就會(huì)存在map中key為null的value
ThreadLocal 的底層實(shí)現(xiàn)中我們可以看見(jiàn),無(wú)論是 get()、set()在某些時(shí) 候,調(diào)用了 expungeStaleEntry() 方法用來(lái)清除 Entry 中 Key 為 null 的 Value,但是這是不及時(shí)的,也不是每次都會(huì)執(zhí)行的,所以一些情況下還是會(huì)發(fā)生內(nèi)存泄露。
到此這篇關(guān)于ThreadLocal導(dǎo)致JVM內(nèi)存泄漏原因探究的文章就介紹到這了,更多相關(guān)JVM內(nèi)存泄漏內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!
相關(guān)文章
Spring Cloud如何切換Ribbon負(fù)載均衡模式
這篇文章主要介紹了Spring Cloud如何切換Ribbon負(fù)載均衡模式,文中通過(guò)示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下2019-12-12
java ReentrantLock條件鎖實(shí)現(xiàn)原理示例詳解
這篇文章主要為大家介紹了java ReentrantLock條件鎖實(shí)現(xiàn)原理示例詳解,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進(jìn)步,早日升職加薪2023-01-01
Mybatis plus的自動(dòng)填充與樂(lè)觀鎖的實(shí)例詳解(springboot)
這篇文章主要介紹了Mybatis plus的自動(dòng)填充與樂(lè)觀鎖的實(shí)例詳解(springboot),本文給大家介紹的非常詳細(xì)對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值,需要的朋友可以參考下2020-11-11
Java 語(yǔ)言實(shí)現(xiàn)清除帶 html 標(biāo)簽的內(nèi)容方法
下面小編就為大家?guī)?lái)一篇Java 語(yǔ)言實(shí)現(xiàn)清除帶 html 標(biāo)簽的內(nèi)容方法。小編覺(jué)得挺不錯(cuò)的,現(xiàn)在就分享給大家,也給大家做個(gè)參考。一起跟隨小編過(guò)來(lái)看看吧2017-02-02
在SpringBoot中使用UniHttp簡(jiǎn)化天地圖路徑規(guī)劃調(diào)用實(shí)踐記錄(場(chǎng)景分析)
本文介紹了如何在SpringBoot項(xiàng)目中使用UniHttp簡(jiǎn)化天地圖路徑規(guī)劃接口的調(diào)用,通過(guò)一個(gè)具體的例子展示了如何根據(jù)中文地址獲取經(jīng)緯度坐標(biāo),并使用UniHttp調(diào)用天地圖路徑規(guī)劃服務(wù),感興趣的朋友一起看看吧2025-02-02
Springboot集成magic-api的詳細(xì)過(guò)程
這篇文章主要介紹了Springboot集成magic-api的相關(guān)知識(shí),本文結(jié)合實(shí)例代碼給大家介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值,需要的朋友可以參考下2023-06-06
Spring security用戶URL權(quán)限FilterSecurityInterceptor使用解析
這篇文章主要介紹了Spring security用戶URL權(quán)限FilterSecurityInterceptor使用解析,文中通過(guò)示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下2019-12-12

