解讀ThreadLocal

1 什么是ThreadLocal

ThreadLocal全闷,翻譯過來总珠,就是"線程本地變量",它是從JDK1.2開始提供的一個(gè)類姚淆,它能夠?yàn)椴煌木€程提供單獨(dú)的變量副本腌逢,使得當(dāng)在不同的線程調(diào)用變量的時(shí)候互不干擾。

從名字可以得到兩個(gè)關(guān)鍵信息搏讶,

線程——該對(duì)象是被線程所持有的媒惕;

本地變量——這個(gè)變量作用域在線程內(nèi);

2 ThreadLocal給夠給我們帶來什么

  1. 解決多線程下的資源競(jìng)爭(zhēng)問題妒蔚;
  2. 全局共享變量月弛;

2.1 解決多線程下的資源競(jìng)爭(zhēng)問題

假如有一個(gè)動(dòng)物園帽衙,猴子那個(gè)扎堆啊 = = , 管理員那個(gè)扎心啊 T_T。開始的時(shí)候恍飘,整個(gè)猴子園就一只碗,每次猴子要吃香蕉的時(shí)候就在碗里放一只香蕉母蛛。碗就相當(dāng)于向園長(zhǎng)(操作系統(tǒng))申請(qǐng)的空間乳怎,就只有一個(gè)啦舞肆,每只猴子(線程)應(yīng)該都有自己的一根香蕉(變量)博杖。

如果照正常情況下椿胯,管理員要避免猴子們爭(zhēng)奪食物,會(huì)讓猴子們排隊(duì)剃根,一只猴子一只猴子的喂哩盲,每次往碗里放一根香蕉。排一長(zhǎng)隊(duì)狈醉,猴子當(dāng)然痛恨要抗議啊廉油,因?yàn)橛行┖镒映缘寐竺娴暮镒雍飳O就等不住了苗傅。管理員也要耗費(fèi)相當(dāng)?shù)臅r(shí)間抒线,管理員也郁悶。

于是渣慕,管理員干脆向園長(zhǎng)申請(qǐng)了又一批碗逊桦,干脆一個(gè)猴子一只碗算了睡陪。這時(shí)候兰迫,一只猴子一只碗逮矛,互不干擾须鼎,喂猴子的時(shí)間節(jié)約了不少汞窗。

ThreadLocal就是這么一個(gè)情況仲吏,為每一個(gè)線程都創(chuàng)建一個(gè)線程本地的變量來存儲(chǔ)數(shù)據(jù),當(dāng)線程需要使用的時(shí)候直接取出來用就可以了许帐。而不必?fù)?dān)心變量被其他的線程所篡改成畦。

2.2 共享變量

這個(gè)也很好理解循帐。給每個(gè)猴子分配一只碗以后,猴子要怎么使用這個(gè)碗衷旅,完全由他自己決定柿顶,有碗嘁锯,真的可以玩所欲為的,他想什么時(shí)候用他就什么時(shí)候用仁锯,碗里的香蕉他想什么時(shí)候吃他就什么時(shí)候吃业崖。

與之類似狞悲,線程中一旦存了具體的數(shù)據(jù)摇锋,只要在線程內(nèi)部,什么時(shí)候取出來都可以死相。有時(shí)候參數(shù)傳遞不是最佳的解決方案,那么就設(shè)置一個(gè)全局變量吧钮惠,比如在View層設(shè)置一個(gè)變量素挽,然后在Service層再取出來用。是不是有點(diǎn)像緩存呢撰糠?

2.3 如何使用

如這個(gè)例子所示:

    private static void testThreaLoacl(){

        final ThreadLocal<String> tl = new ThreadLocal<String>();

        String threadName = Thread.currentThread().getName();
        tl.set(threadName);

        new Thread(){
            @Override
            public void run() {
                System.out.println("---------start");
                String name = tl.get();
                System.out.println(name);
                System.out.println("---------end");

            }
        }.start();

        String name = tl.get();
        System.out.println(name);

    }

