netty里的ByteBuf擴容源碼分析

??我們知道在實例化一個ByteBuf對象的時候,是可以設(shè)置一個capacity和一個maxCapacity窜骄,當(dāng)writerIndex達(dá)到capacity的時候,再往里面寫入內(nèi)容女淑,ByteBuf就會進行擴容。
??下面我們來看一些ByteBuf是怎樣進行擴容的:
??我們先看一下調(diào)用ByteBuf的writeByte(int value)寫入一個字節(jié)的數(shù)據(jù)会宪。因為ByteBuf的writeByte(int value)是一個抽象方法箱残,它的具體實現(xiàn)是在AbstractByteBuf里面

public ByteBuf writeByte(int value) {
    ensureWritable0(1);
    _setByte(writerIndex++, value);
    return this;
}

??我們能看到會先調(diào)用ensureWritable0()方法來檢查是否能往里面寫入數(shù)據(jù)求妹,傳入1

final void ensureWritable0(int minWritableBytes) {
     ensureAccessible();
     if (minWritableBytes <= writableBytes()) {
         return;
     }
     if (checkBounds) {
         if (minWritableBytes > maxCapacity - writerIndex) {
             throw new IndexOutOfBoundsException(String.format(
                     "writerIndex(%d) + minWritableBytes(%d) exceeds maxCapacity(%d): %s",
                     writerIndex, minWritableBytes, maxCapacity, this));
         }
     }

     // Normalize the current capacity to the power of 2.
     int newCapacity = alloc().calculateNewCapacity(writerIndex + minWritableBytes, maxCapacity);

     // Adjust to the new capacity.
    capacity(newCapacity);
}

??ensureAccessible()方法是檢查refCnt是否為0研乒,為0代表該ByteBuf對象以被釋放汹忠,會拋IllegalReferenceCountException。
??接下來判斷minWritableBytes是否小于或等于writableBytes,如果滿足代表還有空間滿足寫入數(shù)據(jù)宽菜,則直接返回奖地。如果不滿足,則判斷是否檢查邊界赋焕,checkBounds是個boolean值,可在啟動JVM的時候由io.netty.buffer.checkBounds參數(shù)指定仰楚,其默認(rèn)值是true隆判。如果checkBounds為true,判斷將要寫入的字節(jié)數(shù)是否大于最大可寫入的字節(jié)數(shù)(maxCapacity - writerIndex)僧界,如果大于直接拋異常侨嘀,否則繼續(xù)執(zhí)行。
??接下來會調(diào)用ByteBufAllocator的calculateNewCapacity計算新的capacity捂襟。方法的實現(xiàn)在AbstractByteBufAllocator里面:

public int calculateNewCapacity(int minNewCapacity, int maxCapacity) {
        if (minNewCapacity < 0) {
            throw new IllegalArgumentException("minNewCapacity: " + minNewCapacity + " (expected: 0+)");
        }
        if (minNewCapacity > maxCapacity) {
            throw new IllegalArgumentException(String.format(
                    "minNewCapacity: %d (expected: not greater than maxCapacity(%d)",
                    minNewCapacity, maxCapacity));
        }
        final int threshold = CALCULATE_THRESHOLD; // 4 MiB page

        if (minNewCapacity == threshold) {
            return threshold;
        }

        // If over threshold, do not double but just increase by threshold.
        if (minNewCapacity > threshold) {
            int newCapacity = minNewCapacity / threshold * threshold;
            if (newCapacity > maxCapacity - threshold) {
                newCapacity = maxCapacity;
            } else {
                newCapacity += threshold;
            }
            return newCapacity;
        }

        // Not over threshold. Double up to 4 MiB, starting from 64.
        int newCapacity = 64;
        while (newCapacity < minNewCapacity) {
            newCapacity <<= 1;
        }

        return Math.min(newCapacity, maxCapacity);
    }

??我們能看到擴容是有一個閥值(CALCULATE_THRESHOLD)的咬腕,為4MB大小,當(dāng)所需容量大性岷伞(minNewCapacity)小于閥值(threshold)的時候涨共,新的容量(newCapacity)都是是以64位基數(shù)向坐移位位計算出來的,通過循環(huán)宠漩,每次移動移1位举反,直到newCapacity>=minNewCapacity為止,如果計算出來newCapacity大于maxCapacity扒吁,則返回maxCapacity火鼻,否則返回newCapacity。也就是說當(dāng)minNewCapacity=300的時候雕崩,newCapacity=512魁索。
??當(dāng)minNewCapacity>=threshold的時候,則先計算minNewCapacity / threshold * threshold的大小盼铁,如果這個值在加上一個threshold(4MB)大于newCapacity的時候粗蔚,則newCapacity的值取maxCapacity,否則newCapacity=minNewCapacity / threshold * threshold+threshold捉貌。
??再回到ensureWritable0()方法支鸡,我們能看到,拿到計算出來的newCapacity趁窃,原后調(diào)用capacity(newCapacity)方法將新的capacity設(shè)置進去牧挣。

