2. 程式人生 > >徹底理解ThreadLocal

徹底理解ThreadLocal

阿新 • • 發佈：2017-05-08
pass 進行 tps rem spec 區別 tablet dea 覆蓋

ThreadLocal是什麽

　　早在JDK 1.2的版本中就提供Java.lang.ThreadLocal，ThreadLocal為解決多線程程序的並發問題提供了一種新的思路。使用這個工具類可以很簡潔地編寫出優美的多線程程序。

　　當使用ThreadLocal維護變量時，ThreadLocal為每個使用該變量的線程提供獨立的變量副本，所以每一個線程都可以獨立地改變自己的副本，而不會影響其它線程所對應的副本。

　　從線程的角度看，目標變量就象是線程的本地變量，這也是類名中“Local”所要表達的意思。

　　所以，在Java中編寫線程局部變量的代碼相對來說要笨拙一些，因此造成線程局部變量沒有在Java開發者中得到很好的普及。

ThreadLocal的接口方法

ThreadLocal類接口很簡單，只有4個方法，我們先來了解一下：

  • void set(Object value)設置當前線程的線程局部變量的值。
  • public Object get()該方法返回當前線程所對應的線程局部變量。
  • public void remove()將當前線程局部變量的值刪除，目的是為了減少內存的占用，該方法是JDK 5.0新增的方法。需要指出的是，當線程結束後，對應該線程的局部變量將自動被垃圾回收，所以顯式調用該方法清除線程的局部變量並不是必須的操作，但它可以加快內存回收的速度。
  • protected Object initialValue()返回該線程局部變量的初始值，該方法是一個protected的方法，顯然是為了讓子類覆蓋而設計的。這個方法是一個延遲調用方法，在線程第1次調用get()或set(Object)時才執行，並且僅執行1次。ThreadLocal中的缺省實現直接返回一個null。

　　值得一提的是，在JDK5.0中，ThreadLocal已經支持泛型，該類的類名已經變為ThreadLocal<T>。API方法也相應進行了調整，新版本的API方法分別是void set(T value)、T get()以及T initialValue()。

　　ThreadLocal是如何做到為每一個線程維護變量的副本的呢？其實實現的思路很簡單：在ThreadLocal類中有一個Map，用於存儲每一個線程的變量副本，Map中元素的鍵為線程對象，而值對應線程的變量副本。我們自己就可以提供一個簡單的實現版本：

[java] view plain copy print?技術分享
技術分享
  1. package com.test;
  3. public class TestNum {
  4. // ①通過匿名內部類覆蓋ThreadLocal的initialValue()方法，指定初始值
  5. private static ThreadLocal<Integer> seqNum = new ThreadLocal<Integer>() {
  6. public Integer initialValue() {
  7. return 0;
  8. }
  9. };
  11. // ②獲取下一個序列值
  12. public int getNextNum() {
  13. seqNum.set(seqNum.get() + 1);
  14. return seqNum.get();
  15. }
  17. public static void main(String[] args) {
  18. TestNum sn = new TestNum();
  19. // ③ 3個線程共享sn，各自產生序列號
  20. TestClient t1 = new TestClient(sn);
  21. TestClient t2 = new TestClient(sn);
  22. TestClient t3 = new TestClient(sn);
  23. t1.start();
  24. t2.start();
  25. t3.start();
  26. }
  28. private static class TestClient extends Thread {
  29. private TestNum sn;
  31. public TestClient(TestNum sn) {
  32. this.sn = sn;
  33. }
  35. public void run() {
  36. for (int i = 0; i < 3; i++) {
  37. // ④每個線程打出3個序列值
  38. System.out.println("thread[" + Thread.currentThread().getName() + "] --> sn["
  39. + sn.getNextNum() + "]");
  40. }
  41. }
  42. }
  43. }



通常我們通過匿名內部類的方式定義ThreadLocal的子類，提供初始的變量值，如例子中①處所示。TestClient線程產生一組序列號，在③處，我們生成3個TestClient，它們共享同一個TestNum實例。運行以上代碼，在控制臺上輸出以下的結果：

