日本综合一区二区|亚洲中文天堂综合|日韩欧美自拍一区|男女精品天堂一区|欧美自拍第6页亚洲成人精品一区|亚洲黄色天堂一区二区成人|超碰91偷拍第一页|日韩av夜夜嗨中文字幕|久久蜜综合视频官网|精美人妻一区二区三区

RELATEED CONSULTING
相關(guān)咨詢
選擇下列產(chǎn)品馬上在線溝通
服務(wù)時間：8:30-17:00
你可能遇到了下面的問題
關(guān)閉右側(cè)工具欄

新聞中心

這里有您想知道的互聯(lián)網(wǎng)營銷解決方案
ThreadLocal：線程專屬的變量

一、ThreadLocal 簡介

ThreadLocal是 java 提供的一個方便對象在本線程內(nèi)不同方法中傳遞和獲取的類。用它定義的變量，僅在本線程中可見和維護(hù)，不受其他線程的影響，與其他線程相互隔離。

成都創(chuàng)新互聯(lián)公司服務(wù)項(xiàng)目包括鼓樓網(wǎng)站建設(shè)、鼓樓網(wǎng)站制作、鼓樓網(wǎng)頁制作以及鼓樓網(wǎng)絡(luò)營銷策劃等。多年來，我們專注于互聯(lián)網(wǎng)行業(yè)，利用自身積累的技術(shù)優(yōu)勢、行業(yè)經(jīng)驗(yàn)、深度合作伙伴關(guān)系等，向廣大中小型企業(yè)、政府機(jī)構(gòu)等提供互聯(lián)網(wǎng)行業(yè)的解決方案，鼓樓網(wǎng)站推廣取得了明顯的社會效益與經(jīng)濟(jì)效益。目前，我們服務(wù)的客戶以成都為中心已經(jīng)輻射到鼓樓省份的部分城市，未來相信會繼續(xù)擴(kuò)大服務(wù)區(qū)域并繼續(xù)獲得客戶的支持與信任！

那 ThreadLocal 到底解決了什么問題，又適用于什么樣的場景?

  • This class provides thread-local variables. These variables differ from their normal counterparts in that each thread that accesses one (via its get or set method) has its own, independently initialized copy of the variable. ThreadLocal instances are typically private static fields in classes that wish to associate state with a thread (e.g., a user ID or Transaction ID). Each thread holds an implicit reference to its copy of a thread-local variable as long as the thread is alive and the ThreadLocal instance is accessible; after a thread goes away, all of its copies of thread-local instances are subject to garbage collection (unless other references to these copies exist).

核心意思是

ThreadLocal 提供了線程本地的實(shí)例。它與普通變量的區(qū)別在于，每個使用該變量的線程都會初始化一個完全獨(dú)立的實(shí)例副本。ThreadLocal 變量通常被private static修飾。當(dāng)一個線程結(jié)束時，它所使用的所有 ThreadLocal 相對的實(shí)例副本都可被回收。

總的來說，ThreadLocal 適用于每個線程需要自己獨(dú)立的實(shí)例且該實(shí)例需要在多個方法中被使用，也即變量在線程間隔離而在方法或類間共享的場景。后文會通過實(shí)例詳細(xì)闡述該觀點(diǎn)。另外，該場景下，并非必須使用 ThreadLocal ，其它方式完全可以實(shí)現(xiàn)同樣的效果，只是 ThreadLocal 使得實(shí)現(xiàn)更簡潔。

二、ThreadLocal 使用

ThreadLocal 通過 set 方法可以給變量賦值，通過 get 方法獲取變量的值。當(dāng)然，也可以在定義變量時通過 ThreadLocal.withInitial 方法給變量賦初始值，或者定義一個繼承 ThreadLocal 的類，然后重寫 initialValue 方法。

