Java基礎(chǔ)-并發(fā)編程-ThreadLocal使用與原理分析

Java工程師知識樹 / Java基礎(chǔ)


java.lang.ThreadLocal

JDK針對ThreadLocal的描述

public class ThreadLocal<T> 

這個類提供線程局部變量秉氧。 這些變量與其正常的對應(yīng)方式不同,因為訪問一個的每個線程(通過其get或set方法)都有自己獨立初始化的變量副本涂臣。 ThreadLocal實例通常是希望將狀態(tài)與線程關(guān)聯(lián)的類中的私有靜態(tài)字段(例如,用戶ID或事務(wù)ID)侧纯。

解讀:ThreadLocal中填充的變量屬于當前線程骚揍,該變量對其他線程而言是隔離的媳拴。

ThreadLocal實現(xiàn)線程間的數(shù)據(jù)隔離原理:
每個線程對應(yīng)的數(shù)據(jù)存儲在不同的Thread對象的 threadLocals 屬性中,而 threadLocals 屬性是一個ThreadLocal.ThreadLocalMap 對象亥至。
ThreadLocalMap為ThreadLocal的靜態(tài)內(nèi)部類悼沈。其實現(xiàn)是使用一個數(shù)組 private Entry[] table 來保存鍵值對的實體,初始大小為16姐扮,ThreadLocalMap自己實現(xiàn)了如何從 key 到 value 的映射:

int i = firstKey.threadLocalHashCode & (INITIAL_CAPACITY - 1);

使用一個 static 的原子屬性 AtomicInteger nextHashCode絮供,通過每次增加 HASH_INCREMENT = 0x61c88647 ,然后 & (INITIAL_CAPACITY - 1)取得在數(shù)組 private Entry[] table中的索引溶握。

總結(jié):ThreadLoca為每個線程都會分配有一個新的變量對象,在使用時每個線程獲取的對象都是不同的杯缺。

ThreadLocal的使用

ThreadLocal和Synchonized的區(qū)別和聯(lián)系

ThreadLocal和Synchonized都用于解決多線程并發(fā)訪問

但是ThreadLocal與synchronized有本質(zhì)的區(qū)別睡榆。

Synchronized用于線程間的數(shù)據(jù)共享萍肆,而ThreadLocal則用于線程間的數(shù)據(jù)隔離

Synchronized是利用鎖的機制胀屿,使變量或代碼塊在某一時該只能被一個線程訪問塘揣,用于在多個線程間通信時能夠獲得共享資源的同步數(shù)據(jù)。而ThreadLocal為每一個線程都提供了變量的副本宿崭,使得每個線程在某一時間訪問到的并不是同一個對象亲铡,這樣就隔離了多個線程對數(shù)據(jù)的數(shù)據(jù)共享。

ThreadLocal的常見使用場景

當很多線程需要多次使用同一個對象,并且需要該對象具有相同初始化值的時候最適合使用ThreadLocal

比如:

1奖蔓、在進行對象跨層傳遞的時候赞草,使用ThreadLocal可以避免多次傳遞,打破層次間的約束吆鹤。

2厨疙、線程間數(shù)據(jù)隔離

3、進行事務(wù)操作疑务,用于存儲線程事務(wù)信息沾凄。

4、數(shù)據(jù)庫連接知允,Session會話管理撒蟀。

注意事項:使用完ThreadLocal后,執(zhí)行remove操作温鸽,避免出現(xiàn)內(nèi)存溢出情況保屯。