thread[Thread-0] --> sn[1]
thread[Thread-1] --> sn[1]
thread[Thread-2] --> sn[1]
thread[Thread-1] --> sn[2]
thread[Thread-0] --> sn[2]
thread[Thread-1] --> sn[3]
thread[Thread-2] --> sn[2]
thread[Thread-0] --> sn[3]
thread[Thread-2] --> sn[3]

考察輸出的結果信息，我們發現每個線程所產生的序號雖然都共享同一個TestNum實例，但它們並沒有發生相互幹擾的情況，而是各自產生獨立的序列號，這是因為我們通過ThreadLocal為每一個線程提供了單獨的副本。

Thread同步機制的比較

　　ThreadLocal和線程同步機制相比有什麽優勢呢？ThreadLocal和線程同步機制都是為了解決多線程中相同變量的訪問沖突問題。

　　在同步機制中，通過對象的鎖機制保證同一時間只有一個線程訪問變量。這時該變量是多個線程共享的，使用同步機制要求程序慎密地分析什麽時候對變量進行讀寫，什麽時候需要鎖定某個對象，什麽時候釋放對象鎖等繁雜的問題，程序設計和編寫難度相對較大。

　　而ThreadLocal則從另一個角度來解決多線程的並發訪問。ThreadLocal會為每一個線程提供一個獨立的變量副本，從而隔離了多個線程對數據的訪問沖突。因為每一個線程都擁有自己的變量副本，從而也就沒有必要對該變量進行同步了。ThreadLocal提供了線程安全的共享對象，在編寫多線程代碼時，可以把不安全的變量封裝進ThreadLocal。

　　由於ThreadLocal中可以持有任何類型的對象，低版本JDK所提供的get()返回的是Object對象，需要強制類型轉換。但JDK 5.0通過泛型很好的解決了這個問題，在一定程度地簡化ThreadLocal的使用，代碼清單 9 2就使用了JDK 5.0新的ThreadLocal<T>版本。

　　概括起來說，對於多線程資源共享的問題，同步機制采用了“以時間換空間”的方式，而ThreadLocal采用了“以空間換時間”的方式。前者僅提供一份變量，讓不同的線程排隊訪問，而後者為每一個線程都提供了一份變量，因此可以同時訪問而互不影響。

　　spring使用ThreadLocal解決線程安全問題我們知道在一般情況下，只有無狀態的Bean才可以在多線程環境下共享，在Spring中，絕大部分Bean都可以聲明為singleton作用域。就是因為Spring對一些Bean（如RequestContextHolder、TransactionSynchronizationManager、LocaleContextHolder等）中非線程安全狀態采用ThreadLocal進行處理，讓它們也成為線程安全的狀態，因為有狀態的Bean就可以在多線程中共享了。

　　一般的Web應用劃分為展現層、服務層和持久層三個層次，在不同的層中編寫對應的邏輯，下層通過接口向上層開放功能調用。在一般情況下，從接收請求到返回響應所經過的所有程序調用都同屬於一個線程，如圖9?2所示：

技術分享

　　同一線程貫通三層這樣你就可以根據需要，將一些非線程安全的變量以ThreadLocal存放，在同一次請求響應的調用線程中，所有關聯的對象引用到的都是同一個變量。

　　下面的實例能夠體現Spring對有狀態Bean的改造思路：

代碼清單3 TestDao：非線程安全

[java] view plain copy print?技術分享技術分享
  1. package com.test;
  3. import java.sql.Connection;
  4. import java.sql.SQLException;
  5. import java.sql.Statement;
  7. public class TestDao {
  8. private Connection conn;// ①一個非線程安全的變量
  10. public void addTopic() throws SQLException {
  11. Statement stat = conn.createStatement();// ②引用非線程安全變量
  12. // …
  13. }
  14. }



由於①處的conn是成員變量，因為addTopic()方法是非線程安全的，必須在使用時創建一個新TopicDao實例（非singleton）。下面使用ThreadLocal對conn這個非線程安全的“狀態”進行改造：

代碼清單4 TestDao：線程安全