運(yùn)行結(jié)果:

---------start
null
---------start
main
  • 先new出一個(gè)ThreadLocal對(duì)象,然后直接set進(jìn)去value,然后在想要使用的地方使用就可以了术辐;
  • 因?yàn)樽兞渴蔷€程內(nèi)部獨(dú)享的。當(dāng)在main線程set的時(shí)候瑞躺,在子線程中是無法獲取到main線程set的值的隘蝎。

3 經(jīng)典使用場(chǎng)景

很多框架匯總都可以看到ThreadLocal的影子狮含。

? 1.Spring中的事務(wù)控制几迄。大致的流程是

向數(shù)據(jù)庫獲取一個(gè)Connnection,然后存到ThreadLocal中去解孙,然后調(diào)用業(yè)務(wù)方法,最后再從ThreadLocal中取出Connnection廷臼,commit荠商!

? 2.playFrameWork1.0中的請(qǐng)求參數(shù)。

可能很多寶寶都不知道PlayFrameWork!酷鸦,它是一個(gè)java的全棧式框架啦,然后略略略(講不完)….在它的1.0版本中属铁,請(qǐng)求參數(shù)在整個(gè)MVC三層都可以輕松取得,如盒发,Params.params拼卵,原因只是因?yàn)樗鼜囊婚_始就將請(qǐng)求參數(shù)存到ThreadLocal里面去了雀彼。