下面通過如下代碼說明 ThreadLocal 的使用方式：

 
 
 
 
    
  
  
  
  
  1. public class TestThreadLocal 
    2. 
  
  
  
  
  2. { 
    3. 
  
  
  
  
  3.     private static ThreadLocal builder = ThreadLocal.withInitial(StringBuilder::new); 
    4. 
  
  
  
  
  4.  
    5. 
  
  
  
  
  5.     public static void main(String[] args) 
    6. 
  
  
  
  
  6.     { 
    7. 
  
  
  
  
  7.         for (int i = 0; i < 5; i++) 
    8. 
  
  
  
  
  8.         { 
    9. 
  
  
  
  
  9.             new Thread(() -> { 
    10. 
  
  
  
  
  10.                 String threadName = Thread.currentThread().getName(); 
    11. 
  
  
  
  
  11.                 for (int j = 0; j < 3; j++) 
    12. 
  
  
  
  
  12.                 { 
    13. 
  
  
  
  
  13.                     append(j); 
    14. 
  
  
  
  
  14.                     System.out.printf("%s append %d, now builder value is %s, ThreadLocal instance hashcode is %d, ThreadLocal instance mapping value hashcode is %d\n", threadName, j, builder.get().toString(), builder.hashCode(), builder.get().hashCode()); 
    15. 
  
  
  
  
  15.                 } 
    16. 
  
  
  
  
  16.  
    17. 
  
  
  
  
  17.                 change(); 
    18. 
  
  
  
  
  18.                 System.out.printf("%s set new stringbuilder, now builder value is %s, ThreadLocal instance hashcode is %d, ThreadLocal instance mapping value hashcode is %d\n", threadName, builder.get().toString(), builder.hashCode(), builder.get().hashCode()); 
    19. 
  
  
  
  
  19.             }, "thread-" + i).start(); 
    20. 
  
  
  
  
  20.         } 
    21. 
  
  
  
  
  21.     } 
    22. 
  
  
  
  
  22.  
    23. 
  
  
  
  
  23.     private static void append(int num) { 
    24. 
  
  
  
  
  24.         builder.get().append(num); 
    25. 
  
  
  
  
  25.     } 
    26. 
  
  
  
  
  26.  
    27. 
  
  
  
  
  27.     private static void change() { 
    28. 
  
  
  
  
  28.         StringBuilder newStringBuilder = new StringBuilder("HelloWorld"); 
    29. 
  
  
  
  
  29.         builder.set(newStringBuilder); 
    30. 
  
  
  
  
  30.     } 
    31. 
  
  
  
  
  31. } 
    32.

在例子中，定義了一個 builder 的 ThreadLocal 對象，然后啟動 5 個線程，分別對 builder 對象進(jìn)行訪問和修改操作，這兩個操作放在兩個不同的函數(shù) append、change 中進(jìn)行，兩個函數(shù)訪問 builder 對象也是直接獲取，而不是放入函數(shù)的入?yún)⒅袀鬟f進(jìn)來。