[java] view plain copy print?技術分享技術分享
  1. package com.test;
  3. import java.sql.Connection;
  4. import java.sql.SQLException;
  5. import java.sql.Statement;
  7. public class TestDaoNew {
  8. // ①使用ThreadLocal保存Connection變量
  9. private static ThreadLocal<Connection> connThreadLocal = new ThreadLocal<Connection>();
  11. public static Connection getConnection() {
  12. // ②如果connThreadLocal沒有本線程對應的Connection創建一個新的Connection，
  13. // 並將其保存到線程本地變量中。
  14. if (connThreadLocal.get() == null) {
  15. Connection conn = getConnection();
  16. connThreadLocal.set(conn);
  17. return conn;
  18. } else {
  19. return connThreadLocal.get();// ③直接返回線程本地變量
  20. }
  21. }
  23. public void addTopic() throws SQLException {
  24. // ④從ThreadLocal中獲取線程對應的Connection
  25. Statement stat = getConnection().createStatement();
  26. }
  27. }

　　不同的線程在使用TopicDao時，先判斷connThreadLocal.get()是否是null，如果是null，則說明當前線程還沒有對應的Connection對象，這時創建一個Connection對象並添加到本地線程變量中；如果不為null，則說明當前的線程已經擁有了Connection對象，直接使用就可以了。這樣，就保證了不同的線程使用線程相關的Connection，而不會使用其它線程的Connection。因此，這個TopicDao就可以做到singleton共享了。

　　當然，這個例子本身很粗糙，將Connection的ThreadLocal直接放在DAO只能做到本DAO的多個方法共享Connection時不發生線程安全問題，但無法和其它DAO共用同一個Connection，要做到同一事務多DAO共享同一Connection，必須在一個共同的外部類使用ThreadLocal保存Connection。



ConnectionManager.java

[java] view plain copy print?技術分享技術分享
  1. package com.test;
  3. import java.sql.Connection;
  4. import java.sql.DriverManager;
  5. import java.sql.SQLException;
  7. public class ConnectionManager {
  9. private static ThreadLocal<Connection> connectionHolder = new ThreadLocal<Connection>() {
  10. @Override
  11. protected Connection initialValue() {
  12. Connection conn = null;
  13. try {
  14. conn = DriverManager.getConnection(
  15. "jdbc:mysql://localhost:3306/test", "username",
  16. "password");
  17. } catch (SQLException e) {
  18. e.printStackTrace();
  19. }
  20. return conn;
  21. }
  22. };
  24. public static Connection getConnection() {
  25. return connectionHolder.get();
  26. }
  28. public static void setConnection(Connection conn) {
  29. connectionHolder.set(conn);
  30. }
  31. }

java.lang.ThreadLocal<T>的具體實現

那麽到底ThreadLocal類是如何實現這種“為每個線程提供不同的變量拷貝”的呢？先來看一下ThreadLocal的set()方法的源碼是如何實現的：

[java] view plain copy print?技術分享技術分享
  1. /**
  2. * Sets the current thread‘s copy of this thread-local variable
  3. * to the specified value. Most subclasses will have no need to
  4. * override this method, relying solely on the [email protected] #initialValue}
  5. * method to set the values of thread-locals.
  6. *
  7. * @param value the value to be stored in the current thread‘s copy of
  8. * this thread-local.
  9. */
  10. public void set(T value) {
  11. Thread t = Thread.currentThread();
  12. ThreadLocalMap map = getMap(t);
  13. if (map != null)
  14. map.set(this, value);
  15. else
  16. createMap(t, value);
  17. }


在這個方法內部我們看到，首先通過getMap(Thread t)方法獲取一個和當前線程相關的ThreadLocalMap，然後將變量的值設置到這個ThreadLocalMap對象中，當然如果獲取到的ThreadLocalMap對象為空，就通過createMap方法創建。


線程隔離的秘密，就在於ThreadLocalMap這個類。ThreadLocalMap是ThreadLocal類的一個靜態內部類，它實現了鍵值對的設置和獲取（對比Map對象來理解），每個線程中都有一個獨立的ThreadLocalMap副本，它所存儲的值，只能被當前線程讀取和修改。ThreadLocal類通過操作每一個線程特有的ThreadLocalMap副本，從而實現了變量訪問在不同線程中的隔離。因為每個線程的變量都是自己特有的，完全不會有並發錯誤。還有一點就是，ThreadLocalMap存儲的鍵值對中的鍵是this對象指向的ThreadLocal對象，而值就是你所設置的對象了。