4 使用ThreadLocal需要注意什么

  1. ThreadLocal并不能保證數(shù)據(jù)是安全的徊哑。而且,看一下源碼就可以發(fā)現(xiàn)梢莽。

        /**
         * ThreadLocalMap is a customized hash map suitable only for
         * maintaining thread local values. No operations are exported
         * outside of the ThreadLocal class. The class is package private to
         * allow declaration of fields in class Thread.  To help deal with
         * very large and long-lived usages, the hash table entries use
         * WeakReferences for keys. However, since reference queues are not
         * used, stale entries are guaranteed to be removed only when
         * the table starts running out of space.
         */
    static class ThreadLocalMap {
            static class Entry extends WeakReference<ThreadLocal> {
                /** The value associated with this ThreadLocal. */
                Object value;
                Entry(ThreadLocal k, Object v) {
                    super(k);
                    value = v;
                }
            }
    
    

    ThreadLocal內(nèi)部使用到了一個(gè)ThreadLocalMap,具體的數(shù)據(jù)就是存在里面的Entry膜钓,而這個(gè)Entry是被定義為WeakReference弱引用的,注釋也說明了:為了避免變量的生命周期太長(zhǎng),所以采用弱引用司蔬,來確保在特定情況下能夠釋放這部分的空間。

  2. 容易造成代碼耦合授帕。切勿濫用彤路。畢竟每個(gè)線程都要為之分配空間屏轰,如果把ThreadLocal當(dāng)緩存使用姆吭,遲早要內(nèi)存溢出的。而且,共享變量的使用是先set,然后再get昂灵,如果你的某個(gè)方法中在get到這個(gè)共享變量,不然就會(huì)報(bào)錯(cuò),那你可能無法確保此時(shí)這個(gè)變量已經(jīng)被set了甘晤,甚至于,前面有人已經(jīng)set了共享變量,但是你并不知道虹脯,為了保險(xiǎn),你又作為一個(gè)參數(shù)傳了進(jìn)來咒彤。

    例1:

        static final ThreadLocal<String> tl = new ThreadLocal<String>();
    
        public void method1() {
            tl.set("哦呼~");
            method2();
        }
        public void method2(){
            System.out.println(tl.get().toString());
        }
    

    可以看到模叙,method1中已經(jīng)set了變量故觅,然后method2直接從ThreadLocal中獲取并使用替蛉,如果method1中沒有set呢它浅?method2就一定會(huì)出現(xiàn)空指針異常怎静。method1根本就不知道調(diào)用method2要先set!這種情況下method1和method2之間的耦合度太高了!

    怎么改塘装?就按照正常的寫法就好啦。

    例2:

        public void method11(String value) {
            method22(value);
        }
    
        public void method22(String value){
            System.out.println(value.toString());
        }
    

    通過參數(shù)傳遞的參數(shù)傳遞進(jìn)來就好啦勺阐。此時(shí)议忽,method11很輕易就知道他需要傳參數(shù)毛雇,那么就會(huì)將要打印的參數(shù)傳進(jìn)來(這里不考慮傳Null)壳繁。

  3. 使用ThreadLocal后,當(dāng)線程復(fù)用時(shí)可能會(huì)帶來一些副作用

    看如下代碼:

public static void testThreadLocal2() {
    final ThreadLocal<String> tl = new ThreadLocal<String>();

    ExecutorService service = Executors.newFixedThreadPool(1);

    service.submit(new Runnable() {
        public void run() {
            tl.set("hello");
        }
    });

    service.submit(new Runnable() {
        public void run() {
            String name = tl.get();
            System.out.println(name);
        }
    });

    service.shutdown();
}

運(yùn)行結(jié)果:

hello

當(dāng)在一個(gè)線程池內(nèi)部,只有的幾個(gè)線程的時(shí)候皂冰,有很大概率會(huì)出現(xiàn)線程復(fù)用的情況柳弄。此時(shí)糖赔,同一個(gè)線程的ThrealLocal是會(huì)被窺視到。

上述代碼中,我們以為第一個(gè)Runnable任務(wù)set的"hello",居然被第二個(gè)Runnable任務(wù)給get出來了声怔。這不一定是我們預(yù)期的。

就比如,spring中,為了防止請(qǐng)求過多丽猬,我們可能會(huì)限制線程池的數(shù)量强饮。當(dāng)A用戶的請(qǐng)求進(jìn)來了行您,使用了a線程,此時(shí)a中的ThreadLocal已經(jīng)被set了value妈经,此時(shí)第B用戶的請(qǐng)求進(jìn)來了,假如a線程被復(fù)用了洞难,那么B用戶中可以直接讀到a線程中A用戶set下的value潭袱。這里的數(shù)據(jù)就沒有被有效隔離開來。是絕對(duì)危險(xiǎn)的嘉抓!

所以幕屹,使用了ThreadLocal之后,務(wù)必要記得清理ThreadLocal...

5 源碼概覽

  1. ThreadLocal的基本組成

    public class ThreadLocal<T> {
        private final int threadLocalHashCode = nextHashCode();
    
     private static AtomicInteger nextHashCode =
            new AtomicInteger();
           
          ...
          
        public T get() {...}
        
        public void set(T value) {...}
        
        public void remove() {...}
        
        ...
        
        static class ThreadLocalMap {
         ...
         Entry(ThreadLocal k, Object v) {
                    super(k);
                    value = v;
             }
             
             ...
             
         static class Entry extends WeakReference<ThreadLocal> {...}
         private Entry[] table;
         ...
        }
    
     ...
    
    }
    
        public class Thread implements Runnable {
         ...
             ThreadLocal.ThreadLocalMap threadLocals = null;
             ...
         }
    
    

    可以看到:

    • 每個(gè)Thread中盔沫,都有一個(gè)變量ThreadLocalMap類型的變量threadLocals,threadLocals用來存放ThreadLocal很泊;
    • ThreadLocalMap中有一個(gè)變量叫做table,是一個(gè)Entry類型的數(shù)組。用于存放不同的ThreadLocal所對(duì)應(yīng)的key。一個(gè)Thread可能存在很多ThreadLocal隶债,它們都存在table里面继蜡,一個(gè)ThreadLocal將會(huì)對(duì)應(yīng)一個(gè)table的下標(biāo)仅颇;
    • 每個(gè)ThreadLocal被初始化的時(shí)候引颈,都會(huì)先去初始化它內(nèi)部final類型的threadLocalHashCode。threadLocalHashCode用于確定這個(gè)ThreadLocal在Thread中變量Entry數(shù)組table的下標(biāo)。下標(biāo)的唯一性是通過nextHashCode來確保的,它是一個(gè)AtomicInteger類型變量。
  1. get():
  /**
     * Sets the current thread's copy of this thread-local variable
     * to the specified value.  Most subclasses will have no need to
     * override this method, relying solely on the {@link #initialValue}
     * method to set the values of thread-locals.
     *
     * @param value the value to be stored in the current thread's copy of
     *        this thread-local.
     */
    public void set(T value) {
        Thread t = Thread.currentThread();
        ThreadLocalMap map = getMap(t);
        if (map != null)
            map.set(this, value);
        else
            createMap(t, value);
    }

可以看到皆尔,set方法中先嘗試拿到當(dāng)前線程的ThreadLocalMap食呻,然后設(shè)值剑辫。如果沒有,創(chuàng)建一個(gè),并設(shè)值。

createMap:


    /**
     * Create the map associated with a ThreadLocal. Overridden in
     * InheritableThreadLocal.
     *
     * @param t the current thread
     * @param firstValue value for the initial entry of the map
     * @param map the map to store.
     */
    void createMap(Thread t, T firstValue) {
        t.threadLocals = new ThreadLocalMap(this, firstValue);
    }

創(chuàng)建ThreadLocalMap也很簡(jiǎn)單,就是new出來,然后將引用交給當(dāng)前線程持有,這里就可以發(fā)現(xiàn)埃撵,實(shí)際上谣拣,ThreadLocal中的數(shù)據(jù),其實(shí)是保存在當(dāng)前線程內(nèi)部的列肢。

  1. 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();
        ThreadLocalMap map = getMap(t);
        if (map != null) {
            ThreadLocalMap.Entry e = map.getEntry(this);
            if (e != null)
                return (T)e.value;
        }
        return setInitialValue();
    }

