成人免费xxxxx在线视频软件_久久精品久久久_亚洲国产精品久久久_天天色天天色_亚洲人成一区_欧美一级欧美三级在线观看

InheritableThreadLocal異步傳遞數據實現原理

開發 前端
在Java中,一個Java線程就是一個操作系統線程,創建一個線程需要通過new Thread創建,由JVM為Thread綁定操作系統線程,即便是使用線程池,也需要通過new Thread創建線程。

由于上次主要分析如何解決異步獲取不到Session問題,所以沒有展開分析留下的那個思考題:使用InheritableThreadLocal傳遞Session,為什么說使用線程池不一定能獲取到Session,而不是一定獲取不到?

在Java中,一個Java線程就是一個操作系統線程,創建一個線程需要通過new Thread創建,由JVM為Thread綁定操作系統線程,即便是使用線程池,也需要通過new Thread創建線程。

Thread類有兩個ThreadLocal字段:

  1. public class Thread implements Runnable { 
  2.     ThreadLocal.ThreadLocalMap threadLocals = null
  3.     ThreadLocal.ThreadLocalMap inheritableThreadLocals = null

InheritableThreadLocal是ThreadLocal的子類,本質上就是一個ThreadLocal。

在Thread類中,threadLocals與inheritableThreadLocals都是線程對象私有的,只能通過當前線程對象寫入和獲取數據,只是Thread會將寫入inheritableThreadLocals的數據傳遞給子線程的inheritableThreadLocals。

當我們往ThreadLocal或者InheritableThreadLocal寫入數據時,寫入過程為:

  • 1、ThreadLocal或者InheritableThreadLocal先調用Thread#currentThread靜態方法獲取當前線程的Thread對象;
  • 2、獲取Thread對象的threadLocals或者inheritableThreadLocals;
  • 3、將ThreadLocal或者InheritableThreadLocal對象作為key,將數據寫入到當前Thread對象的threadLocals或者inheritableThreadLocals字段中。

因此,Thread的threadLocals與inheritableThreadLocals的key是ThreadLocal或者InheritableThreadLocal實例,value是寫入的數據。

關于threadLocals我在前面一篇《反向理解ThreadLocal,或許這樣更容易理解》已經詳細介紹過了,本篇重點分析inheritableThreadLocals是如何傳遞給子線程的。

默認情況下,當我們使用new Thread()創建一個線程時,在Thread的構造方法中會通過Thread#currentThread獲取當前線程,將當前線程作為新創建線程的父線程,所以就有了父子線程關系。

無論使用哪個重載的構造方法創建Thread,都會在構造方法中調用init方法完成初始化為Thread字段賦值,而init方法中有這樣一段代碼:

  1. private void init(ThreadGroup g, Runnable target, String name
  2.                       long stackSize, AccessControlContext acc, 
  3.                       boolean inheritThreadLocals) { 
  4.         ...... 
  5.         if (inheritThreadLocals && parent.inheritableThreadLocals != null
  6.             this.inheritableThreadLocals = 
  7.                 ThreadLocal.createInheritedMap(parent.inheritableThreadLocals); 
  8.        ...... 

在init方法中,由于inheritThreadLocals參數默認為true,所以只要父線程的inheritableThreadLocals字段不為空,就copy一份父線程的inheritableThreadLocals給當前創建的線程對象,這就實現了將父線程的inheritableThreadLocals存儲的數據傳遞給子線程。

使用InheritableThreadLocal我們不得不考慮的問題:內存泄漏。

ThreadLocal.ThreadLocalMap使用數組存儲元素,與HashMap不同,它通過開放定址法解決hash沖突,不存在鏈表,通過動態擴容數組可無限存儲元素,數組元素的類型為Entry。

當我們往ThreadLocal.ThreadLocalMap寫入一個key-value時,ThreadLocalMap把key和value包裝成一個Entry,并通過key的hashcode值計算索引值,將Entry放到數組中。

ThreadLocal.ThreadLocalMap.Entry類的源碼如下:

  1. static class Entry extends WeakReference<ThreadLocal<?>> { 
  2.    Object value; 
  3.    Entry(ThreadLocal<?> k, Object v) { 
  4.        super(k); 
  5.        value = v; 
  6.    } 

雖然key為弱引用的ThreadLocal,當ThreadLocal釋放時,Entry的key變為null,但由于value還在,如果Thread不釋放,那么Entry也就不會被垃圾收集器回收。

但如果線程是臨時創建的,在方法中創建且沒有被其它地方引用,當線程執行完成時就會被JVM銷毀,在線程實際退出之前由JVM調用線程的exit方法給線程對象完成清理。exit方法部分源碼如下。

  1. private void exit() { 
  2.     ...... 
  3.     threadLocals = null
  4.     inheritableThreadLocals = null
  5.     ...... 

因此,只要Thread對象的exit方法被調用,就不會存在內存泄漏問題。只要線程用完就銷毀,那么使用InheritableThreadLocal,在子線程中不需要調用InheritableThreadLocal的remove方法也不會存在內存泄漏的可能。

比如我們在項目中使用InheritableThreadLocal實現將Session傳遞給子線程:

  1. @GetMapping("/test"
  2. public SsoUser test() { 
  3.     // 獲取登錄用戶 
  4.     SsoUser ssoUser = SsoUserManager.curLoggedUser(); 
  5.     System.out.println(ssoUser.getUserCode()); 
  6.     // 支持子線程傳遞 
  7.     new Thread(() -> { 
  8.         try { 
  9.             Thread.sleep(100); 
  10.             SsoUser ssoUser2 = SsoUserManager.curLoggedUser(); 
  11.             System.out.println(ssoUser2.getUserCode()); 
  12.         } catch (InterruptedException e) { 
  13.         } 
  14.     }).start(); 
  15.     return ssoUser; 

在此案例中,由于子線程只是臨時創建的,所以我們不需要在子線程中調用InheritableThreadLocal的remove方法,只需要在父線程調用一次remove方法,因為tomcat的work線程是不會在一次請求結束后就銷毀的。

現在我們已經知道了InheritableThreadLocal是如何實現將數據傳遞給子線程的,思考題的答案也就有了一半:由于InheritableThreadLocal只能將線程上下文傳遞給當前線程創建的子線程,所以只有線程池中的線程是由當前線程創建的才能夠傳遞。

但要知道另一半答案我們還需要從線程池中尋找。

使用不同參數構建的線程池不同,常見的有單線程的線程池、只有固定數量核心線程的線程池、有固定數量核心線程和非核心線程的線程池、只有非核心線程的線程池。

線程池的幾個構造參數說明如下:

  • corePoolSize:核心線程數,不會被釋放的線程數量(設置allowCoreThreadTimeOut為ture時例外);
  • maximumPoolSize:線程池的最大線程數,等于核心線程與非核心線程的數量總和;
  • keepAliveTime:非核心線程最大空閑等待時間,在指定空閑時間后如果還沒有任務則釋放該線程;
  • workQueue:任務隊列,當核心線程數用完時,任務被放入隊列。

一、線程池是臨時線程池

如果線程池是在當前線程創建的,且任務都是由當前線程提交的,線程池用完就消毀了,那么不管是哪種線程池,池中的線程都是由當前線程所創建,在這種場景下,InheritableThreadLocal能夠將Context傳給給線程池中的任一線程。

二、線程池是全局線程池

如果線程池是全局線程池:

  • 沒有核心線程且非核心線程的keepAliveTime等于0:線程都是用到才創建,且由于keepAliveTime等于0,線程用完可能就釋放了,在這種場景下,相當于是由當前線程創建子線程執行任務,因此能夠實現透傳;
  • 沒有非核心線程:前(核心線程數)個任務的提交都會創建線程,也都是由當前線程創建,所以只有這幾個任務的執行是能夠正常獲取父線程寫入InheritableThreadLocal的數據的,后面提交的任務就不知道會被哪個核心線程拉取執行了;
  • 其它:....

因此,如果線程池是全局線程池,那么無論是哪個情況,都不建議使

本文轉載自微信公眾號「Java藝術」,可以通過以下二維碼關注。轉載本文請聯系Java藝術公眾號。

 

責任編輯:武曉燕 來源: Java藝術
相關推薦

2024-07-09 08:35:09

2024-11-25 13:49:00

2023-10-07 08:26:40

多線程數據傳遞數據共享

2013-10-18 15:49:15

微軟大數據微軟

2023-01-04 08:38:43

Spring異步線程

2015-05-05 09:50:45

大數據實現塊數據

2010-01-12 14:02:14

VB.NET數據實體層

2014-01-22 11:22:44

華為HANA一體機FusionCube大數據分析

2024-07-03 08:02:19

MySQL數據搜索

2010-01-13 16:52:03

VB.NET導出數據

2025-01-10 10:44:52

2016-09-13 22:46:41

大數據

2020-09-07 11:14:02

Vue異步更新

2011-07-22 09:51:51

iPhone FROM 表單

2017-03-13 09:48:26

pysparkhive數據

2014-09-16 13:33:50

大數據

2020-10-16 11:41:07

攻擊

2022-11-30 18:38:50

數據血緣DataLeap

2020-06-01 15:13:41

騰訊云圖數據庫

2015-07-13 14:27:48

大數據Cloudera價值
點贊
收藏

51CTO技術棧公眾號

主站蜘蛛池模板: 在线观看亚洲欧美 | 免费一区二区三区 | 在线资源视频 | 天天射天天操天天干 | 日韩在线视频一区二区三区 | 久久久精品一区 | 国产高清在线观看 | 91一区 | 99热热热热 | 日本三级全黄三级三级三级口周 | 欧美日韩精品综合 | www四虎影视| 国产精品久久 | 一区二区三区视频在线 | 国产精品色 | www.久久.com| 日韩中文字幕免费在线 | a级片播放| 手机日韩| 精品国产一区二区在线 | 色综合久 | 国产精品成人品 | 国产美女在线精品免费 | 免费观看成人性生生活片 | 国产成人精品综合 | 国产真实精品久久二三区 | 美国一级毛片a | 一区二区三区欧美在线 | 一区二区三区视频在线 | 欧美一级免费观看 | 亚洲精品国产电影 | www.日韩高清 | 一级做a爰片性色毛片16 | 国产精品美女久久久av超清 | 狠狠操婷婷| 在线四虎| 91精产国品一二三区 | 精品视频一区二区 | 黄色在线免费观看 | 免费观看国产视频在线 | 国产精品一区二区视频 |