為了加深理解，我們接著看上面代碼中出現的getMap和createMap方法的實現：

[java] view plain copy print?技術分享技術分享
  1. /**
  2. * Get the map associated with a ThreadLocal. Overridden in
  3. * InheritableThreadLocal.
  4. *
  5. * @param t the current thread
  6. * @return the map
  7. */
  8. ThreadLocalMap getMap(Thread t) {
  9. return t.threadLocals;
  10. }
  12. /**
  13. * Create the map associated with a ThreadLocal. Overridden in
  14. * InheritableThreadLocal.
  15. *
  16. * @param t the current thread
  17. * @param firstValue value for the initial entry of the map
  18. * @param map the map to store.
  19. */
  20. void createMap(Thread t, T firstValue) {
  21. t.threadLocals = new ThreadLocalMap(this, firstValue);
  22. }


接下來再看一下ThreadLocal類中的get()方法:

[java] view plain copy print?技術分享技術分享
  1. /**
  2. * Returns the value in the current thread‘s copy of this
  3. * thread-local variable. If the variable has no value for the
  4. * current thread, it is first initialized to the value returned
  5. * by an invocation of the [email protected] #initialValue} method.
  6. *
  7. * @return the current thread‘s value of this thread-local
  8. */
  9. public T get() {
  10. Thread t = Thread.currentThread();
  11. ThreadLocalMap map = getMap(t);
  12. if (map != null) {
  13. ThreadLocalMap.Entry e = map.getEntry(this);
  14. if (e != null)
  15. return (T)e.value;
  16. }
  17. return setInitialValue();
  18. }


再來看setInitialValue()方法：

[java] view plain copy print?技術分享技術分享
  1. /**
  2. * Variant of set() to establish initialValue. Used instead
  3. * of set() in case user has overridden the set() method.
  4. *
  5. * @return the initial value
  6. */
  7. private T setInitialValue() {
  8. T value = initialValue();
  9. Thread t = Thread.currentThread();
  10. ThreadLocalMap map = getMap(t);
  11. if (map != null)
  12. map.set(this, value);
  13. else
  14. createMap(t, value);
  15. return value;
  16. }


　　獲取和當前線程綁定的值時，ThreadLocalMap對象是以this指向的ThreadLocal對象為鍵進行查找的，這當然和前面set()方法的代碼是相呼應的。


　　進一步地，我們可以創建不同的ThreadLocal實例來實現多個變量在不同線程間的訪問隔離，為什麽可以這麽做？因為不同的ThreadLocal對象作為不同鍵，當然也可以在線程的ThreadLocalMap對象中設置不同的值了。通過ThreadLocal對象，在多線程中共享一個值和多個值的區別，就像你在一個HashMap對象中存儲一個鍵值對和多個鍵值對一樣，僅此而已。

小結

　　ThreadLocal是解決線程安全問題一個很好的思路，它通過為每個線程提供一個獨立的變量副本解決了變量並發訪問的沖突問題。在很多情況下，ThreadLocal比直接使用synchronized同步機制解決線程安全問題更簡單，更方便，且結果程序擁有更高的並發性。

ConnectionManager.java

[java] view plain copy print?技術分享技術分享
  1. package com.test;
  3. import java.sql.Connection;
  4. import java.sql.DriverManager;
  5. import java.sql.SQLException;
  7. public class ConnectionManager {
  9. private static ThreadLocal<Connection> connectionHolder = new ThreadLocal<Connection>() {
  10. @Override
  11. protected Connection initialValue() {
  12. Connection conn = null;
  13. try {
  14. conn = DriverManager.getConnection(
  15. "jdbc:mysql://localhost:3306/test", "username",
  16. "password");
  17. } catch (SQLException e) {
  18. e.printStackTrace();
  19. }
  20. return conn;
  21. }
  22. };
  24. public static Connection getConnection() {
  25. return connectionHolder.get();
  26. }
  28. public static void setConnection(Connection conn) {
  29. connectionHolder.set(conn);
  30. }
  31. }

