Netty 源碼之 FastThreadLocal

近期由于瀏覽Netty 的源碼,想把Netty中一些編程技巧與優(yōu)化的東西記錄下來!來了解Netty中一些編程思想莱革!

FastThreadLocal:對JDK中ThreadLocal進行優(yōu)化,由于ThreadLocal底層存儲數(shù)據(jù)是一個ThreadLocalMap 結(jié)構(gòu)讹开,是一個數(shù)組結(jié)構(gòu)盅视,通過threadLocalHashCode查找在數(shù)組中的元素Entry, 當hash沖突時,繼續(xù)向前檢測查找, 所以當Hash沖突時旦万,檢索的效率就會降低闹击,具體可查看java.lang.ThreadLocal#getjava.lang.ThreadLocal.ThreadLocalMap#getEntry 方法。而FastThreadLocal則正是處理了這個問題成艘,使其時間復(fù)雜度一直為O(1)

看一下 FastThredLocal 的系主要代碼:

class UnpaddedInternalThreadLocalMap {
   //對非FastThreadLocalThread線程做兼容赏半,從中獲取InternalThreadLocalMap
   static final ThreadLocal<InternalThreadLocalMap> slowThreadLocalMap = new ThreadLocal<InternalThreadLocalMap>();
   //從此變量中獲取線程存儲數(shù)據(jù)的index
   static final AtomicInteger nextIndex = new AtomicInteger();
   //數(shù)據(jù)存儲的數(shù)組
   Object[] indexedVariables;
} 
public final class InternalThreadLocalMap extends UnpaddedInternalThreadLocalMap {
    ....
    public static InternalThreadLocalMap get() {
        Thread thread = Thread.currentThread();
        //根據(jù)是否是FastThreadLocalThread 兩種獲取InternalThreadLocalMap 的方式
        if (thread instanceof FastThreadLocalThread) {
            return fastGet((FastThreadLocalThread) thread);
        } else {
            return slowGet();
        }
    }
   
    //對于FastThreadLocalThread 線程,都會有一個InternalThreadLocalMap的引用淆两,直接獲取
    private static InternalThreadLocalMap fastGet(FastThreadLocalThread thread) {
        InternalThreadLocalMap threadLocalMap = thread.threadLocalMap();
        if (threadLocalMap == null) {
            thread.setThreadLocalMap(threadLocalMap = new InternalThreadLocalMap());
        }
        return threadLocalMap;
    }

    //對于非FastThreadLocalThread 線程
    private static InternalThreadLocalMap slowGet() {
        ThreadLocal<InternalThreadLocalMap> slowThreadLocalMap = UnpaddedInternalThreadLocalMap.slowThreadLocalMap;
        InternalThreadLocalMap ret = slowThreadLocalMap.get();
        if (ret == null) {
            ret = new InternalThreadLocalMap();
            slowThreadLocalMap.set(ret);
        }
        return ret;
    }
   ...
}
    public class FastThreadLocal<V> {
        ...
        private final int index;
        public FastThreadLocal() {
            index = InternalThreadLocalMap.nextVariableIndex();
        }

        //獲取ThreadLocal當前線程對應(yīng)保存的數(shù)據(jù)断箫, 與ThreadLocal中的get()功能相同
        public final V get() {
            //InternalThreadLocalMap.get()獲取InternalThreadLocalMap實例,從InternalThreadLocalMap中獲取存儲的數(shù)據(jù)
            return get(InternalThreadLocalMap.get());
        }

       public final V get(InternalThreadLocalMap threadLocalMap) {
            //根據(jù)index獲取保存在UnpaddedInternalThreadLocalMap 中Object[] indexedVariables的值
            Object v = threadLocalMap.indexedVariable(index);
            if (v != InternalThreadLocalMap.UNSET) {
                return (V) v;
            }
            //為NULL 則調(diào)用initialize(...)方法
            return initialize(threadLocalMap);
       }

        private V initialize(InternalThreadLocalMap threadLocalMap) {
           V v = null;
           try {
                v = initialValue();
          } catch (Exception e) {
                PlatformDependent.throwException(e);
          }

          threadLocalMap.setIndexedVariable(index, v);
          addToVariablesToRemove(threadLocalMap, this);
          return v;
       }
      ...
    }

從上面的代碼可以看出:
1:每一個FastThreadLocalThread都會有一個對InternalThreadLocalMap 的獲取秋冰,方法thread.threadLocalMap(), 非FastThreadLocalThread直接從UnpaddedInternalThreadLocalMap.slowThreadLocalMap中獲取仲义。得到InternalThreadLocalMap.
2:當FastThreadLocalThreadFastThreadLocal中獲取數(shù)據(jù)時,每一個FastThreadLocal都有一個index屬性剑勾,此屬性InternalThreadLocalMap.nextVariableIndex();賦值埃撵,保證了index的唯一性。index表示UnpaddedInternalThreadLocalMap屬性indexedVariables數(shù)組的下標, 從而獲取到保存在indexedVariables中的數(shù)據(jù)
3:如果獲取的數(shù)據(jù)為null, 則調(diào)用FastThreadLocalinitialize()進行一個數(shù)據(jù)的初始化操作