代碼輸出如下:

 
 
 
 
    
  
  
  
  
  1. thread-0 append 0, now builder value is 0, ThreadLocal instance hashcode is 796465865, ThreadLocal instance mapping value hashcode is 566157654 
    2. 
  
  
  
  
  2. thread-0 append 1, now builder value is 01, ThreadLocal instance hashcode is 796465865, ThreadLocal instance mapping value hashcode is 566157654 
    3. 
  
  
  
  
  3. thread-4 append 0, now builder value is 0, ThreadLocal instance hashcode is 796465865, ThreadLocal instance mapping value hashcode is 654647086 
    4. 
  
  
  
  
  4. thread-3 append 0, now builder value is 0, ThreadLocal instance hashcode is 796465865, ThreadLocal instance mapping value hashcode is 1803363945 
    5. 
  
  
  
  
  5. thread-2 append 0, now builder value is 0, ThreadLocal instance hashcode is 796465865, ThreadLocal instance mapping value hashcode is 1535812498 
    6. 
  
  
  
  
  6. thread-1 append 0, now builder value is 0, ThreadLocal instance hashcode is 796465865, ThreadLocal instance mapping value hashcode is 2075237830 
    7. 
  
  
  
  
  7. thread-2 append 1, now builder value is 01, ThreadLocal instance hashcode is 796465865, ThreadLocal instance mapping value hashcode is 1535812498 
    8. 
  
  
  
  
  8. thread-3 append 1, now builder value is 01, ThreadLocal instance hashcode is 796465865, ThreadLocal instance mapping value hashcode is 1803363945 
    9. 
  
  
  
  
  9. thread-4 append 1, now builder value is 01, ThreadLocal instance hashcode is 796465865, ThreadLocal instance mapping value hashcode is 654647086 
    10. 
  
  
  
  
  10. thread-0 append 2, now builder value is 012, ThreadLocal instance hashcode is 796465865, ThreadLocal instance mapping value hashcode is 566157654 
    11. 
  
  
  
  
  11. thread-0 set new stringbuilder, now builder value is HelloWorld, ThreadLocal instance hashcode is 796465865, ThreadLocal instance mapping value hashcode is 1773033190 
    12. 
  
  
  
  
  12. thread-4 append 2, now builder value is 012, ThreadLocal instance hashcode is 796465865, ThreadLocal instance mapping value hashcode is 654647086 
    13. 
  
  
  
  
  13. thread-4 set new stringbuilder, now builder value is HelloWorld, ThreadLocal instance hashcode is 796465865, ThreadLocal instance mapping value hashcode is 700642750 
    14. 
  
  
  
  
  14. thread-3 append 2, now builder value is 012, ThreadLocal instance hashcode is 796465865, ThreadLocal instance mapping value hashcode is 1803363945 
    15. 
  
  
  
  
  15. thread-3 set new stringbuilder, now builder value is HelloWorld, ThreadLocal instance hashcode is 796465865, ThreadLocal instance mapping value hashcode is 1706743158 
    16. 
  
  
  
  
  16. thread-2 append 2, now builder value is 012, ThreadLocal instance hashcode is 796465865, ThreadLocal instance mapping value hashcode is 1535812498 
    17. 
  
  
  
  
  17. thread-2 set new stringbuilder, now builder value is HelloWorld, ThreadLocal instance hashcode is 796465865, ThreadLocal instance mapping value hashcode is 1431127699 
    18. 
  
  
  
  
  18. thread-1 append 1, now builder value is 01, ThreadLocal instance hashcode is 796465865, ThreadLocal instance mapping value hashcode is 2075237830 
    19. 
  
  
  
  
  19. thread-1 append 2, now builder value is 012, ThreadLocal instance hashcode is 796465865, ThreadLocal instance mapping value hashcode is 2075237830 
    20. 
  
  
  
  
  20. thread-1 set new stringbuilder, now builder value is HelloWorld, ThreadLocal instance hashcode is 796465865, ThreadLocal instance mapping value hashcode is 1970695360 
    21.
  • 從輸出中 1~6 行可以看出，不同線程訪問的是同一個 builder 對象(不同線程輸出的 ThreadLocal instance hashcode 值相同)，但是每個線程獲得的 builder 對象存儲的實(shí)例 StringBuilder 不同(不同線程輸出的 ThreadLocal instance mapping value hashcode值不相同)。
  • 從輸出中1~2、9~10 行可以看出，同一個線程中修改 builder 對象存儲的實(shí)例的值時，并不會影響到其他線程的 builder 對象存儲的實(shí)例(thread-4 線程改變存儲的 StringBuilder 的值并不會引起 thread-0 線程的 ThreadLocal instance mapping value hashcode 值發(fā)生改變)
  • 從輸出中 9~13 行可以看出，一個線程對 ThreadLocal 對象存儲的值發(fā)生改變時，并不會影響其他的線程(thread-0 線程調(diào)用 set 方法改變本線程 ThreadLocal 存儲的對象值，本線程的 ThreadLocal instance mapping value hashcode 發(fā)生改變，但是 thread-4 的 ThreadLocal instance mapping value hashcode 并沒有因此改變)。