通過getMap()拿到當(dāng)前線程的ThreadLocalMap,然后從table中取出對(duì)應(yīng)的Entry,返回里面的數(shù)據(jù)即可。

{
??spa太難SEO,我的網(wǎng)站完全木有人???♀?
所以不要臉的過來 簡(jiǎn)書 打廣告了...

[sonny的博客](http://chings.cn/article/detail/14)

歡迎光臨~~~
}

sonny的博客

最后編輯于
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請(qǐng)聯(lián)系作者
  • 序言:七十年代末蓝撇,一起剝皮案震驚了整個(gè)濱河市走搁,隨后出現(xiàn)的幾起案子,更是在濱河造成了極大的恐慌湖员,老刑警劉巖唤反,帶你破解...
    沈念sama閱讀 223,207評(píng)論 6 521
  • 序言:濱河連續(xù)發(fā)生了三起死亡事件,死亡現(xiàn)場(chǎng)離奇詭異般哼,居然都是意外死亡楞卡,警方通過查閱死者的電腦和手機(jī)藕各,發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 95,455評(píng)論 3 400
  • 文/潘曉璐 我一進(jìn)店門竭讳,熙熙樓的掌柜王于貴愁眉苦臉地迎上來成黄,“玉大人荸百,你說我怎么就攤上這事女嘲⊥=叮” “怎么了蚓挤?”我有些...
    開封第一講書人閱讀 170,031評(píng)論 0 366
  • 文/不壞的土叔 我叫張陵甲捏,是天一觀的道長(zhǎng)大溜。 經(jīng)常有香客問我,道長(zhǎng),這世上最難降的妖魔是什么? 我笑而不...
    開封第一講書人閱讀 60,334評(píng)論 1 300
  • 正文 為了忘掉前任苏潜,我火速辦了婚禮贰锁,結(jié)果婚禮上物咳,老公的妹妹穿的比我還像新娘压鉴。我一直安慰自己,他們只是感情好,可當(dāng)我...
    茶點(diǎn)故事閱讀 69,322評(píng)論 6 398
  • 文/花漫 我一把揭開白布区宇。 她就那樣靜靜地躺著柿隙,像睡著了一般波附。 火紅的嫁衣襯著肌膚如雪然评。 梳的紋絲不亂的頭發(fā)上亿眠,一...
    開封第一講書人閱讀 52,895評(píng)論 1 314
  • 那天,我揣著相機(jī)與錄音,去河邊找鬼诵次。 笑死遵堵,一個(gè)胖子當(dāng)著我的面吹牛壳坪,可吹牛的內(nèi)容都是我干的蝎亚。 我是一名探鬼主播缤底,決...
    沈念sama閱讀 41,300評(píng)論 3 424
  • 文/蒼蘭香墨 我猛地睜開眼鳖枕,長(zhǎng)吁一口氣:“原來是場(chǎng)噩夢(mèng)啊……” “哼灭翔!你這毒婦竟也來了?” 一聲冷哼從身側(cè)響起链嘀,我...
    開封第一講書人閱讀 40,264評(píng)論 0 277
  • 序言:老撾萬榮一對(duì)情侶失蹤,失蹤者是張志新(化名)和其女友劉穎糯而,沒想到半個(gè)月后诺祸,有當(dāng)?shù)厝嗽跇淞掷锇l(fā)現(xiàn)了一具尸體,經(jīng)...
    沈念sama閱讀 46,784評(píng)論 1 321
  • 正文 獨(dú)居荒郊野嶺守林人離奇死亡答恶,尸身上長(zhǎng)有42處帶血的膿包…… 初始之章·張勛 以下內(nèi)容為張勛視角 年9月15日...
    茶點(diǎn)故事閱讀 38,870評(píng)論 3 343
  • 正文 我和宋清朗相戀三年悟狱,在試婚紗的時(shí)候發(fā)現(xiàn)自己被綠了。 大學(xué)時(shí)的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片。...
    茶點(diǎn)故事閱讀 40,989評(píng)論 1 354
  • 序言:一個(gè)原本活蹦亂跳的男人離奇死亡,死狀恐怖,靈堂內(nèi)的尸體忽然破棺而出硼身,到底是詐尸還是另有隱情荚板,我是刑警寧澤唧席,帶...
    沈念sama閱讀 36,649評(píng)論 5 351
  • 正文 年R本政府宣布掉弛,位于F島的核電站壁晒,受9級(jí)特大地震影響秒咐,放射性物質(zhì)發(fā)生泄漏雷滋。R本人自食惡果不足惜姆坚,卻給世界環(huán)境...
    茶點(diǎn)故事閱讀 42,331評(píng)論 3 336
  • 文/蒙蒙 一兔辅、第九天 我趴在偏房一處隱蔽的房頂上張望。 院中可真熱鬧,春花似錦勉失、人聲如沸顽素。這莊子的主人今日做“春日...
    開封第一講書人閱讀 32,814評(píng)論 0 25
  • 文/蒼蘭香墨 我抬頭看了看天上的太陽荣月。三九已至,卻和暖如春槐脏,著一層夾襖步出監(jiān)牢的瞬間喉童,已是汗流浹背。 一陣腳步聲響...
    開封第一講書人閱讀 33,940評(píng)論 1 275
  • 我被黑心中介騙來泰國(guó)打工顿天, 沒想到剛下飛機(jī)就差點(diǎn)兒被人妖公主榨干…… 1. 我叫王不留堂氯,地道東北人。 一個(gè)月前我還...
    沈念sama閱讀 49,452評(píng)論 3 379
  • 正文 我出身青樓牌废,卻偏偏與公主長(zhǎng)得像咽白,于是被迫代替她去往敵國(guó)和親。 傳聞我的和親對(duì)象是個(gè)殘疾皇子鸟缕,可洞房花燭夜當(dāng)晚...
    茶點(diǎn)故事閱讀 45,995評(píng)論 2 361

推薦閱讀更多精彩內(nèi)容