拋出這8個(gè)問題,檢驗(yàn)一下你到底會(huì)不會(huì)ThreadLocal,來摸個(gè)底~
0、問題
- 和Synchronized的區(qū)別
- 存儲(chǔ)在jvm的哪個(gè)區(qū)域
- 真的只是當(dāng)前線程可見嗎
- 會(huì)導(dǎo)致內(nèi)存泄漏么
- 為什么用Entry數(shù)組而不是Entry對(duì)象
- 你學(xué)習(xí)的開源框架哪些用到了ThreadLocal
- ThreadLocal里的對(duì)象一定是線程安全的嗎
- 筆試題
一、概述
1、官方術(shù)語
ThreadLocal類是用來提供線程內(nèi)部的局部變量。讓這些變量在多線程環(huán)境下訪問(get/set)時(shí)能保證各個(gè)線程里的變量相對(duì)獨(dú)立于其他線程內(nèi)的變量。
2、大白話
ThreadLocal是一個(gè)關(guān)于創(chuàng)建線程局部變量的類。
通常情況下,我們創(chuàng)建的成員變量都是線程不安全的。因?yàn)樗赡鼙欢鄠€(gè)線程同時(shí)修改,此變量對(duì)于多個(gè)線程之間彼此并不獨(dú)立,是共享變量。而使用ThreadLocal創(chuàng)建的變量只能被當(dāng)前線程訪問,其他線程無法訪問和修改。也就是說:將線程公有化變成線程私有化。
二、應(yīng)用場景
- 每個(gè)線程都需要一個(gè)獨(dú)享的對(duì)象(比如工具類,典型的就是SimpleDateFormat,每次使用都new一個(gè)多浪費(fèi)性能呀,直接放到成員變量里又是線程不安全,所以把他用ThreadLocal管理起來就完美了。)
比如:
- /**
- * Description: SimpleDateFormat就一份,不浪費(fèi)資源。
- *
- * @author TongWei.Chen 2020-07-10 14:00:29
- */
- public class ThreadLocalTest05 {
- public static String dateToStr(int millisSeconds) {
- Date date = new Date(millisSeconds);
- SimpleDateFormat simpleDateFormat = ThreadSafeFormatter.dateFormatThreadLocal.get();
- return simpleDateFormat.format(date);
- }
- private static final ExecutorService executorService = Executors.newFixedThreadPool(100);
- public static void main(String[] args) {
- for (int i = 0; i < 3000; i++) {
- int j = i;
- executorService.execute(() -> {
- String date = dateToStr(j * 1000);
- // 從結(jié)果中可以看出是線程安全的,時(shí)間沒有重復(fù)的。
- System.out.println(date);
- });
- }
- executorService.shutdown();
- }
- }
- class ThreadSafeFormatter {
- public static ThreadLocal<SimpleDateFormat> dateFormatThreadLocal = new ThreadLocal() {
- @Override
- protected SimpleDateFormat initialValue() {
- return new SimpleDateFormat("yyyy-MM-dd hh:mm:ss");
- }
- };
- // java8的寫法,裝逼神器
- // public static ThreadLocal<SimpleDateFormat> dateFormatThreadLocal =
- // ThreadLocal.withInitial(() -> new SimpleDateFormat("yyyy-MM-dd hh:mm:ss"));
- }
細(xì)心的朋友已經(jīng)發(fā)現(xiàn)了,這TM也是每個(gè)線程都創(chuàng)建一個(gè)SimpleDateFormat啊,跟直接在方法內(nèi)部new沒區(qū)別,錯(cuò)了,大錯(cuò)特錯(cuò)!1個(gè)請(qǐng)求進(jìn)來是一個(gè)線程,他可能貫穿了N個(gè)方法,你這N個(gè)方法假設(shè)有3個(gè)都在使用dateToStr(),你直接new的話會(huì)產(chǎn)生三個(gè)SimpleDateFormat對(duì)象,而用ThreadLocal的話只會(huì)產(chǎn)生一個(gè)對(duì)象,一個(gè)線程一個(gè)。
- 每個(gè)線程內(nèi)需要保存全局變量(比如在登錄成功后將用戶信息存到ThreadLocal里,然后當(dāng)前線程操作的業(yè)務(wù)邏輯直接get取就完事了,有效的避免的參數(shù)來回傳遞的麻煩之處),一定層級(jí)上減少代碼耦合度。
再細(xì)化一點(diǎn)就是:
- 比如存儲(chǔ) 交易id等信息。每個(gè)線程私有。
- 比如aop里記錄日志需要before記錄請(qǐng)求id,end拿出請(qǐng)求id,這也可以。
- 比如jdbc連接池(很典型的一個(gè)ThreadLocal用法)
- ....等等....
三、核心知識(shí)
1、類關(guān)系
每個(gè)Thread對(duì)象中都持有一個(gè)ThreadLocalMap的成員變量。每個(gè)ThreadLocalMap內(nèi)部又維護(hù)了N個(gè)Entry節(jié)點(diǎn),也就是Entry數(shù)組,每個(gè)Entry代表一個(gè)完整的對(duì)象,key是ThreadLocal本身,value是ThreadLocal的泛型值。
核心源碼如下
- // java.lang.Thread類里持有ThreadLocalMap的引用
- public class Thread implements Runnable {
- ThreadLocal.ThreadLocalMap threadLocals = null;
- }
- // java.lang.ThreadLocal有內(nèi)部靜態(tài)類ThreadLocalMap
- public class ThreadLocal<T> {
- static class ThreadLocalMap {
- private Entry[] table;
- // ThreadLocalMap內(nèi)部有Entry類,Entry的key是ThreadLocal本身,value是泛型值
- static class Entry extends WeakReference<ThreadLocal<?>> {
- Object value;
- Entry(ThreadLocal<?> k, Object v) {
- super(k);
- vvalue = v;
- }
- }
- }
- }
2、類關(guān)系圖
ThreadLocal內(nèi)存結(jié)構(gòu)圖。
3、主要方法
- initialValue:初始化。在get方法里懶加載的。
- get:得到這個(gè)線程對(duì)應(yīng)的value。如果調(diào)用get之前沒set過,則get內(nèi)部會(huì)執(zhí)行initialValue方法進(jìn)行初始化。
- set:為這個(gè)線程設(shè)置一個(gè)新值。
- remove:刪除這個(gè)線程對(duì)應(yīng)的值,防止內(nèi)存泄露的最佳手段。
3.1、initialValue
3.1.1、什么意思
見名知意,初始化一些value(泛型值)。懶加載的。
3.1.2、觸發(fā)時(shí)機(jī)
調(diào)用get方法之前沒有調(diào)用set方法,則get方法內(nèi)部會(huì)觸發(fā)initialValue,也就是說get的時(shí)候如果沒拿到東西,則會(huì)觸發(fā)initialValue。
3.1.3、補(bǔ)充說明
- 通常,每個(gè)線程最多調(diào)用一次此方法。但是如果已經(jīng)調(diào)用了remove(),然后再次調(diào)用get()的話,則可以再次觸發(fā)initialValue。
- 如果要重寫的話一般建議采取匿名內(nèi)部類的方式重寫此方法,否則默認(rèn)返回的是null。
比如:
- public static ThreadLocal<SimpleDateFormat> dateFormatThreadLocal = new ThreadLocal() {
- @Override
- protected SimpleDateFormat initialValue() {
- return new SimpleDateFormat("yyyy-MM-dd hh:mm:ss");
- }
- };
- // Java8的高逼格寫法
- public static ThreadLocal<SimpleDateFormat> dateFormatThreadLocal =
- ThreadLocal.withInitial(() -> new SimpleDateFormat("yyyy-MM-dd hh:mm:ss"));
3.1.4、源碼
- // 由子類提供實(shí)現(xiàn)。
- // protected的含義就是交給子類干的。
- protected T initialValue() {
- return null;
- }
3.2、get
3.2.1、什么意思
獲取當(dāng)前線程下的ThreadLocal中的值。
3.2.2、源碼
- /**
- * 獲取當(dāng)前線程下的entry里的value值。
- * 先獲取當(dāng)前線程下的ThreadLocalMap,
- * 然后以當(dāng)前ThreadLocal為key取出map中的value
- */
- public T get() {
- // 獲取當(dāng)前線程
- Thread t = Thread.currentThread();
- // 獲取當(dāng)前線程對(duì)應(yīng)的ThreadLocalMap對(duì)象。
- ThreadLocalMap map = getMap(t);
- // 若獲取到了。則獲取此ThreadLocalMap下的entry對(duì)象,若entry也獲取到了,那么直接獲取entry對(duì)應(yīng)的value返回即可。
- if (map != null) {
- // 獲取此ThreadLocalMap下的entry對(duì)象
- ThreadLocalMap.Entry e = map.getEntry(this);
- // 若entry也獲取到了
- if (e != null) {
- @SuppressWarnings("unchecked")
- // 直接獲取entry對(duì)應(yīng)的value返回。
- T result = (T)e.value;
- return result;
- }
- }
- // 若沒獲取到ThreadLocalMap或沒獲取到Entry,則設(shè)置初始值。
- // 知識(shí)點(diǎn):我早就說了,初始值方法是延遲加載,只有在get才會(huì)用到,這下看到了吧,只有在這獲取沒獲取到才會(huì)初始化,下次就肯定有值了,所以只會(huì)執(zhí)行一次?。?!
- return setInitialValue();
- }
3.3、set
3.3.1、什么意思
其實(shí)干的事和initialValue是一樣的,都是set值,只是調(diào)用時(shí)機(jī)不同。set是想用就用,api擺在這里,你想用就調(diào)一下set方法。很自由。
3.3.2、源碼
- /**
- * 設(shè)置當(dāng)前線程的線程局部變量的值
- * 實(shí)際上ThreadLocal的值是放入了當(dāng)前線程的一個(gè)ThreadLocalMap實(shí)例中,所以只能在本線程中訪問。
- */
- public void set(T value) {
- // 獲取當(dāng)前線程
- Thread t = Thread.currentThread();
- // 獲取當(dāng)前線程對(duì)應(yīng)的ThreadLocalMap實(shí)例,注意這里是將t傳進(jìn)去了,t是當(dāng)前線程,就是說ThreadLocalMap是在線程里持有的引用。
- ThreadLocalMap map = getMap(t);
- // 若當(dāng)前線程有對(duì)應(yīng)的ThreadLocalMap實(shí)例,則將當(dāng)前ThreadLocal對(duì)象作為key,value做為值存到ThreadLocalMap的entry里。
- if (map != null)
- map.set(this, value);
- else
- // 若當(dāng)前線程沒有對(duì)應(yīng)的ThreadLocalMap實(shí)例,則創(chuàng)建ThreadLocalMap,并將此線程與之綁定
- createMap(t, value);
- }
3.4、remove
3.4.1、什么意思
將當(dāng)前線程下的ThreadLocal的值刪除,目的是為了減少內(nèi)存占用。主要目的是防止內(nèi)存泄漏。內(nèi)存泄漏問題下面會(huì)說。
3.4.2、源碼
- /**
- * 將當(dāng)前線程局部變量的值刪除,目的是為了減少內(nèi)存占用。主要目的是防止內(nèi)存泄漏。內(nèi)存泄漏問題下面會(huì)說。
- */
- public void remove() {
- // 獲取當(dāng)前線程的ThreadLocalMap對(duì)象,并將其移除。
- ThreadLocalMap m = getMap(Thread.currentThread());
- if (m != null)
- // 直接移除以當(dāng)前ThreadLocal為key的value
- m.remove(this);
- }
4、ThreadLocalMap
為啥單獨(dú)拿出來說下,我就是想強(qiáng)調(diào)一點(diǎn):這個(gè)東西是歸Thread類所有的。它的引用在Thread類里,這也證實(shí)了一個(gè)問題:ThreadLocalMap類內(nèi)部為什么有Entry數(shù)組,而不是Entry對(duì)象?
因?yàn)槟銟I(yè)務(wù)代碼能new好多個(gè)ThreadLocal對(duì)象,各司其職。但是在一次請(qǐng)求里,也就是一個(gè)線程里,ThreadLocalMap是同一個(gè),而不是多個(gè),不管你new幾次ThreadLocal,ThreadLocalMap在一個(gè)線程里就一個(gè),因?yàn)樵僬f一次,ThreadLocalMap的引用是在Thread里的,所以它里面的Entry數(shù)組存放的是一個(gè)線程里你new出來的多個(gè)ThreadLocal對(duì)象。
核心源碼如下:
- // 在你調(diào)用ThreadLocal.get()方法的時(shí)候就會(huì)調(diào)用這個(gè)方法,它的返回是當(dāng)前線程里的threadLocals的引用。
- // 這個(gè)引用指向的是ThreadLocal里的ThreadLocalMap對(duì)象
- ThreadLocalMap getMap(Thread t) {
- return t.threadLocals;
- }
- public class Thread implements Runnable {
- // ThreadLocal.ThreadLocalMap
- ThreadLocal.ThreadLocalMap threadLocals = null;
- }
四、完整源碼
1、核心源碼
- // 本地線程。Thread:線程。Local:本地
- public class ThreadLocal<T> {
- // 構(gòu)造器
- public ThreadLocal() {}
- // 初始值,用來初始化值用的,比如:ThreadLocal<Integer> count = new ThreadLocal<>();
- // 你想Integer value = count.get(); value++;這樣是報(bào)錯(cuò)的,因?yàn)閏ount現(xiàn)在還沒值,取出來的是個(gè)null,所以你需要先重寫此方法為value賦上初始值,本身方法是protected也代表就是為了子類重寫的。
- // 此方法是一個(gè)延遲調(diào)用方法,在線程第一次調(diào)用get的時(shí)候才執(zhí)行,下面具體分析源碼就知道了。
- protected T initialValue() {}
- // 創(chuàng)建ThreadLocalMap,ThreadLocal底層其實(shí)就是一個(gè)map來維護(hù)的。
- void createMap(Thread t, T firstValue) {}
- // 返回該當(dāng)前線程對(duì)應(yīng)的線程局部變量值。
- public T get() {}
- // 獲取ThreadLocalMap
- ThreadLocalMap getMap(Thread t) {}
- // 設(shè)置當(dāng)前線程的線程局部變量的值
- public void set(T value) {}
- // 將當(dāng)前線程局部變量的值刪除,目的是為了減少內(nèi)存占用。其實(shí)當(dāng)線程結(jié)束后對(duì)應(yīng)該線程的局部變量將自動(dòng)被垃圾回收,所以無需我們調(diào)用remove,我們調(diào)用remove無非也就是加快內(nèi)存回收速度。
- public void remove() {}
- // 設(shè)置初始值,調(diào)用initialValue
- private T setInitialValue() {}
- // 靜態(tài)內(nèi)部類,一個(gè)map來維護(hù)的?。?!
- static class ThreadLocalMap {
- // ThreadLocalMap的靜態(tài)內(nèi)部類,繼承了弱引用,這正是不會(huì)造成內(nèi)存泄漏根本原因
- // Entry的key為ThreadLocal并且是弱引用。value是值
- static class Entry extends WeakReference<ThreadLocal<?>> {}
- }
- }
2、set()
- /**
- * 設(shè)置當(dāng)前線程的線程局部變量的值
- * 實(shí)際上ThreadLocal的值是放入了當(dāng)前線程的一個(gè)ThreadLocalMap實(shí)例中,所以只能在本線程中訪問。
- */
- public void set(T value) {
- // 獲取當(dāng)前線程
- Thread t = Thread.currentThread();
- // 獲取當(dāng)前線程對(duì)應(yīng)的ThreadLocalMap實(shí)例
- ThreadLocalMap map = getMap(t);
- // 若當(dāng)前線程有對(duì)應(yīng)的ThreadLocalMap實(shí)例,則將當(dāng)前ThreadLocal對(duì)象作為key,value做為值存到ThreadLocalMap的entry里。
- if (map != null)
- map.set(this, value);
- else
- // 若當(dāng)前線程沒有對(duì)應(yīng)的ThreadLocalMap實(shí)例,則創(chuàng)建ThreadLocalMap,并將此線程與之綁定
- createMap(t, value);
- }
3、getMap()
- // 在你調(diào)用ThreadLocal.get()方法的時(shí)候就會(huì)調(diào)用這個(gè)方法,它的返回是當(dāng)前線程里的threadLocals的引用。
- // 這個(gè)引用指向的是ThreadLocal里的ThreadLocalMap對(duì)象
- ThreadLocalMap getMap(Thread t) {
- return t.threadLocals;
- }
- public class Thread implements Runnable {
- // ThreadLocal.ThreadLocalMap
- ThreadLocal.ThreadLocalMap threadLocals = null;
- }
4、map.set()
- // 不多BB,就和HashMap的set一個(gè)道理,只是賦值key,value。
- // 需要注意的是這里key是ThreadLocal對(duì)象,value是值
- private void set(ThreadLocal<?> key, Object value) {}
5、createMap()
- /**
- * 創(chuàng)建ThreadLocalMap對(duì)象。
- * t.threadLocals在上面的getMap中詳細(xì)介紹了。此處不BB。
- * 實(shí)例化ThreadLocalMap并且傳入兩個(gè)值,一個(gè)是當(dāng)前ThreadLocal對(duì)象一個(gè)是value。
- */
- void createMap(Thread t, T firstValue) {
- t.threadLocals = new ThreadLocalMap(this, firstValue);
- }
- // ThreadLocalMap構(gòu)造器。
- ThreadLocalMap(ThreadLocal<?> firstKey, Object firstValue) {
- table = new Entry[INITIAL_CAPACITY];
- int i = firstKey.threadLocalHashCode & (INITIAL_CAPACITY - 1);
- // 重點(diǎn)看這里?。。。。?!
- // new了一個(gè)ThreadLocalMap的內(nèi)部類Entry,且將key和value傳入。
- // key是ThreadLocal對(duì)象。
- table[i] = new Entry(firstKey, firstValue);
- size = 1;
- setThreshold(INITIAL_CAPACITY);
- }
- /**
- * 到這里朋友們應(yīng)該真相大白了,其實(shí)ThreadLocal就是內(nèi)部維護(hù)一個(gè)ThreadLocalMap,
- * 而ThreadLocalMap內(nèi)部又維護(hù)了一個(gè)Entry對(duì)象。Entry對(duì)象是key-value形式,
- * key是ThreadLocal對(duì)象,value是傳入的value
- * 所以我們對(duì)ThreadLocal的操作其實(shí)都是對(duì)內(nèi)部的ThreadLocalMap.Entry的操作
- * 所以保證了線程之前互不干擾。
- */
6、get()
- /**
- * 獲取當(dāng)前線程下的entry里的value值。
- * 先獲取當(dāng)前線程下的ThreadLocalMap,
- * 然后以當(dāng)前ThreadLocal為key取出map中的value
- */
- public T get() {
- // 獲取當(dāng)前線程
- Thread t = Thread.currentThread();
- // 獲取當(dāng)前線程對(duì)應(yīng)的ThreadLocalMap對(duì)象。
- ThreadLocalMap map = getMap(t);
- // 若獲取到了。則獲取此ThreadLocalMap下的entry對(duì)象,若entry也獲取到了,那么直接獲取entry對(duì)應(yīng)的value返回即可。
- if (map != null) {
- // 獲取此ThreadLocalMap下的entry對(duì)象
- ThreadLocalMap.Entry e = map.getEntry(this);
- // 若entry也獲取到了
- if (e != null) {
- @SuppressWarnings("unchecked")
- // 直接獲取entry對(duì)應(yīng)的value返回。
- T result = (T)e.value;
- return result;
- }
- }
- // 若沒獲取到ThreadLocalMap或沒獲取到Entry,則設(shè)置初始值。
- // 知識(shí)點(diǎn):我早就說了,初始值方法是延遲加載,只有在get才會(huì)用到,這下看到了吧,只有在這獲取沒獲取到才會(huì)初始化,下次就肯定有值了,所以只會(huì)執(zhí)行一次?。?!
- return setInitialValue();
- }
7、setInitialValue()
- // 設(shè)置初始值
- private T setInitialValue() {
- // 調(diào)用初始值方法,由子類提供。
- T value = initialValue();
- // 獲取當(dāng)前線程
- Thread t = Thread.currentThread();
- // 獲取map
- ThreadLocalMap map = getMap(t);
- // 獲取到了
- if (map != null)
- // set
- map.set(this, value);
- else
- // 沒獲取到。創(chuàng)建map并賦值
- createMap(t, value);
- // 返回初始值。
- return value;
- }
8、initialValue()
- // 由子類提供實(shí)現(xiàn)。
- // protected
- protected T initialValue() {
- return null;
- }
9、remove()
- /**
- * 將當(dāng)前線程局部變量的值刪除,目的是為了減少內(nèi)存占用。
- * 其實(shí)當(dāng)線程結(jié)束后對(duì)應(yīng)該線程的局部變量將自動(dòng)被垃圾回收,所以無需我們調(diào)用remove,我們調(diào)用remove無非也就是加快內(nèi)存回收速度。
- */
- public void remove() {
- // 獲取當(dāng)前線程的ThreadLocalMap對(duì)象,并將其移除。
- ThreadLocalMap m = getMap(Thread.currentThread());
- if (m != null)
- m.remove(this);
- }
10、小結(jié)
只要捋清楚如下幾個(gè)類的關(guān)系,ThreadLocal將變得so easy!
Thread、ThreadLocal、ThreadLocalMap、Entry
一句話總結(jié)就是:Thread維護(hù)了ThreadLocalMap,而ThreadLocalMap里維護(hù)了Entry,而Entry里存的是以ThreadLocal為key,傳入的值為value的鍵值對(duì)。
五、答疑(面試題)
1、和Synchronized的區(qū)別
問:他和線程同步機(jī)制(如:Synchronized)提供一樣的功能,這個(gè)很吊啊。
答:放屁!同步機(jī)制保證的是多線程同時(shí)操作共享變量并且能正確的輸出結(jié)果。ThreadLocal不行啊,他把共享變量變成線程私有了,每個(gè)線程都有獨(dú)立的一個(gè)變量。舉個(gè)通俗易懂的案例:網(wǎng)站計(jì)數(shù)器,你給變量count++的時(shí)候帶上synchronized即可解決。ThreadLocal的話做不到啊,他沒發(fā)統(tǒng)計(jì),他只能說能統(tǒng)計(jì)每個(gè)線程登錄了多少次。
2、存儲(chǔ)在jvm的哪個(gè)區(qū)域
問:線程私有,那么就是說ThreadLocal的實(shí)例和他的值是放到棧上咯?
答:不是。還是在堆的。ThreadLocal對(duì)象也是對(duì)象,對(duì)象就在堆。只是JVM通過一些技巧將其可見性變成了線程可見。
3、真的只是當(dāng)前線程可見嗎
問:真的只是當(dāng)前線程可見嗎?
答:貌似不是,貌似通過InheritableThreadLocal類可以實(shí)現(xiàn)多個(gè)線程訪問ThreadLocal的值,但是我沒研究過,知道這碼事就行了。
4、會(huì)導(dǎo)致內(nèi)存泄漏么
問:會(huì)導(dǎo)致內(nèi)存泄漏么?
答:分析一下:
1、ThreadLocalMap.Entry的key會(huì)內(nèi)存泄漏嗎?
2、ThreadLocalMap.Entry的value會(huì)內(nèi)存泄漏嗎?
先看下key-value的核心源碼
- static class Entry extends WeakReference<ThreadLocal<?>> {
- Object value;
- Entry(ThreadLocal<?> k, Object v) {
- super(k);
- vvalue = v;
- }
- }
先看繼承關(guān)系,發(fā)現(xiàn)是繼承了弱引用,而且key直接是交給了父類處理super(key),父類是個(gè)弱引用,所以key完全不存在內(nèi)存泄漏問題,因?yàn)樗皇菑?qiáng)引用,它可以被GC回收的。
弱引用的特點(diǎn):如果這個(gè)對(duì)象只被弱引用關(guān)聯(lián),沒有任何強(qiáng)引用關(guān)聯(lián),那么這個(gè)對(duì)象就可以被GC回收掉。弱引用不會(huì)阻止GC回收。這是jvm知識(shí)。
再看value,發(fā)現(xiàn)value是個(gè)強(qiáng)引用,但是想了下也沒問題的呀,因?yàn)榫€程終止了,我管你強(qiáng)引用還是弱引用,都會(huì)被GC掉的,因?yàn)橐面湐嗔耍╦vm用的可達(dá)性分析法,線程終止了,根節(jié)點(diǎn)就斷了,下面的都會(huì)被回收)。
這么分析一點(diǎn)毛病都沒有,但是忘了一個(gè)主要的角色,那就是線程池,線程池的存在核心線程是不會(huì)銷毀的,只要?jiǎng)?chuàng)建出來他會(huì)反復(fù)利用,生命周期不會(huì)結(jié)束掉,但是key是弱引用會(huì)被GC回收掉,value強(qiáng)引用不會(huì)回收,所以形成了如下場面:
Thread->ThreadLocalMap->Entry(key為null)->value
由于value和Thread還存在鏈路關(guān)系,還是可達(dá)的,所以不會(huì)被回收,這樣越來越多的垃圾對(duì)象產(chǎn)生卻無法回收,早晨內(nèi)存泄漏,時(shí)間久了必定OOM。
解決方案ThreadLocal已經(jīng)為我們想好了,提供了remove()方法,這個(gè)方法是將value移出去的。所以用完后記得remove()。
5、為什么用Entry數(shù)組而不是Entry對(duì)象
這個(gè)其實(shí)主要想考ThreadLocalMap是在Thread里持有的引用。
問:ThreadLocalMap內(nèi)部的table為什么是數(shù)組而不是單個(gè)對(duì)象呢?
答:因?yàn)槟銟I(yè)務(wù)代碼能new好多個(gè)ThreadLocal對(duì)象,各司其職。但是在一次請(qǐng)求里,也就是一個(gè)線程里,ThreadLocalMap是同一個(gè),而不是多個(gè),不管你new幾次ThreadLocal,ThreadLocalMap在一個(gè)線程里就一個(gè),因?yàn)門hreadLocalMap的引用是在Thread里的,所以它里面的Entry數(shù)組存放的是一個(gè)線程里你new出來的多個(gè)ThreadLocal對(duì)象。
6、你學(xué)習(xí)的開源框架哪些用到了ThreadLocal
Spring框架。
DateTimeContextHolder
RequestContextHolder
7、ThreadLocal里的對(duì)象一定是線程安全的嗎
未必,如果在每個(gè)線程中ThreadLocal.set()進(jìn)去的東西本來就是多線程共享的同一個(gè)對(duì)象,比如static對(duì)象,那么多個(gè)線程的ThreadLocal.get()獲取的還是這個(gè)共享對(duì)象本身,還是有并發(fā)訪問線程不安全問題。
8、筆試題
問:下面這段程序會(huì)輸出什么?為什么?
- public class TestThreadLocalNpe {
- private static ThreadLocal<Long> threadLocal = new ThreadLocal();
- public static void set() {
- threadLocal.set(1L);
- }
- public static long get() {
- return threadLocal.get();
- }
- public static void main(String[] args) throws InterruptedException {
- new Thread(() -> {
- set();
- System.out.println(get());
- }).start();
- // 目的就是為了讓子線程先運(yùn)行完
- Thread.sleep(100);
- System.out.println(get());
- }
- }
答:
- 1
- Exception in thread "main" java.lang.NullPointerException
- at com.chentongwei.study.thread.TestThreadLocalNpe.get(TestThreadLocalNpe.java:16)
- at com.chentongwei.study.thread.TestThreadLocalNpe.main(TestThreadLocalNpe.java:26)
為什么?
為什么輸出個(gè)1,然后空指針了?
首先輸出1是沒任何問題的,其次主線程空指針是為什么?
如果你這里回答
- 1
- 1
那我恭喜你,你連ThreadLocal都不知道是啥,這明顯兩個(gè)線程,子線程和主線程。子線程設(shè)置1,主線程肯定拿不到啊,ThreadLocal和線程是嘻嘻相關(guān)的。這個(gè)不多費(fèi)口舌。
說說為什么是空指針?
因?yàn)槟鉭et方法用的long而不是Long,那也應(yīng)該返回null啊,大哥,long是基本類型,默認(rèn)值是0,沒有null這一說法。ThreadLocal里的泛型是Long,get卻是基本類型,這需要拆箱操作的,也就是會(huì)執(zhí)行null.longValue()的操作,這絕逼空指針了。
看似一道Javase的基礎(chǔ)題目,實(shí)則隱藏了很多知識(shí)。
六、ThreadLocal工具類
- package com.duoku.base.util;
- import com.google.common.collect.Maps;
- import org.springframework.core.NamedThreadLocal;
- import java.util.Map;
- /**
- * Description:
- *
- * @author TongWei.Chen 2019-09-09 18:35:30
- */
- public class ThreadLocalUtil {
- private static final ThreadLocal<Map<String, Object>> threadLocal = new NamedThreadLocal("xxx-threadlocal") {
- @Override
- protected Map<String, Object> initialValue() {
- return Maps.newHashMap();
- }
- };
- public static Map<String, Object> getThreadLocal(){
- return threadLocal.get();
- }
- public static <T> T get(String key) {
- Map map = threadLocal.get();
- // todo:copy a new one
- return (T)map.get(key);
- }
- public static <T> T get(String key,T defaultValue) {
- Map map = threadLocal.get();
- return (T)map.get(key) == null ? defaultValue : (T)map.get(key);
- }
- public static void set(String key, Object value) {
- Map map = threadLocal.get();
- map.put(key, value);
- }
- public static void set(Map<String, Object> keyValueMap) {
- Map map = threadLocal.get();
- map.putAll(keyValueMap);
- }
- public static void remove() {
- threadLocal.remove();
- }
- }
另
瑣碎時(shí)間想看一些技術(shù)文章,可以去公眾號(hào)菜單欄翻一翻我分類好的內(nèi)容,應(yīng)該對(duì)部分童鞋有幫助。