最后編輯于
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
  • 序言:七十年代末虽另,一起剝皮案震驚了整個濱河市暂刘,隨后出現(xiàn)的幾起案子,更是在濱河造成了極大的恐慌捂刺,老刑警劉巖谣拣,帶你破解...
    沈念sama閱讀 211,884評論 6 492
  • 序言:濱河連續(xù)發(fā)生了三起死亡事件,死亡現(xiàn)場離奇詭異族展,居然都是意外死亡芝发,警方通過查閱死者的電腦和手機,發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 90,347評論 3 385
  • 文/潘曉璐 我一進店門苛谷,熙熙樓的掌柜王于貴愁眉苦臉地迎上來辅鲸,“玉大人,你說我怎么就攤上這事腹殿《楞玻” “怎么了例书?”我有些...
    開封第一講書人閱讀 157,435評論 0 348
  • 文/不壞的土叔 我叫張陵,是天一觀的道長刻炒。 經(jīng)常有香客問我决采,道長,這世上最難降的妖魔是什么坟奥? 我笑而不...
    開封第一講書人閱讀 56,509評論 1 284
  • 正文 為了忘掉前任树瞭,我火速辦了婚禮,結(jié)果婚禮上爱谁,老公的妹妹穿的比我還像新娘晒喷。我一直安慰自己,他們只是感情好访敌,可當我...
    茶點故事閱讀 65,611評論 6 386
  • 文/花漫 我一把揭開白布凉敲。 她就那樣靜靜地躺著,像睡著了一般寺旺。 火紅的嫁衣襯著肌膚如雪爷抓。 梳的紋絲不亂的頭發(fā)上,一...
    開封第一講書人閱讀 49,837評論 1 290
  • 那天阻塑,我揣著相機與錄音蓝撇,去河邊找鬼。 笑死陈莽,一個胖子當著我的面吹牛唉地,可吹牛的內(nèi)容都是我干的。 我是一名探鬼主播传透,決...
    沈念sama閱讀 38,987評論 3 408
  • 文/蒼蘭香墨 我猛地睜開眼,長吁一口氣:“原來是場噩夢啊……” “哼极颓!你這毒婦竟也來了朱盐?” 一聲冷哼從身側(cè)響起,我...
    開封第一講書人閱讀 37,730評論 0 267
  • 序言:老撾萬榮一對情侶失蹤菠隆,失蹤者是張志新(化名)和其女友劉穎兵琳,沒想到半個月后,有當?shù)厝嗽跇淞掷锇l(fā)現(xiàn)了一具尸體骇径,經(jīng)...
    沈念sama閱讀 44,194評論 1 303
  • 正文 獨居荒郊野嶺守林人離奇死亡躯肌,尸身上長有42處帶血的膿包…… 初始之章·張勛 以下內(nèi)容為張勛視角 年9月15日...
    茶點故事閱讀 36,525評論 2 327
  • 正文 我和宋清朗相戀三年,在試婚紗的時候發(fā)現(xiàn)自己被綠了破衔。 大學時的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片清女。...
    茶點故事閱讀 38,664評論 1 340
  • 序言:一個原本活蹦亂跳的男人離奇死亡,死狀恐怖晰筛,靈堂內(nèi)的尸體忽然破棺而出嫡丙,到底是詐尸還是另有隱情拴袭,我是刑警寧澤,帶...
    沈念sama閱讀 34,334評論 4 330
  • 正文 年R本政府宣布曙博,位于F島的核電站拥刻,受9級特大地震影響,放射性物質(zhì)發(fā)生泄漏父泳。R本人自食惡果不足惜般哼,卻給世界環(huán)境...
    茶點故事閱讀 39,944評論 3 313
  • 文/蒙蒙 一、第九天 我趴在偏房一處隱蔽的房頂上張望惠窄。 院中可真熱鬧蒸眠,春花似錦、人聲如沸睬捶。這莊子的主人今日做“春日...
    開封第一講書人閱讀 30,764評論 0 21
  • 文/蒼蘭香墨 我抬頭看了看天上的太陽擒贸。三九已至臀晃,卻和暖如春,著一層夾襖步出監(jiān)牢的瞬間介劫,已是汗流浹背徽惋。 一陣腳步聲響...
    開封第一講書人閱讀 31,997評論 1 266
  • 我被黑心中介騙來泰國打工, 沒想到剛下飛機就差點兒被人妖公主榨干…… 1. 我叫王不留座韵,地道東北人险绘。 一個月前我還...
    沈念sama閱讀 46,389評論 2 360
  • 正文 我出身青樓,卻偏偏與公主長得像誉碴,于是被迫代替她去往敵國和親宦棺。 傳聞我的和親對象是個殘疾皇子,可洞房花燭夜當晚...
    茶點故事閱讀 43,554評論 2 349

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