一、概述

1、官方術語

ThreadLocal類是用來提供線程內部的局部變量。讓這些變量在多線程環境下訪問（get/set）時能保證各個線程里的變量相對獨立于其他線程內的變量。

2、大白話

ThreadLocal是一個關于創建線程局部變量的類。

通常情況下，我們創建的成員變量都是線程不安全的。因為他可能被多個線程同時修改，此變量對于多個線程之間彼此并不獨立，是共享變量。而使用ThreadLocal創建的變量只能被當前線程訪問，其他線程無法訪問和修改。也就是說：將線程公有化變成線程私有化。

二、應用場景

• 每個線程都需要一個獨享的對象（比如工具類，典型的就是SimpleDateFormat，每次使用都new一個多浪費性能呀，直接放到成員變量里又是線程不安全，所以把他用ThreadLocal管理起來就完美了。）

比如：

/*** Description: SimpleDateFormat就一份，不浪費資源。**?@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);//?從結果中可以看出是線程安全的，時間沒有重復的。System.out.println(date);});}executorService.shutdown();} }class?ThreadSafeFormatter?{public?static?ThreadLocal<SimpleDateFormat>?dateFormatThreadLocal?=?new?ThreadLocal()?{@Overrideprotected?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")); }

細心的朋友已經發現了，這TM也是每個線程都創建一個SimpleDateFormat啊，跟直接在方法內部new沒區別，錯了，大錯特錯！1個請求進來是一個線程，他可能貫穿了N個方法，你這N個方法假設有3個都在使用dateToStr()，你直接new的話會產生三個SimpleDateFormat對象，而用ThreadLocal的話只會產生一個對象，一個線程一個。

• 每個線程內需要保存全局變量（比如在登錄成功后將用戶信息存到ThreadLocal里，然后當前線程操作的業務邏輯直接get取就完事了，有效的避免的參數來回傳遞的麻煩之處），一定層級上減少代碼耦合度。

再細化一點就是：

• 比如存儲 交易id等信息。每個線程私有。

• 比如aop里記錄日志需要before記錄請求id，end拿出請求id，這也可以。

• 比如jdbc連接池（很典型的一個ThreadLocal用法）

• ....等等....

三、核心知識

1、類關系

每個Thread對象中都持有一個ThreadLocalMap的成員變量。每個ThreadLocalMap內部又維護了N個Entry節點，也就是Entry數組，每個Entry代表一個完整的對象，key是ThreadLocal本身，value是ThreadLocal的泛型值。

核心源碼如下

//?java.lang.Thread類里持有ThreadLocalMap的引用 public?class?Thread?implements?Runnable?{ThreadLocal.ThreadLocalMap?threadLocals?=?null; }//?java.lang.ThreadLocal有內部靜態類ThreadLocalMap public?class?ThreadLocal<T>?{static?class?ThreadLocalMap?{private?Entry[]?table;//?ThreadLocalMap內部有Entry類，Entry的key是ThreadLocal本身，value是泛型值static?class?Entry?extends?WeakReference<ThreadLocal<?>>?{Object?value;Entry(ThreadLocal<?>?k,?Object?v)?{super(k);value?=?v;}}} }

2、類關系圖

ThreadLocal內存結構圖。

?

3、主要方法

• initialValue：初始化。在get方法里懶加載的。

• get：得到這個線程對應的value。如果調用get之前沒set過，則get內部會執行initialValue方法進行初始化。

• set：為這個線程設置一個新值。

• remove：刪除這個線程對應的值，防止內存泄露的最佳手段。

3.1、initialValue

3.1.1、什么意思

見名知意，初始化一些value（泛型值）。懶加載的。

3.1.2、觸發時機

調用get方法之前沒有調用set方法，則get方法內部會觸發initialValue，也就是說get的時候如果沒拿到東西，則會觸發initialValue。

3.1.3、補充說明

• 通常，每個線程最多調用一次此方法。但是如果已經調用了remove()，然后再次調用get()的話，則可以再次觸發initialValue。

• 如果要重寫的話一般建議采取匿名內部類的方式重寫此方法，否則默認返回的是null。

比如：

public?static?ThreadLocal<SimpleDateFormat>?dateFormatThreadLocal?=?new?ThreadLocal()?{@Overrideprotected?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、源碼

//?由子類提供實現。 // protected的含義就是交給子類干的。 protected?T?initialValue()?{return?null; }

3.2、get

3.2.1、什么意思

獲取當前線程下的ThreadLocal中的值。

3.2.2、源碼

/***?獲取當前線程下的entry里的value值。*?先獲取當前線程下的ThreadLocalMap，*?然后以當前ThreadLocal為key取出map中的value*/ public?T?get()?{//?獲取當前線程Thread?t?=?Thread.currentThread();//?獲取當前線程對應的ThreadLocalMap對象。ThreadLocalMap?map?=?getMap(t);//?若獲取到了。則獲取此ThreadLocalMap下的entry對象，若entry也獲取到了，那么直接獲取entry對應的value返回即可。if?(map?!=?null)?{//?獲取此ThreadLocalMap下的entry對象ThreadLocalMap.Entry?e?=?map.getEntry(this);//?若entry也獲取到了if?(e?!=?null)?{@SuppressWarnings("unchecked")//?直接獲取entry對應的value返回。T?result?=?(T)e.value;return?result;}}//?若沒獲取到ThreadLocalMap或沒獲取到Entry，則設置初始值。//?知識點：我早就說了，初始值方法是延遲加載，只有在get才會用到，這下看到了吧，只有在這獲取沒獲取到才會初始化，下次就肯定有值了，所以只會執行一次！！！return?setInitialValue(); }

3.3、set

3.3.1、什么意思

其實干的事和initialValue是一樣的，都是set值，只是調用時機不同。set是想用就用，api擺在這里，你想用就調一下set方法。很自由。

3.3.2、源碼

/***?設置當前線程的線程局部變量的值*?實際上ThreadLocal的值是放入了當前線程的一個ThreadLocalMap實例中，所以只能在本線程中訪問。*/ public?void?set(T?value)?{//?獲取當前線程Thread?t?=?Thread.currentThread();//?獲取當前線程對應的ThreadLocalMap實例，注意這里是將t傳進去了，t是當前線程，就是說ThreadLocalMap是在線程里持有的引用。ThreadLocalMap?map?=?getMap(t);//?若當前線程有對應的ThreadLocalMap實例，則將當前ThreadLocal對象作為key，value做為值存到ThreadLocalMap的entry里。if?(map?!=?null)map.set(this,?value);else//?若當前線程沒有對應的ThreadLocalMap實例，則創建ThreadLocalMap，并將此線程與之綁定createMap(t,?value); }

3.4、remove

3.4.1、什么意思

將當前線程下的ThreadLocal的值刪除，目的是為了減少內存占用。主要目的是防止內存泄漏。內存泄漏問題下面會說。

3.4.2、源碼

/***?將當前線程局部變量的值刪除，目的是為了減少內存占用。主要目的是防止內存泄漏。內存泄漏問題下面會說。*/ public?void?remove()?{//?獲取當前線程的ThreadLocalMap對象，并將其移除。ThreadLocalMap?m?=?getMap(Thread.currentThread());if?(m?!=?null)//?直接移除以當前ThreadLocal為key的valuem.remove(this); }

4、ThreadLocalMap

為啥單獨拿出來說下，我就是想強調一點：這個東西是歸Thread類所有的。它的引用在Thread類里，這也證實了一個問題：ThreadLocalMap類內部為什么有Entry數組，而不是Entry對象？

因為你業務代碼能new好多個ThreadLocal對象，各司其職。但是在一次請求里，也就是一個線程里，ThreadLocalMap是同一個，而不是多個，不管你new幾次ThreadLocal，ThreadLocalMap在一個線程里就一個，因為再說一次，ThreadLocalMap的引用是在Thread里的，所以它里面的Entry數組存放的是一個線程里你new出來的多個ThreadLocal對象。

核心源碼如下：

//?在你調用ThreadLocal.get()方法的時候就會調用這個方法，它的返回是當前線程里的threadLocals的引用。 //?這個引用指向的是ThreadLocal里的ThreadLocalMap對象 ThreadLocalMap?getMap(Thread?t)?{return?t.threadLocals; }public?class?Thread?implements?Runnable?{//?ThreadLocal.ThreadLocalMapThreadLocal.ThreadLocalMap?threadLocals?=?null; }

四、完整源碼

1、核心源碼

//?本地線程。Thread：線程。Local：本地 public?class?ThreadLocal<T>?{//?構造器public?ThreadLocal()?{}//?初始值，用來初始化值用的，比如：ThreadLocal<Integer> count = new ThreadLocal<>();//?你想Integer value = count.get(); value++;這樣是報錯的，因為count現在還沒值，取出來的是個null,所以你需要先重寫此方法為value賦上初始值，本身方法是protected也代表就是為了子類重寫的。//?此方法是一個延遲調用方法，在線程第一次調用get的時候才執行，下面具體分析源碼就知道了。protected?T?initialValue()?{}//?創建ThreadLocalMap，ThreadLocal底層其實就是一個map來維護的。void?createMap(Thread?t,?T?firstValue)?{}//?返回該當前線程對應的線程局部變量值。public?T?get()?{}//?獲取ThreadLocalMapThreadLocalMap?getMap(Thread?t)?{}//?設置當前線程的線程局部變量的值public?void?set(T?value)?{}//?將當前線程局部變量的值刪除，目的是為了減少內存占用。其實當線程結束后對應該線程的局部變量將自動被垃圾回收，所以無需我們調用remove，我們調用remove無非也就是加快內存回收速度。public?void?remove()?{}//?設置初始值，調用initialValueprivate?T?setInitialValue()?{}//?靜態內部類，一個map來維護的！！！static?class?ThreadLocalMap?{//?ThreadLocalMap的靜態內部類，繼承了弱引用，這正是不會造成內存泄漏根本原因// Entry的key為ThreadLocal并且是弱引用。value是值static?class?Entry?extends?WeakReference<ThreadLocal<?>>?{}}}

2、set()

/***?設置當前線程的線程局部變量的值*?實際上ThreadLocal的值是放入了當前線程的一個ThreadLocalMap實例中，所以只能在本線程中訪問。*/ public?void?set(T?value)?{//?獲取當前線程Thread?t?=?Thread.currentThread();//?獲取當前線程對應的ThreadLocalMap實例ThreadLocalMap?map?=?getMap(t);//?若當前線程有對應的ThreadLocalMap實例，則將當前ThreadLocal對象作為key，value做為值存到ThreadLocalMap的entry里。if?(map?!=?null)map.set(this,?value);else//?若當前線程沒有對應的ThreadLocalMap實例，則創建ThreadLocalMap，并將此線程與之綁定createMap(t,?value); }

3、getMap()

//?在你調用ThreadLocal.get()方法的時候就會調用這個方法，它的返回是當前線程里的threadLocals的引用。 //?這個引用指向的是ThreadLocal里的ThreadLocalMap對象 ThreadLocalMap?getMap(Thread?t)?{return?t.threadLocals; }public?class?Thread?implements?Runnable?{//?ThreadLocal.ThreadLocalMapThreadLocal.ThreadLocalMap?threadLocals?=?null; }

4、map.set()

//?不多BB，就和HashMap的set一個道理，只是賦值key,value。 //?需要注意的是這里key是ThreadLocal對象，value是值 private?void?set(ThreadLocal<?>?key,?Object?value)?{}

5、createMap()

/***?創建ThreadLocalMap對象。* t.threadLocals在上面的getMap中詳細介紹了。此處不BB。*?實例化ThreadLocalMap并且傳入兩個值，一個是當前ThreadLocal對象一個是value。*/ void?createMap(Thread?t,?T?firstValue)?{t.threadLocals?=?new?ThreadLocalMap(this,?firstValue); }// ThreadLocalMap構造器。 ThreadLocalMap(ThreadLocal<?>?firstKey,?Object?firstValue)?{table?=?new?Entry[INITIAL_CAPACITY];int?i?=?firstKey.threadLocalHashCode?&?(INITIAL_CAPACITY?-?1);//?重點看這里！！！！！！// new了一個ThreadLocalMap的內部類Entry，且將key和value傳入。// key是ThreadLocal對象。table[i]?=?new?Entry(firstKey,?firstValue);size?=?1;setThreshold(INITIAL_CAPACITY); }/***?到這里朋友們應該真相大白了，其實ThreadLocal就是內部維護一個ThreadLocalMap，*?而ThreadLocalMap內部又維護了一個Entry對象。Entry對象是key-value形式，*?key是ThreadLocal對象，value是傳入的value*?所以我們對ThreadLocal的操作其實都是對內部的ThreadLocalMap.Entry的操作*?所以保證了線程之前互不干擾。*/

6、get()

/***?獲取當前線程下的entry里的value值。*?先獲取當前線程下的ThreadLocalMap，*?然后以當前ThreadLocal為key取出map中的value*/ public?T?get()?{//?獲取當前線程Thread?t?=?Thread.currentThread();//?獲取當前線程對應的ThreadLocalMap對象。ThreadLocalMap?map?=?getMap(t);//?若獲取到了。則獲取此ThreadLocalMap下的entry對象，若entry也獲取到了，那么直接獲取entry對應的value返回即可。if?(map?!=?null)?{//?獲取此ThreadLocalMap下的entry對象ThreadLocalMap.Entry?e?=?map.getEntry(this);//?若entry也獲取到了if?(e?!=?null)?{@SuppressWarnings("unchecked")//?直接獲取entry對應的value返回。T?result?=?(T)e.value;return?result;}}//?若沒獲取到ThreadLocalMap或沒獲取到Entry，則設置初始值。//?知識點：我早就說了，初始值方法是延遲加載，只有在get才會用到，這下看到了吧，只有在這獲取沒獲取到才會初始化，下次就肯定有值了，所以只會執行一次！！！return?setInitialValue(); }

7、setInitialValue()

//?設置初始值 private?T?setInitialValue()?{//?調用初始值方法，由子類提供。T?value?=?initialValue();//?獲取當前線程Thread?t?=?Thread.currentThread();//?獲取mapThreadLocalMap?map?=?getMap(t);//?獲取到了if?(map?!=?null)//?setmap.set(this,?value);else//?沒獲取到。創建map并賦值createMap(t,?value);//?返回初始值。return?value; }

8、initialValue()

//?由子類提供實現。 //?protected protected?T?initialValue()?{return?null; }

9、remove()

/***?將當前線程局部變量的值刪除，目的是為了減少內存占用。*?其實當線程結束后對應該線程的局部變量將自動被垃圾回收，所以無需我們調用remove，我們調用remove無非也就是加快內存回收速度。*/ public?void?remove()?{//?獲取當前線程的ThreadLocalMap對象，并將其移除。ThreadLocalMap?m?=?getMap(Thread.currentThread());if?(m?!=?null)m.remove(this); }

10、小結

只要捋清楚如下幾個類的關系，ThreadLocal將變得so easy！

Thread、ThreadLocal、ThreadLocalMap、Entry

一句話總結就是：Thread維護了ThreadLocalMap，而ThreadLocalMap里維護了Entry，而Entry里存的是以ThreadLocal為key，傳入的值為value的鍵值對。

五、答疑（面試題）

1、和Synchronized的區別

問：他和線程同步機制（如：Synchronized）提供一樣的功能，這個很吊啊。

答：否！同步機制保證的是多線程同時操作共享變量并且能正確的輸出結果。ThreadLocal不行啊，他把共享變量變成線程私有了，每個線程都有獨立的一個變量。舉個通俗易懂的案例：網站計數器，你給變量count++的時候帶上synchronized即可解決。ThreadLocal的話做不到啊，他沒發統計，他只能說能統計每個線程登錄了多少次。

2、存儲在jvm的哪個區域

問：線程私有，那么就是說ThreadLocal的實例和他的值是放到棧上咯？

答：不是。還是在堆的。ThreadLocal對象也是對象，對象就在堆。只是JVM通過一些技巧將其可見性變成了線程可見。

3、真的只是當前線程可見嗎

問：真的只是當前線程可見嗎？

答：貌似不是，貌似通過InheritableThreadLocal類可以實現多個線程訪問ThreadLocal的值，但是我沒研究過，知道這碼事就行了。

4、會導致內存泄漏么

問：會導致內存泄漏么？

答：分析一下：

• 1、ThreadLocalMap.Entry的key會內存泄漏嗎？

• 2、ThreadLocalMap.Entry的value會內存泄漏嗎？

先看下key-value的核心源碼

static?class?Entry?extends?WeakReference<ThreadLocal<?>>?{Object?value;Entry(ThreadLocal<?>?k,?Object?v)?{super(k);value?=?v;} }

先看繼承關系，發現是繼承了弱引用，而且key直接是交給了父類處理super(key)，父類是個弱引用，所以key完全不存在內存泄漏問題，因為他不是強引用，它可以被GC回收的。

弱引用的特點：如果這個對象只被弱引用關聯，沒有任何強引用關聯，那么這個對象就可以被GC回收掉。弱引用不會阻止GC回收。這是jvm知識。

再看value，發現value是個強引用，但是想了下也沒問題的呀，因為線程終止了，我管你強引用還是弱引用，都會被GC掉的，因為引用鏈斷了（jvm用的可達性分析法，線程終止了，根節點就斷了，下面的都會被回收）。

這么分析一點毛病都沒有，但是忘了一個主要的角色，那就是線程池，線程池的存在核心線程是不會銷毀的，只要創建出來他會反復利用，生命周期不會結束掉，但是key是弱引用會被GC回收掉，value強引用不會回收，所以形成了如下場面：

Thread->ThreadLocalMap->Entry(key為null)->value

由于value和Thread還存在鏈路關系，還是可達的，所以不會被回收，這樣越來越多的垃圾對象產生卻無法回收，早晨內存泄漏，時間久了必定OOM。

解決方案ThreadLocal已經為我們想好了，提供了remove()方法，這個方法是將value移出去的。所以用完后記得remove()。

5、為什么用Entry數組而不是Entry對象

這個其實主要想考ThreadLocalMap是在Thread里持有的引用。

問：ThreadLocalMap內部的table為什么是數組而不是單個對象呢？

答：因為你業務代碼能new好多個ThreadLocal對象，各司其職。但是在一次請求里，也就是一個線程里，ThreadLocalMap是同一個，而不是多個，不管你new幾次ThreadLocal，ThreadLocalMap在一個線程里就一個，因為ThreadLocalMap的引用是在Thread里的，所以它里面的Entry數組存放的是一個線程里你new出來的多個ThreadLocal對象。

6、你學習的開源框架哪些用到了ThreadLocal

Spring框架。

DateTimeContextHolder

RequestContextHolder

7、ThreadLocal里的對象一定是線程安全的嗎

未必，如果在每個線程中ThreadLocal.set()進去的東西本來就是多線程共享的同一個對象，比如static對象，那么多個線程的ThreadLocal.get()獲取的還是這個共享對象本身，還是有并發訪問線程不安全問題。

8、筆試題

問：下面這段程序會輸出什么？為什么？

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();//?目的就是為了讓子線程先運行完Thread.sleep(100);System.out.println(get());} }

答：

1 Exception?in?thread?"main"?java.lang.NullPointerExceptionat?com.chentongwei.study.thread.TestThreadLocalNpe.get(TestThreadLocalNpe.java:16)at?com.chentongwei.study.thread.TestThreadLocalNpe.main(TestThreadLocalNpe.java:26)

為什么？

為什么輸出個1，然后空指針了？

首先輸出1是沒任何問題的，其次主線程空指針是為什么？

如果你這里回答

1 1

那我恭喜你，你連ThreadLocal都不知道是啥，這明顯兩個線程，子線程和主線程。子線程設置1，主線程肯定拿不到啊，ThreadLocal和線程是嘻嘻相關的。這個不多費口舌。

說說為什么是空指針？

因為你get方法用的long而不是Long，那也應該返回null啊，大哥，long是基本類型，默認值是0，沒有null這一說法。ThreadLocal里的泛型是Long，get卻是基本類型，這需要拆箱操作的，也就是會執行null.longValue()的操作，這絕逼空指針了。

看似一道Javase的基礎題目，實則隱藏了很多知識。

六、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")?{@Overrideprotected?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?onereturn?(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();}}

總結

以上是生活随笔為你收集整理的抛出这8个问题，检验你是否真的会ThreadLocal的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。