後記

　　看到網友評論的很激烈，甚至關於ThreadLocalMap不是ThreadLocal裏面的，而是Thread裏面的這種評論都出現了，於是有了這個後記，下面先把jdk源碼貼上，源碼最有說服力了。

[java] view plain copy print?技術分享技術分享
  1. /**
  2. * ThreadLocalMap is a customized hash map suitable only for
  3. * maintaining thread local values. No operations are exported
  4. * outside of the ThreadLocal class. The class is package private to
  5. * allow declaration of fields in class Thread. To help deal with
  6. * very large and long-lived usages, the hash table entries use
  7. * WeakReferences for keys. However, since reference queues are not
  8. * used, stale entries are guaranteed to be removed only when
  9. * the table starts running out of space.
  10. */
  11. static class ThreadLocalMap {...}

　　源碼就是以上，這源碼自然是在ThreadLocal裏面的，有截圖為證。

技術分享

　　本文是自己在學習ThreadLocal的時候，一時興起，深入看了源碼，思考了此類的作用、使用範圍，進而聯想到對傳統的synchronize共享變量線程安全的問題進行比較，而總結的博文，總結一句話就是一個是鎖機制進行時間換空間，一個是存儲拷貝進行空間換時間。

徹底理解ThreadLocal

相關推薦

徹底理解ThreadLocal

pass 進行 tps rem spec 區別 tablet dea 覆蓋 ThreadLocal是什麽 　　早在JDK 1.2的版本中就提供Java.lang.ThreadLocal，ThreadLocal為解決多線程程序的並發問題提供了一種新的思路。使用這個工具類可以很

【多執行緒】徹底理解ThreadLocal

徹底理解ThreadLocal 知其然 synchronized這類執行緒同步的機制可以解決多執行緒併發問題，在這種解決方案下，多個執行緒訪問到的，都是同一份變數的內容。為了防止在多執行緒訪問的過程中，可能會出現的併發錯誤。不得不對多個執行緒的訪問進行同步，這樣也就意味

十分鐘徹底理解javascript 的 this指向，不懂請砸店

hub 改變 alert blog var rip def 徹底 文章 函數的this指向誰，和函數在哪裏被定義的，函數在哪裏被執行的沒有半毛錢關系，只遵守下面的規律： 在非嚴格模式中： 1、自執行函數裏面，this永遠指向window; <script

c++引用和指針的徹底理解

內容操作 nbsp 容易 不必要 別名 影響 sof 的確 設置 ★ 相同點： 1. 都是地址的概念； 指針指向一塊內存，它的內容是所指內存的地址；引用是某塊內存的別名。 ★ 區別： 1. 指針是一個實體，而引用僅是個別名； 2.

字符編碼詳解——徹底理解掌握編碼知識，“亂碼”不復存在

想法 3.3 無符號 orm 微軟公司 詳解 表示 xxxxxx 全部 每一個程序員都不可避免的遇到字符編碼的問題，特別是做Web開發的程序員，“亂碼問題”一直是讓人頭疼的問題，也許您已經很少遇到“亂碼”問題，然而，對解決亂碼的方法的內在原理，您是否明白？本人作為一個程序員

從源碼理解 ThreadLocal()

com 完整性 ref () get details 為什麽 blank target 每一反應，使用Thread中定義一個成員變量來解決 線程局部變量問題； 為什麽要使用ThreadLocal()，有什麽好處； 單例的完整性； 解決了線程上下文中的變量傳遞問題，達到線

【字符編碼】徹底理解字符編碼

-1 常用 最終 大寫 而且 transform bmp develop 基礎上 一、前言 　　在解決昨天的問題時，又引出了很多新的問題，如為什麽要進行編碼，這些編碼的關系如何，如ASCII，IOS-8859-1，GB2312，GBK，Unicode之間的關系，筆者想要徹底

徹底理解webservice SOAP WSDL

組網 二進制 config tool teams 開發工具 不用 應用 windows 7 原文： http://wenku.baidu.com/view/f87b55f19e31433239689314.html WebServices簡介 先給出一個概念 SOA ，

