亚洲香蕉成人av网站在线观看_欧美精品成人91久久久久久久_久久久久久久久久久亚洲_热久久视久久精品18亚洲精品_国产精自产拍久久久久久_亚洲色图国产精品_91精品国产网站_中文字幕欧美日韩精品_国产精品久久久久久亚洲调教_国产精品久久一区_性夜试看影院91社区_97在线观看视频国产_68精品久久久久久欧美_欧美精品在线观看_国产精品一区二区久久精品_欧美老女人bb

首頁 > 學院 > 開發設計 > 正文

Netty學習之旅----ThreadLocal原理分析與性能優化思考(思考篇)

2019-11-10 17:40:49
字體:
來源:轉載
供稿:網友
1、java.lang.ThreadLocal概況ThreadLocal,本地線程變量,每個線程保留著一個共享變量的副本。其實我不太認可每個線程保存共享變量的一個副本這個說法,而是ThreadLocal是線程上下文環境的一種實現方式而已。就以數據庫事務這一常用場景來舉例說明,比如每個線程需要訪問數據庫,就需要獲取數據庫的連接Connection對象,在實際中,我們會用數據庫連接池來重復利用Connection,首先線程池,這里是一個共享變量,線程池的實現必須保證多個線程同時從線程池中獲取Connection不會重復,然后每個線程使用單獨的Connection,并且該Connection被一個線程占用后,其他線程壓根就不會使用到,也不會試圖去使用一個已經被其他線程占用的Connection對象。由于一個線程在執行過程中,可能需要多次操作數據庫,所以我們的設計就是一個線程在執行過程中,只與一個Connection打交道,也就是整個線程的執行過程(執行環境)需要保存剛獲取的Connection,最簡單有效的辦法,就是把這個Connection保存在線程對象的某個屬性中,ThreadLocal就是干這事的。ThreadLocal并不是為這個Connection復制一份,多個線程都使用這個副本,不是這樣的,一個Connection對象在任意時刻,沒有被復制多份。我的觀點:ThreadLocal是線程一個本地變量,是線程的執行上下文。2、 從ThreadLocal get方法源碼分析其實現邏輯
/**     * Returns the value in the current thread's copy of this     * thread-local variable.  If the variable has no value for the     * current thread, it is first initialized to the value returned     * by an invocation of the {@link #initialValue} method.     *     * @return the current thread's value of this thread-local     */    public T get() {        Thread t = Thread.currentThread();    //@1        ThreadLocalMap map = getMap(t);   //@2        if (map != null) {            ThreadLocalMap.Entry e = map.getEntry(this);     //@3            if (e != null)                return (T)e.value;        }        return setInitialValue();                      // @4    }代碼@1,獲取當前線程。代碼@2,從當前線程獲取ThreadLocalMap,ThreadLocalMap getMap(Thread t) {        return t.threadLocals;    },這里是直接返回線程對象的threadLocals變量,有點意思吧,所以說ThreadLocal,是線程的本地變量,就是這層意思,真正存放數據的地方,就是線程對象本身,其實接下來的會更加有意思:我們進入ThreadLocalMap源碼分析,得知,原來ThreadLocalMap就是一個Map結構(K-V)鍵值對,關于里面的源碼就不一一分析了,ThreadLocalMap(ThreadLocal firstKey, Object firstValue),firstKey 為ThreadLocal,神奇吧,其實這也是為什么Thread的本地變量的數據類型為Map的原型,一個線程可以被多個ThreadLocal關聯,每聲明一個,就在線程的threadLocals增加為一個鍵值對,key 為 ThreadLocal,而value為具體存放的對象。代碼@3,如果線程的ThreadLocalMap不為空,則直接返回對,否則進入到代碼@4代碼@4,初始化并獲取放入ThreadLocal中的變量。上面就是ThreadLocal的核心設計理念,為了更加直觀的說明ThreadLocal原理,舉例說明:
-----------------------------------------------------------------------public class ThreadLocalDemo1 {   PRivate static final ThreadLocal<String> schemaLocal           = new ThreadLocal<String>();    public void test1() {        String a = schemaLocal.get();        ThreadLocalDemo2 demo2 = new ThreadLocalDemo2();        demo2.test(a);    }    public static void main(String[] args) {        // TODO Auto-generated method stub    }}public class ThreadLocalDemo2 {  private static final ThreadLocal<String> slocal = new ThreadLocal<String>();    public void test(String b) {        String a = slocal.get();        // 其他代碼        System.out.println(b);    }    public static void main(String[] args) {        // TODO Auto-generated method stub    }}public class TestMain {    public static void main(String[] args) {        // TODO Auto-generated method stub        ThreadLocalDemo1 d = new ThreadLocalDemo1();        d.test1();    }}//一個線程調用 ThreadLocalDemo1 的 test1方法,在這個執行鏈中會涉及到兩個ThreadLocal變量,調用ThreadLocal的get方法,首先會獲取當前線程,然后從當前線程對象中獲取線程內部屬性[ThreadLocal.ThreadLocalMap threadLocals = null;],然后從ThreadLocalMap中以ThreadLocal對象為鍵,從threadLocals map中獲取存放的值。線程的threadLocals值為{     ThreadLocalDemo1.schemaLocal  : 該變量中的值,     ThreadLocalDemo2.scloal : 存放在本線程中的值   }------------------------------------------------------------------------------------3、 ThreadLocal優化思考    ThreadLocal的數據訪問算法,本質上就是Map的訪問特性。 我在分析HashMap源碼的時候,已經將HashMap的存儲結構講解完畢,如有興趣,可以瀏覽一下我的博文:深入理解HashMap:http://blog.csdn.net/prestigeding/article/details/52861420,HashMap根據key的訪問速度效率是很快的,為什么呢?因為HashMap根據key的hash,然后會定位到內部的數據槽(該數據是數組結構),眾所周知,根據數組的下標訪問,訪問速度是最快的,也就是說HashMap根據key的定位速度比LinkedList等都快,僅次于數組訪問方式,這是因為HashMap多了一步Hash定位槽的過程(當然,如果有Hash沖突那就更慢了)。所以,如果在高并發場景下,需要進一步優化ThreadLocal的訪問性能,那就要從線程對象(Thread的threadLocals 數據結構下手了,如果能將數據結構修改為數組,然后每個ThreadLocal對象維護其下標那就完美了)。是的,Netty框架就是為了高并發而生的,由于并發訪問的數量很大,一點點的性能優化,就會帶來可觀的性能提升效應,Netty主要從如下兩個方面對ThreadLocal的實現進行優化1)線程對象直接提供 set、get方法,以便直接獲取線程本地存儲相關的變量屬性。2)將數據存儲基于數組存儲。4、Netty關于ThreadLocal機制的優化由于ThreadLocal是JDK的原生實現,通用性很強,直接擴展進行定制化不是明智的選擇,故Netty在優化ThreadLocal的方式是自己另起灶爐,實現ThreadLocal的語義。優化方法如下:1)提供一個接口,FastThreadLocalaccess,并對線程池工廠類進行定制,創建的線程繼承在java.lang.Thread類,并實現FastThreadLocalAccess接口,提供直接設置,獲取線程本地變量的方法。2)提供FastThreadLocal類,此類實現ThreadLocal相同的語義。3)提供InternalThreadLocalMap類,此類作用類同于java.lang.ThreadLocal.ThreadLocalMap類,用于線程存放真實數據的結構。4.1 擴展線程對象,提供set,get方法     通過定制的線程池工廠,創建的線程對象為擴展后的線程對象,在Netty中對應為FastThreadLocalThread,該類本身很簡單,值得大家注意的是其思想,jdk并發包中提供的線程池實現機制中,提供了線程創建的工廠的擴展點,這里就是其典型的實踐。     這里附上其源碼,不做解讀:
public class FastThreadLocalThread extends Thread implements FastThreadLocalAccess {    private InternalThreadLocalMap threadLocalMap;    public FastThreadLocalThread() { }    public FastThreadLocalThread(Runnable target) {        super(target);    }    public FastThreadLocalThread(ThreadGroup group, Runnable target) {        super(group, target);    }    public FastThreadLocalThread(String name) {        super(name);    }    public FastThreadLocalThread(ThreadGroup group, String name) {        super(group, name);    }    public FastThreadLocalThread(Runnable target, String name) {        super(target, name);    }    public FastThreadLocalThread(ThreadGroup group, Runnable target, String name) {        super(group, target, name);    }    public FastThreadLocalThread(ThreadGroup group, Runnable target, String name, long stackSize) {        super(group, target, name, stackSize);    }    /**     * Returns the internal data structure that keeps the thread-local variables bound to this thread.     * Note that this method is for internal use only, and thus is subject to change at any time.     */    @Override    public final InternalThreadLocalMap threadLocalMap() {        return threadLocalMap;    }    /**     * Sets the internal data structure that keeps the thread-local variables bound to this thread.     * Note that this method is for internal use only, and thus is subject to change at any time.     */    @Override    public final void setThreadLocalMap(InternalThreadLocalMap threadLocalMap) {        this.threadLocalMap = threadLocalMap;    }}4.2 FastThreadLocal與InternalThreadLocalMapInternalThreadLocalMap是線程存儲本地變量的數據結構,每個線程擁有自己的InternalThreadLocalMap,其作用與java.lang.ThreadLocal.ThreadLocalMap內部類一樣,而FastThreadLocal,其語義與ThreadLocal一樣,對外表現與ThreadLocal一樣。再次重復一下,Netty的InternalThreadLocalMap內部為數組,為什么是數組呢?線程本地變量,要從線程的執行流的角度看,一個線程在執行過程中,會經過多個類,會有多個類中聲明有線程本地變量(參考上文說明ThreadLocal時候的舉例),所以此處的數組就是保留線程在整個線程的執行過程中,不同的ThreadLocal變量中保存不同的數據,java.lang.ThreadLocal.ThreadLocalMap內部類的實現使用map結構,鍵為 ThreadLocal對象,而值為真正保存的變量值,InternalThreadLocalMap既然是數組,數組是一維的,數組最終肯定只能保存 真正要保持的變量值,那怎么區分不同的ThreadLocal在InternalThreadLocalMap中的下標呢?Netty采用的方式是將下標保存在FastThreadLocal中,我們知道,一般使用本地線程變量,FastThreadLocal的聲明方式,一般是類變量(靜態變量),諸如:private static final ThreadLocal aThreadLocal = new ThreadLocal();整個系統ThreadLocal的個數其實不會很多,每個FastThreadLocal在InternalThreadLocalMap的下標(偏移量)在FastThreadLocal加載時候確定,并保持不變。并且每個InternalThreadLocal內部數組的第一元素,存放系統運行中的FastThreadLocal對象。InternalThreadLocalMap的內部數據結構為:/** Used by {@link FastThreadLocal} */Object[] indexedVariables;現在舉例說明上述理論,比如整個項目,有A,B,C,D,E5個類中各聲明了一個靜態的FastThreadLocal變量,類的加載順序為  A , B  , D, E, C那們 類A中的FastThreadLocal存放在線程變量InternalThreadLocalMap的下標為1,B,為2,D為3,依次內推,比如線程 T1,在一次請求過程中,需要用的A,E,C三個類中的FastThreadLocalMap,那么線程T1,的InternalThreadLocalMap的水庫中的下標為1為A,下標為2,3的元素為空,下標為4為E,下標5存放C中的變量值。每個線程InternalThreadLocalMap下標為0的是一Set集合,存放的是系統運行中有效的FastThreadLocal變量。根據這樣的存放后,FastThreadLocal 的get,set方法,都是根據下標直接在InternalThreadLocalMap的數組中直接存儲,當然,值得一提的是InternalThreadLocalMap中數組元素長度默認為32,如果系統的FastThreadLocal的數量超過32個的話,會成倍擴容。FastThreadLocal學習的入口,建議從set,get方法入手即可,知道上述原理后,源碼的閱讀應該比較容易,就不做過多講解了。    如果愿意分享技術心得,歡迎加群:互聯網技術交流群 34265357
發表評論 共有條評論
用戶名: 密碼:
驗證碼: 匿名發表
亚洲香蕉成人av网站在线观看_欧美精品成人91久久久久久久_久久久久久久久久久亚洲_热久久视久久精品18亚洲精品_国产精自产拍久久久久久_亚洲色图国产精品_91精品国产网站_中文字幕欧美日韩精品_国产精品久久久久久亚洲调教_国产精品久久一区_性夜试看影院91社区_97在线观看视频国产_68精品久久久久久欧美_欧美精品在线观看_国产精品一区二区久久精品_欧美老女人bb
欧美激情一区二区三区成人| 国产狼人综合免费视频| 欧美成人午夜激情视频| 亚洲欧美国产精品| 精品久久久av| 亚洲视频在线观看网站| 久久久国产影院| 日韩成人网免费视频| 欧美成人免费播放| 91av视频在线免费观看| 亚洲电影成人av99爱色| 欧美亚洲日本黄色| 欧美日韩国产精品| 亚洲精品国产精品久久清纯直播| 精品久久国产精品| 欧美激情乱人伦一区| 精品国产鲁一鲁一区二区张丽| 国产美女搞久久| 欧美又大又粗又长| 国产精品黄视频| 日韩在线播放视频| 按摩亚洲人久久| 97欧美精品一区二区三区| 欧美性猛交xxxx黑人猛交| 国产精品久久久久久久久久久久久| 欧美片一区二区三区| 中文字幕久热精品在线视频| 日韩国产精品一区| 亚洲欧美国产精品专区久久| 欧美日韩国产999| 久久亚洲国产精品成人av秋霞| 国产精品美女呻吟| 欧美精品在线观看| 欧美性感美女h网站在线观看免费| 国产日韩欧美中文在线播放| 欧美视频在线视频| 国产欧美日韩综合精品| 日本一区二区在线播放| 国产在线一区二区三区| 亚洲天堂男人天堂| 欧美日韩中文字幕日韩欧美| 欧美日韩亚洲精品内裤| 色偷偷噜噜噜亚洲男人的天堂| 中文字幕9999| 亚洲第一区中文99精品| 精品久久国产精品| 亚洲一区二区三区sesese| 91国自产精品中文字幕亚洲| 欧美日韩在线视频首页| 成人欧美一区二区三区黑人孕妇| 欧美丝袜美女中出在线| 欧美激情按摩在线| 日本sm极度另类视频| 国产午夜精品理论片a级探花| 国产成人涩涩涩视频在线观看| 亚洲人精品午夜在线观看| 欧美视频在线视频| 91精品久久久久久久久久久| 中文精品99久久国产香蕉| 北条麻妃在线一区二区| 国产欧美韩国高清| 久久亚洲精品毛片| 97**国产露脸精品国产| 亚洲自拍欧美另类| 91欧美视频网站| xvideos国产精品| 国产精品男女猛烈高潮激情| 日韩免费在线看| 欧美裸体xxxx极品少妇软件| 91网站免费看| 久久精品成人欧美大片| 欧美日韩精品在线播放| 亚洲性日韩精品一区二区| 欧美日韩国产色| 欧美视频国产精品| 欧美日韩裸体免费视频| 日韩中文av在线| 国产97在线|亚洲| 都市激情亚洲色图| 亚洲tv在线观看| 欧美又大又硬又粗bbbbb| 疯狂做受xxxx高潮欧美日本| 国产精品一区二区电影| 亚洲成人免费网站| 亚洲成年人在线| 欧美性xxxx极品hd满灌| 精品成人久久av| 精品欧美国产一区二区三区| 欧美日韩国产一区中文午夜| 国产va免费精品高清在线| 色妞在线综合亚洲欧美| 久久国产精品99国产精| 91精品在线一区| 热99精品只有里视频精品| 久久久91精品国产一区不卡| 国产成人精品av在线| 亚洲国产成人精品一区二区| 国模精品视频一区二区三区| 欧美亚洲在线观看| 国产精品麻豆va在线播放| 亚洲国产欧美一区二区三区同亚洲| 茄子视频成人在线| 国产裸体写真av一区二区| 日本免费在线精品| 欧美中文字幕在线观看| 欧美激情xxxx性bbbb| 国产啪精品视频| 日韩av不卡电影| 日韩欧美高清视频| 日韩成人在线视频观看| 成人观看高清在线观看免费| 亚洲黄一区二区| 国产精品大片wwwwww| 美女黄色丝袜一区| 97在线视频免费| 韩国三级日本三级少妇99| 一本大道亚洲视频| 亚洲aa中文字幕| 久久免费视频网站| 久久精品国产亚洲7777| 欧美夜福利tv在线| 精品国产乱码久久久久久婷婷| 在线观看国产欧美| 国产日本欧美一区| 亚洲一区二区三区久久| 欧美精品免费在线观看| 亚洲欧美成人一区二区在线电影| 亚洲国产欧美久久| 日韩美女毛茸茸| 色婷婷久久一区二区| www.欧美三级电影.com| 日韩欧美a级成人黄色| 国产网站欧美日韩免费精品在线观看| 国产v综合ⅴ日韩v欧美大片| 久久国产精品网站| 亚洲精品动漫久久久久| 久久久精品中文字幕| 亚洲毛片在线观看.| 亚洲人成电影网| 成人av资源在线播放| 国内揄拍国内精品| 97视频在线观看免费| 久久韩国免费视频| 色偷偷亚洲男人天堂| 久久成年人视频| 91久久国产精品91久久性色| 日韩欧美第一页| 国产成人avxxxxx在线看| 国产一区二区视频在线观看| 国产精品久久久久久久久久ktv| 国产精品久久久久久av| 欧美老妇交乱视频| 国产欧美日韩中文字幕在线| 日韩在线视频国产| 国产香蕉一区二区三区在线视频| 欧美成人午夜激情| 亚洲欧美一区二区三区在线| 欧美一区二区.| 中文.日本.精品| 国产成人av在线播放| 欧美激情奇米色| 国产精品视频999| 久久久国产一区| 2025国产精品视频|