摘要:返回索引位置的值。因為依賴于靜態(tài)成員變量的關(guān)系,所以它的肯定唯一獲取當(dāng)前線程。位置還沒有初始化第一次這個,直接將放到的位置。在線程池模式下,生命周期伴隨著線程一直存在,可能出現(xiàn)內(nèi)存泄漏的情況,最好手動調(diào)用方法。
前言本文原創(chuàng)地址,:jsbintask的博客(食用效果最佳),轉(zhuǎn)載請注明出處!
ThreadLocal是jdk中一個非常重要的工具,它可以控制堆內(nèi)存中的對象只能被指定線程訪問,如果你經(jīng)常閱讀源碼,基本在各大框架都能發(fā)現(xiàn)它的蹤影。而它最經(jīng)典的應(yīng)用就是事務(wù)管理,同時它也是面試中的常客。
原理我們知道,堆內(nèi)存是共享的,為什么ThreadLocal能夠控制指定線程訪問呢? 如圖:
調(diào)用ThreadLocal的get方法。
獲取當(dāng)前線程t1.
獲取t1的成員變量ThreadLocalMap。
根據(jù)ThreadLocal的hashcode計算出ThreadLocalMap中Entry[]數(shù)組的索引。
返回索引位置的值。 這樣我們就很容易理解了,為什么只有當(dāng)前線程才能獲取到某些值,因為這是這些值都直接保存在當(dāng)前線程的成員變量ThreadLocalMap中,而ThreadLocal在這個過程中充當(dāng)?shù)慕巧珓t是提供它獨一無二的hashcode值,這樣我們就能計算出我們保存的值在ThreadLocalMap的位置。
我們從構(gòu)建一個ThreadLocal到調(diào)用它的set,get方法完整的分析一遍它的源碼。
構(gòu)造器當(dāng)我們使用new ThreadLocal<>() new一個ThreadLocal對象時,它初始化了一個成員變量threadLocalHashCode,這個成員變量代表當(dāng)前ThreadLocal的hashcode值,而它肯定是唯一的:
ThreadLocal內(nèi)部有一個靜態(tài)hashCode生成器nextHashCode。
每次新new一個ThreadLocal對象,調(diào)用這個生成器同步方法獲取hashcode。 因為依賴于靜態(tài)成員變量nextHashCode的關(guān)系,所以它的hashcode肯定唯一!
public void set(T value) {
Thread t = Thread.currentThread();
ThreadLocalMap map = getMap(t);
if (map != null)
map.set(this, value);
else
createMap(t, value);
}
獲取當(dāng)前線程t。
從t中獲取ThreadLocalMap map。
如果map不為空,將當(dāng)前值value放入map。
如果map為空,新建一個ThreadLocalMap放入線程t。 ThreadLocalMap是ThreadLocal中的內(nèi)部類,它的結(jié)構(gòu)如下:
public class ThreadLocalMap {
static class Entry extends WeakReference<ThreadLocal<");{
Object value;
Entry(ThreadLocal<");super(k);
value = v;
}
}
private Entry[] table;
private int size = 0;
private static final int INITIAL_CAPACITY = 16;
private int threshold; // Default to 0
}
類似于ArrayList內(nèi)部的構(gòu)造,它內(nèi)部有一個Entry數(shù)組table,并且Entry繼承自弱引用(gc時保存的ThreadLocal會被標(biāo)記清理),所以每一個Entry中保存著兩個值,ThreadLocal,value,value既是我們要保存的值。 接著,我們回過頭詳細(xì)分析第三步,ThreadLocalMap的set方法:
private void set(ThreadLocal<"); {
Entry[] tab = table;
int len = tab.length;
int i = key.threadLocalHashCode & (len-1); // 1
for (Entry e = tab[i];
e != null; // 2
e = tab[i = nextIndex(i, len)]) {
ThreadLocal<");if (k == key) { // 3
e.value = value;
return;
}
if (k == null) { // 4
replaceStaleEntry(key, value, i);
return;
}
}
tab[i] = new Entry(key, value); // 5
int sz = ++size;
if (!cleanSomeSlots(i, sz) && sz >= threshold) // 6
rehash();
}
根據(jù)ThreadLocal的hashCode計算出在entry中的索引i。
取出i對應(yīng)的Entry值e。
如果e的key等于當(dāng)前ThreadLocal,代表已經(jīng)有一個一樣的ThreadLocal在這個entry設(shè)值,直接替換這個entry上的value。
e上面的ThreadLocal為null,代表垃圾收集器準(zhǔn)備回收這個Entry了,重新計算數(shù)組大小,重新hash。
i位置還沒有初始化(第一次set這個ThreadLocal),直接將value放到i的位置。
擴容Entry數(shù)組。
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();
}
獲取當(dāng)前線程。
從當(dāng)前線程中獲取ThreadLocalMap
從ThreadLocalMap中找出ThreadLocal對應(yīng)的Entry.
如果Entry不為null,直接返回Entry中的value
返回初始值。
其中,ThreadLocalMap的get(ThreadLocal tl)如下:
從上面的代碼分析中,我們知道,ThreadLocalMap的生命周期和當(dāng)前線程同步,如果當(dāng)前線程被銷毀,則map中的所有引用均被銷毀。但如果當(dāng)前線程不被銷毀呢(線程池,tomcat處理請求等)?Entry中保存了ThreadLocal的弱引用以及value,gc時可能清理掉ThreadLocal,而這個value確再沒有訪問之地,這個時候就會造成內(nèi)存泄漏! 所以我們需要手動調(diào)用remove方法清理掉當(dāng)前線程ThreadLocalMap的引用!
總結(jié)ThreadLocal中真正保存的值還是在線程的ThreadLocalMap中,ThreadLocal只是使用它的hashcode值充當(dāng)中間計算變量。
ThreadLocalMap內(nèi)部使用一個Entry數(shù)組保存數(shù)據(jù),它根據(jù)ThreadLocal計算出來的hashcode得到Entry的索引值,而ThreadLocal的hashcod在其內(nèi)部的靜態(tài)工具類產(chǎn)生,所以不會出現(xiàn)沖突。
在線程池模式下,ThreadLocal生命周期伴隨著線程一直存在,可能出現(xiàn)內(nèi)存泄漏的情況,最好手動調(diào)用remove方法。
關(guān)注我,這里只有干貨!
文章版權(quán)歸作者所有,未經(jīng)允許請勿轉(zhuǎn)載,若此文章存在違規(guī)行為,您可以聯(lián)系管理員刪除。
轉(zhuǎn)載請注明本文地址:http://systransis.cn/yun/7868.html
摘要:多線程類庫對于共享數(shù)據(jù)的讀寫控制主要采用鎖機制保證線程安全,本文所要探究的則采用了一種完全不同的策略。所以出現(xiàn)內(nèi)存泄露的前提必須是持有的線程一直存活,這在使用線程池時是很正常的,在這種情況下一直不會被,因為 Java 多線程類庫對于共享數(shù)據(jù)的讀寫控制主要采用鎖機制保證線程安全,本文所要探究的 ThreadLocal 則采用了一種完全不同的策略。ThreadLocal 不是用來解決共享數(shù)...
摘要:提供了線程安全的共享對象,在編寫多線程代碼時,可把不安全的整個變量封裝進(jìn),或者把該對象與線程相關(guān)的狀態(tài)使用保存并不能替代同步機制,兩者面向的問題領(lǐng)域不同。 ThreadLocal類 使用ThreadLocal類可以簡化多線程編程時的并發(fā)訪問,使用這個工具類可以很簡捷地隔離多線程程序的競爭資源。Java5之后,為ThreadLocal類增加了泛型支持,即ThreadLocal Threa...
摘要:并沒有提供語言級的線程局部變量,而是在類庫里提供了線程局部變量的功能,也就是這次的主角類。 Yuicon 轉(zhuǎn)載請注明原創(chuàng)出處,謝謝! 序 在多線程環(huán)境下,訪問非線程安全的變量時必須進(jìn)行線程同步,例如使用synchronized方式訪問HashMap實例。但是同步訪問會降低并發(fā)性,影響系統(tǒng)性能。這時候就可以用空間換時間,如果我們給每個線程都分配一個獨立的變量,就可以用非同步的方式使用非...
摘要:進(jìn)程一般由程序數(shù)據(jù)集進(jìn)程控制塊三部分組成。線程概述線程的出現(xiàn)是為了降低上下文切換的消耗,提高系統(tǒng)的并發(fā)性。線程突破了一個進(jìn)程只能干一件事的缺陷,使到進(jìn)程內(nèi)并發(fā)成為可能。進(jìn)程與線程的關(guān)系進(jìn)程是計算機中的程序關(guān)于某數(shù)據(jù)集合上的一次運行活動。 進(jìn)程概述 進(jìn)程:正在運行的程序,是系統(tǒng)進(jìn)行資源分配和調(diào)用的獨立單位。 進(jìn)程就是一個程序在一個數(shù)據(jù)集上的一次動態(tài)執(zhí)行過程。 進(jìn)程一般由程序、數(shù)據(jù)集、進(jìn)...
閱讀 927·2021-09-22 15:17
閱讀 1964·2021-09-22 15:06
閱讀 2255·2021-09-08 09:35
閱讀 5187·2021-09-01 11:43
閱讀 3506·2019-08-30 15:55
閱讀 2181·2019-08-30 12:48
閱讀 3191·2019-08-30 12:45
閱讀 1808·2019-08-29 17:31