親自實驗讓你徹底理解表連接

lec 一個人 相同 bsp 技術 指定 個人 add 冗余 1.表連接的根本條件是共同字段，也叫關聯字段也叫冗余字段，有關聯字段（冗余字段）才能將兩張表的記錄匹配起來嘛。 其中關聯字段，也即形成了表之間的關系，即1對1，還是1對多，還是多對多。 這些表之間的關系，就是

js 徹底理解回調函數

pan sharp 變量名 支持 exec tex 傳參 彈出 csharp 一、前奏 在談回調函數之前，先看下下面兩段代碼： 不妨猜測一下代碼的結果。 function say (value) { alert(value); } alert(say); aler

Vue之徹底理解自定義組件的v-model

自動 value tro 需要 this 變量 mode type 自定義 最近在學習vue，今天看到自定義事件的表單輸入組件，糾結了一會會然後恍然大悟...官方教程寫得不是很詳細，所以我決定總結一下。 v-model語法糖 v-model實現了表單輸入的雙向綁定，我們

徹底理解線程同步與同步代碼塊synchronized

size 靜態方法 就是 pub open 多個 lee gif except 1 public class Demo { 2 public static synchronized void fun1(){ 3 } 4 public sy

徹底理解數據庫事物

ransac 日誌 保存 計算機 變化 事務提交 並發執行 數據庫數據 對數 事務 事務(Transaction)，一般是指要做的或所做的事情。在計算機術語中是指訪問並可能更新數據庫中各種數據項的一個程序執行單元(unit)。在計算機術語中，事務通常就是指數據庫事務。 概念

[數據庫事務與鎖]詳解一: 徹底理解數據庫事務

存儲 數量 情況 一個數 就是 可能 發生 http 舉例 註明: 本文轉載自http://www.hollischuang.com/archives/898 事務 事務(Transaction)，一般是指要做的或所做的事情。在計算機術語中是指訪問並可能更新數據庫中各種

徹底理解 Android 中的陰影

eight 是什麽 tin 角度 閱讀 ron 深入 public 空白 如果我們想創造更好的 Android App，我相信我們需要遵循 Material Design 的設計規範。一般而言，Material Design 是一個包含光線，材質和投影的三維環境。如果我們想

系統調用徹底理解

跟蹤 cast long protect pan 生成 檢查 ati div 用戶程序需要系統提供服務的時候，會通過系統調用產生一個int 0x80的軟中斷，就會進入到系統調用的入口函數，入口函數存放在以下文件當中： 以下是系統調用的入口： ENTRY(system_c

[OpenCV學習]徹底理解卷積的含義

clas enc 成了 學習 元素 open mage .com com 看了很多關於卷積的介紹,一直感覺不怎麽理解,今天徹底研究下: 我們知道圖像是由像素構成的,圖像中的行和列一起構成了圖像矩陣,比如一個分辨率800*400的圖像,同時也是一個大矩陣,這個矩陣有著40

徹底理解正則表達式

inf 數量 com 固定 條件 abc image 中括號 font 正則表達式 一、聲明有兩種方式： 　　1、內置對象創建， 2、字面量創建 二、正則表達式的組成 　　由一些普通字符和元字符組成，普通字符就是字母和數字，元字符是具有特殊意義的字符 三、正則表達式

徹底理解Java的Future模式（轉）

技術分享 sse 數據結構 ride create GC .get AR 補充 先上一個場景：假如你突然想做飯，但是沒有廚具，也沒有食材。網上購買廚具比較方便，食材去超市買更放心。 實現分析：在快遞員送廚具的期間，我們肯定不會閑著，可以去超市買食材。所以，在主線程裏面另起

看完讓你徹底理解 WebSocket 原理，附完整的實戰代碼（包含前端和後端）

tcp 協議 learn php 握手 live 雙向 簡單 再次 註意 1、前言 最近有同學問我有沒有做過在線咨詢功能。同時，公司也剛好讓我接手一個 IM 項目。所以今天抽時間記錄一下最近學習的內容。本文主要剖析了 WebSocket 的原理，以及附上一個完整的聊天室實戰