ThreadLocal源碼分析


    //-------set---------    
    public void set(T value) {
        //(1)獲取當前線程(調(diào)用者線程)
        Thread t = Thread.currentThread();
        //(2)以當前線程作為key值,去查找對應(yīng)的線程變量涤垫,找到對應(yīng)的map
        ThreadLocalMap map = getMap(t);
        if (map != null)
            //(3)如果map不為null配椭,就直接添加本地變量,key為當前線程雹姊,值為添加的本地變量值
            map.set(this, value);
        else
            //(4)如果map為null,說明首次添加衡楞,需要首先創(chuàng)建出對應(yīng)的map
            createMap(t, value);
    }

    ThreadLocalMap getMap(Thread t) {
        return t.threadLocals; //獲取線程自己的變量threadLocals吱雏,并綁定到當前調(diào)用線程的成員變量threadLocals上
    }

    void createMap(Thread t, T firstValue) {
        t.threadLocals = new ThreadLocalMap(this, firstValue);
    }

    //-------get---------

    public T get() {
        //(1)獲取當前線程
        Thread t = Thread.currentThread();
        //(2)獲取當前線程的threadLocals變量
        ThreadLocalMap map = getMap(t);
        //(3)如果threadLocals變量不為null,就可以在map中查找到本地變量的值
        if (map != null) {
            ThreadLocalMap.Entry e = map.getEntry(this);
            if (e != null) {
                @SuppressWarnings("unchecked")
                T result = (T)e.value;
                return result;
            }
        }
        //(4)執(zhí)行到此處瘾境,threadLocals為null歧杏,調(diào)用該更改初始化當前線程的threadLocals變量
        return setInitialValue();
    }

    private T setInitialValue() {
        //protected T initialValue() {return null;}
        T value = initialValue();
        //獲取當前線程
        Thread t = Thread.currentThread();
        //以當前線程作為key值,去查找對應(yīng)的線程變量迷守,找到對應(yīng)的map
        ThreadLocalMap map = getMap(t);
        //如果map不為null犬绒,就直接添加本地變量,key為當前線程兑凿,值為添加的本地變量值
        if (map != null)
            map.set(this, value);
        else
            //如果map為null凯力,說明首次添加,需要首先創(chuàng)建出對應(yīng)的map
            createMap(t, value);
        return value;
    }

    //-------remove---------

    public void remove() {
        //獲取當前線程綁定的threadLocals
         ThreadLocalMap m = getMap(Thread.currentThread());
         //如果map不為null礼华,就移除當前線程中指定ThreadLocal實例的本地變量
         if (m != null)
             m.remove(this);
    }

    // 通過靜態(tài)內(nèi)部類實現(xiàn)變量與線程綁定
    static class ThreadLocalMap {...}

使用完ThreadLocal后咐鹤,執(zhí)行remove操作的原因:

每個線程的本地變量存放在自己的本地內(nèi)存變量threadLocals中,如果當前線程一直不消亡圣絮,那么這些本地變量就會一直存在(所以可能會導(dǎo)致內(nèi)存溢出)祈惶,因此使用完畢需要將其remove掉。

應(yīng)用實例

cn.hutool.db.ThreadLocalConnection

//
// Source code recreated from a .class file by IntelliJ IDEA
// (powered by Fernflower decompiler)
//

package cn.hutool.db;

import java.sql.Connection;
import java.sql.SQLException;
import java.util.HashMap;
import java.util.Map;
import javax.sql.DataSource;

public enum ThreadLocalConnection {
    INSTANCE;

    private final ThreadLocal<ThreadLocalConnection.GroupedConnection> threadLocal = new ThreadLocal();//使用ThreadLocal保存Connection變量

    private ThreadLocalConnection() {
    }

    public Connection get(DataSource ds) throws SQLException {
        ThreadLocalConnection.GroupedConnection groupedConnection = (ThreadLocalConnection.GroupedConnection)this.threadLocal.get();
        if (null == groupedConnection) {//如果connThreadLocal沒有本線程對應(yīng)的Connection創(chuàng)建一個新的Connection,
            groupedConnection = new ThreadLocalConnection.GroupedConnection();
            this.threadLocal.set(groupedConnection);//并將其保存到線程本地變量中捧请。
        }

        return groupedConnection.get(ds);//直接返回線程本地變量
    }
    //提供ThreadLocal的remove()方法凡涩,防止內(nèi)存溢出
    public void close(DataSource ds) {
        ThreadLocalConnection.GroupedConnection groupedConnection = (ThreadLocalConnection.GroupedConnection)this.threadLocal.get();
        if (null != groupedConnection) {
            groupedConnection.close(ds);
            if (groupedConnection.isEmpty()) {
                this.threadLocal.remove();
            }
        }

    }

    public static class GroupedConnection {
        private final Map<DataSource, Connection> connMap = new HashMap(1, 1.0F);

        public GroupedConnection() {
        }

        public Connection get(DataSource ds) throws SQLException {
            Connection conn = (Connection)this.connMap.get(ds);
            if (null == conn || conn.isClosed()) {
                conn = ds.getConnection();
                this.connMap.put(ds, conn);
            }

            return conn;
        }

        public ThreadLocalConnection.GroupedConnection close(DataSource ds) {
            Connection conn = (Connection)this.connMap.get(ds);
            if (null != conn) {
                try {
                    if (!conn.getAutoCommit()) {
                        return this;
                    }
                } catch (SQLException var4) {
                }

                this.connMap.remove(ds);
                DbUtil.close(new Object[]{conn});
            }

            return this;
        }