三、ThreadLocal 原理

ThreadLocal 能在每個線程間進(jìn)行隔離，其主要是靠在每個 Thread 對象中維護(hù)一個 ThreadLocalMap 來實(shí)現(xiàn)的。因?yàn)槭蔷€程中的對象，所以對其他線程不可見，從而達(dá)到隔離的目的。那為什么是一個 Map 結(jié)構(gòu)呢。主要是因?yàn)橐粋€線程中可能有多個 ThreadLocal 對象，這就需要一個集合來進(jìn)行存儲區(qū)分，而用 Map 可以更快地查找到相關(guān)的對象。ThreadLocalMap 是 ThreadLocal 對象的一個靜態(tài)內(nèi)部類，內(nèi)部維護(hù)一個 Entry 數(shù)組，實(shí)現(xiàn)類似 Map 的 get 和 put 等操作，為簡單起見，可以將其看做是一個 Map，其中 key 是 ThreadLocal 實(shí)例，value 是 ThreadLocal 實(shí)例對象存儲的值。

ThreadLocalMap

四、ThreadLocal 適用場景

如上文所述，ThreadLocal 適用于如下場景：

每個線程需要有自己單獨(dú)的實(shí)例，如實(shí)現(xiàn)每個線程單例類或每個線程上下文信息(例如事務(wù)ID)。

ThreadLocal 適用于變量在線程間隔離且在方法間共享的場景，提供了另一種擴(kuò)展 Thread 的方法。如果要保留信息或?qū)⑿畔囊粋€方法調(diào)用傳遞到另一個方法，則可以使用 ThreadLocal 進(jìn)行傳遞。

由于不需要修改任何方法，因此可以提供極大的靈活性。

1、案例一

這里一個處理 flag 的類，通過 ThreadLocal 使用，可以保證每個請求都擁有唯一的一個追蹤標(biāo)記。

 
 
 
 
    
  
  
  
  
  1. public class TestFlagHolder { 
    2. 
  
  
  
  
  2.  
    3. 
  
  
  
  
  3.   private final static ThreadLocal TEST_FLAG = new ThreadLocal<>(); 
    4. 
  
  
  
  
  4.  
    5. 
  
  
  
  
  5.   public static void set(String value) { 
    6. 
  
  
  
  
  6.     TEST_FLAG.set(value); 
    7. 
  
  
  
  
  7.   } 
    8. 
  
  
  
  
  8.  
    9. 
  
  
  
  
  9.   public static String get() { 
    10. 
  
  
  
  
  10.     return TEST_FLAG.get(); 
    11. 
  
  
  
  
  11.   } 
    12. 
  
  
  
  
  12.  
    13. 
  
  
  
  
  13.   public static String get4log() { 
    14. 
  
  
  
  
  14.     if (TEST_FLAG.get() == null) { 
    15. 
  
  
  
  
  15.       return "-"; 
    16. 
  
  
  
  
  16.     } 
    17. 
  
  
  
  
  17.     return TEST_FLAG.get(); 
    18. 
  
  
  
  
  18.   } 
    19. 
  
  
  
  
  19.  
    20. 
  
  
  
  
  20.   public static void remove() { 
    21. 
  
  
  
  
  21.     TEST_FLAG.remove(); 
    22. 
  
  
  
  
  22.   } 
    23. 
  
  
  
  
  23.  
    24. 
  
  
  
  
  24. } 
    25.

2、案例二