?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
  • 序言:七十年代末,一起剝皮案震驚了整個濱河市醒陆,隨后出現(xiàn)的幾起案子瀑构,更是在濱河造成了極大的恐慌,老刑警劉巖,帶你破解...
    沈念sama閱讀 212,718評論 6 492
  • 序言:濱河連續(xù)發(fā)生了三起死亡事件寺晌,死亡現(xiàn)場離奇詭異世吨,居然都是意外死亡,警方通過查閱死者的電腦和手機呻征,發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 90,683評論 3 385
  • 文/潘曉璐 我一進店門耘婚,熙熙樓的掌柜王于貴愁眉苦臉地迎上來,“玉大人陆赋,你說我怎么就攤上這事沐祷。” “怎么了攒岛?”我有些...
    開封第一講書人閱讀 158,207評論 0 348
  • 文/不壞的土叔 我叫張陵赖临,是天一觀的道長。 經(jīng)常有香客問我灾锯,道長兢榨,這世上最難降的妖魔是什么? 我笑而不...
    開封第一講書人閱讀 56,755評論 1 284
  • 正文 為了忘掉前任顺饮,我火速辦了婚禮吵聪,結(jié)果婚禮上,老公的妹妹穿的比我還像新娘兼雄。我一直安慰自己暖璧,他們只是感情好,可當(dāng)我...
    茶點故事閱讀 65,862評論 6 386
  • 文/花漫 我一把揭開白布君旦。 她就那樣靜靜地躺著澎办,像睡著了一般。 火紅的嫁衣襯著肌膚如雪金砍。 梳的紋絲不亂的頭發(fā)上局蚀,一...
    開封第一講書人閱讀 50,050評論 1 291
  • 那天,我揣著相機與錄音恕稠,去河邊找鬼琅绅。 笑死,一個胖子當(dāng)著我的面吹牛鹅巍,可吹牛的內(nèi)容都是我干的千扶。 我是一名探鬼主播,決...
    沈念sama閱讀 39,136評論 3 410
  • 文/蒼蘭香墨 我猛地睜開眼骆捧,長吁一口氣:“原來是場噩夢啊……” “哼澎羞!你這毒婦竟也來了?” 一聲冷哼從身側(cè)響起敛苇,我...
    開封第一講書人閱讀 37,882評論 0 268
  • 序言:老撾萬榮一對情侶失蹤妆绞,失蹤者是張志新(化名)和其女友劉穎,沒想到半個月后,有當(dāng)?shù)厝嗽跇淞掷锇l(fā)現(xiàn)了一具尸體括饶,經(jīng)...
    沈念sama閱讀 44,330評論 1 303
  • 正文 獨居荒郊野嶺守林人離奇死亡株茶,尸身上長有42處帶血的膿包…… 初始之章·張勛 以下內(nèi)容為張勛視角 年9月15日...
    茶點故事閱讀 36,651評論 2 327
  • 正文 我和宋清朗相戀三年,在試婚紗的時候發(fā)現(xiàn)自己被綠了图焰。 大學(xué)時的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片启盛。...
    茶點故事閱讀 38,789評論 1 341
  • 序言:一個原本活蹦亂跳的男人離奇死亡,死狀恐怖技羔,靈堂內(nèi)的尸體忽然破棺而出驰徊,到底是詐尸還是另有隱情,我是刑警寧澤堕阔,帶...
    沈念sama閱讀 34,477評論 4 333
  • 正文 年R本政府宣布,位于F島的核電站颗味,受9級特大地震影響超陆,放射性物質(zhì)發(fā)生泄漏。R本人自食惡果不足惜浦马,卻給世界環(huán)境...
    茶點故事閱讀 40,135評論 3 317
  • 文/蒙蒙 一时呀、第九天 我趴在偏房一處隱蔽的房頂上張望。 院中可真熱鬧晶默,春花似錦谨娜、人聲如沸。這莊子的主人今日做“春日...
    開封第一講書人閱讀 30,864評論 0 21
  • 文/蒼蘭香墨 我抬頭看了看天上的太陽。三九已至币他,卻和暖如春坞靶,著一層夾襖步出監(jiān)牢的瞬間,已是汗流浹背蝴悉。 一陣腳步聲響...
    開封第一講書人閱讀 32,099評論 1 267
  • 我被黑心中介騙來泰國打工彰阴, 沒想到剛下飛機就差點兒被人妖公主榨干…… 1. 我叫王不留,地道東北人拍冠。 一個月前我還...
    沈念sama閱讀 46,598評論 2 362
  • 正文 我出身青樓尿这,卻偏偏與公主長得像,于是被迫代替她去往敵國和親庆杜。 傳聞我的和親對象是個殘疾皇子射众,可洞房花燭夜當(dāng)晚...
    茶點故事閱讀 43,697評論 2 351

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