        public boolean isEmpty() {
            return this.connMap.isEmpty();
        }
    }
}
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
  • 序言:七十年代末,一起剝皮案震驚了整個濱河市疹蛉,隨后出現(xiàn)的幾起案子活箕,更是在濱河造成了極大的恐慌,老刑警劉巖氧吐,帶你破解...
    沈念sama閱讀 218,755評論 6 507
  • 序言:濱河連續(xù)發(fā)生了三起死亡事件讹蘑,死亡現(xiàn)場離奇詭異,居然都是意外死亡筑舅,警方通過查閱死者的電腦和手機座慰,發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 93,305評論 3 395
  • 文/潘曉璐 我一進店門,熙熙樓的掌柜王于貴愁眉苦臉地迎上來翠拣,“玉大人版仔,你說我怎么就攤上這事∥竽梗” “怎么了蛮粮?”我有些...
    開封第一講書人閱讀 165,138評論 0 355
  • 文/不壞的土叔 我叫張陵,是天一觀的道長谜慌。 經(jīng)常有香客問我然想,道長,這世上最難降的妖魔是什么欣范? 我笑而不...
    開封第一講書人閱讀 58,791評論 1 295
  • 正文 為了忘掉前任变泄,我火速辦了婚禮,結(jié)果婚禮上恼琼,老公的妹妹穿的比我還像新娘妨蛹。我一直安慰自己,他們只是感情好晴竞,可當我...
    茶點故事閱讀 67,794評論 6 392
  • 文/花漫 我一把揭開白布蛙卤。 她就那樣靜靜地躺著,像睡著了一般噩死。 火紅的嫁衣襯著肌膚如雪颤难。 梳的紋絲不亂的頭發(fā)上,一...
    開封第一講書人閱讀 51,631評論 1 305
  • 那天已维,我揣著相機與錄音乐严,去河邊找鬼。 笑死衣摩,一個胖子當著我的面吹牛昂验,可吹牛的內(nèi)容都是我干的捂敌。 我是一名探鬼主播,決...
    沈念sama閱讀 40,362評論 3 418
  • 文/蒼蘭香墨 我猛地睜開眼既琴,長吁一口氣:“原來是場噩夢啊……” “哼占婉!你這毒婦竟也來了?” 一聲冷哼從身側(cè)響起甫恩,我...
    開封第一講書人閱讀 39,264評論 0 276
  • 序言:老撾萬榮一對情侶失蹤逆济,失蹤者是張志新(化名)和其女友劉穎,沒想到半個月后磺箕,有當?shù)厝嗽跇淞掷锇l(fā)現(xiàn)了一具尸體奖慌,經(jīng)...
    沈念sama閱讀 45,724評論 1 315
  • 正文 獨居荒郊野嶺守林人離奇死亡,尸身上長有42處帶血的膿包…… 初始之章·張勛 以下內(nèi)容為張勛視角 年9月15日...
    茶點故事閱讀 37,900評論 3 336
  • 正文 我和宋清朗相戀三年松靡,在試婚紗的時候發(fā)現(xiàn)自己被綠了简僧。 大學(xué)時的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片。...
    茶點故事閱讀 40,040評論 1 350
  • 序言:一個原本活蹦亂跳的男人離奇死亡雕欺,死狀恐怖岛马,靈堂內(nèi)的尸體忽然破棺而出,到底是詐尸還是另有隱情屠列,我是刑警寧澤啦逆,帶...
    沈念sama閱讀 35,742評論 5 346
  • 正文 年R本政府宣布,位于F島的核電站笛洛,受9級特大地震影響夏志,放射性物質(zhì)發(fā)生泄漏。R本人自食惡果不足惜苛让,卻給世界環(huán)境...
    茶點故事閱讀 41,364評論 3 330
  • 文/蒙蒙 一盲镶、第九天 我趴在偏房一處隱蔽的房頂上張望。 院中可真熱鬧蝌诡,春花似錦、人聲如沸枫吧。這莊子的主人今日做“春日...
    開封第一講書人閱讀 31,944評論 0 22
  • 文/蒼蘭香墨 我抬頭看了看天上的太陽九杂。三九已至颁湖,卻和暖如春,著一層夾襖步出監(jiān)牢的瞬間例隆,已是汗流浹背甥捺。 一陣腳步聲響...
    開封第一講書人閱讀 33,060評論 1 270
  • 我被黑心中介騙來泰國打工, 沒想到剛下飛機就差點兒被人妖公主榨干…… 1. 我叫王不留镀层,地道東北人镰禾。 一個月前我還...
    沈念sama閱讀 48,247評論 3 371
  • 正文 我出身青樓,卻偏偏與公主長得像,于是被迫代替她去往敵國和親吴侦。 傳聞我的和親對象是個殘疾皇子屋休,可洞房花燭夜當晚...
    茶點故事閱讀 44,979評論 2 355

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