在同一線程中 trace 信息的傳遞：

 
 
 
 
    
  
  
  
  
  1. ThreadLocal traceContext = new ThreadLocal<>(); 
    2. 
  
  
  
  
  2.  
    3. 
  
  
  
  
  3. String traceId = Tracer.startServer(); 
    4. 
  
  
  
  
  4. traceContext.set(traceId) //生成trace信息 傳入threadlocal 
    5. 
  
  
  
  
  5. ... 
    6. 
  
  
  
  
  6. Tracer.startClient(traceContext.get()); //從threadlocal獲取trace信息 
    7. 
  
  
  
  
  7. Tracer.endClient(); 
    8. 
  
  
  
  
  8. ... 
    9. 
  
  
  
  
  9. Tracer.endServer(); 
    10.

3、案例三

給同一個請求的每一行日志增加一個相同的標(biāo)記。這樣，只要拿到這個標(biāo)記就可以查詢到這個請求鏈路上所有步驟的耗時了，我們把這個標(biāo)記叫做 requestId，我們可以在程序的入口處生成一個 requestId，然后把它放在線程的上下文中，這樣就可以在需要時隨時從線程上下文中獲取到 requestId 了。

簡單的代碼實(shí)現(xiàn)就像下面這樣：

 
 
 
 
    
  
  
  
  
  1. String requestId = UUID.randomUUID().toString(); 
    2. 
  
  
  
  
  2. ThreadLocal tl = new ThreadLocal(){ 
    3. 
  
  
  
  
  3.     @Override 
    4. 
  
  
  
  
  4.     protected String initialValue() { 
    5. 
  
  
  
  
  5.         return requestId; 
    6. 
  
  
  
  
  6.     } 
    7. 
  
  
  
  
  7. }; //requestId存儲在線程上下文中 
    8. 
  
  
  
  
  8. long start = System.currentTimeMillis(); 
    9. 
  
  
  
  
  9. processA(); 
    10. 
  
  
  
  
  10. Logs.info("rid : " + tl.get() + ", process A cost " + (System.currentTimeMillis() - start)); // 日志中增加requestId 
    11. 
  
  
  
  
  11. start = System.currentTimeMillis(); 
    12. 
  
  
  
  
  12. processB(); 
    13. 
  
  
  
  
  13. Logs.info("rid : " + tl.get() + ", process B cost " + (System.currentTimeMillis() - start)); 
    14. 
  
  
  
  
  14. start = System.currentTimeMillis(); 
    15. 
  
  
  
  
  15. processC(); 
    16. 
  
  
  
  
  16. Logs.info("rid : " + tl.get() + ", process C cost " + (System.currentTimeMillis() - start)); 
    17.

有了 requestId，你就可以清晰地了解一個調(diào)用鏈路上的耗時分布情況了。

五、小結(jié)

無論是單體系統(tǒng)還是微服務(wù)化架構(gòu)，無論是鏈路打標(biāo)還是服務(wù)追蹤，你都需要在系統(tǒng)中增加 TraceId，這樣可以將你的鏈路串起來，給你呈現(xiàn)一個完整的問題場景。如果 TraceId 可以在客戶端上生成，在請求業(yè)務(wù)接口的時候傳遞給服務(wù)端，那么就可以把客戶端的日志體系也整合進(jìn)來，對于問題的排查幫助更大。

同時，在全鏈路壓測框架中，Trace 信息的傳遞功能是基于 ThreadLocal 的。但實(shí)際業(yè)務(wù)中可能會使用異步調(diào)用，這樣就會丟失 Trace 信息，破壞了鏈路的完整性。所以在實(shí)際的項(xiàng)目建議大家不要輕意使用 ThreadLocal。

參考資料：

[1]：《高并發(fā)系統(tǒng)設(shè)計(jì)40問》

[2]：https://juejin.cn/post/6844904016288317448#heading-6

本文轉(zhuǎn)載自微信公眾號「7DGroup」，可以通過以下二維碼關(guān)注。轉(zhuǎn)載本文請聯(lián)系7DGroup公眾號。


名稱欄目：ThreadLocal：線程專屬的變量
文章位置：http://www.dlmjj.cn/article/ccedpgd.html