ByteBuf釋放

protected final void deallocate() {
    if (handle >= 0) {
        final long handle = this.handle;
        this.handle = -1;
        memory = null;
        // 內(nèi)存釋放
        chunk.arena.free(chunk, handle, maxLength, cache);
        recycle();
    }
}

PoolArena

void free(PoolChunk<T> chunk, long handle, int normCapacity, PoolThreadCache cache) {
    // 如果是非池化的chunk
    if (chunk.unpooled) {
        int size = chunk.chunkSize();
        destroyChunk(chunk);
        activeBytesHuge.add(-size);
        deallocationsHuge.increment();
    } else {
        SizeClass sizeClass = sizeClass(normCapacity);
        // 如果這個(gè)chunk能添加到本地cache中加袋,再好不過(guò)
        if (cache != null && cache.add(this, chunk, handle, normCapacity, sizeClass)) {
            // cached so not free it.
            return;
        }

        freeChunk(chunk, handle, sizeClass);
    }
}

void freeChunk(PoolChunk<T> chunk, long handle, SizeClass sizeClass) {
    final boolean destroyChunk;
    synchronized (this) {
        switch (sizeClass) {
        case Normal:
            ++deallocationsNormal;
            break;
        case Small:
            ++deallocationsSmall;
            break;
        case Tiny:
            ++deallocationsTiny;
            break;
        default:
            throw new Error();
        }
        // 找到該chunk所屬的PoolChunkList惊楼,做free動(dòng)作
        destroyChunk = !chunk.parent.free(chunk, handle);
    }
    if (destroyChunk) {
        // destroyChunk not need to be called while holding the synchronized lock.
        destroyChunk(chunk);
    }
}

PoolThreadCache

boolean add(PoolArena<?> area, PoolChunk chunk, long handle, int normCapacity, SizeClass sizeClass) {
    //去cache里面找滿足條件的MemoryRegionCache
    MemoryRegionCache<?> cache = cache(area, normCapacity, sizeClass);
    if (cache == null) {
        return false;
    }
    // 將這段內(nèi)存空間添加到該cache的隊(duì)列中
    return cache.add(chunk, handle);
}

public final boolean add(PoolChunk<T> chunk, long handle) {
    // 將這段空間包裝成Entry
    Entry<T> entry = newEntry(chunk, handle);
    // 壓入隊(duì)列中
    boolean queued = queue.offer(entry);
    if (!queued) {
        // If it was not possible to cache the chunk, immediately recycle the entry
        // 如果添加隊(duì)列失敗陡蝇,立即recycle翰灾,也就是對(duì)象池回收掉
        entry.recycle();
    }

    return queued;
}

PoolChunkList

boolean free(PoolChunk<T> chunk, long handle) {厂画、
    // 先調(diào)用PoolChunk的free動(dòng)作
    chunk.free(handle);
    // 如果這個(gè)chunk的使用率不達(dá)標(biāo)凸丸,那么需要降級(jí)
    if (chunk.usage() < minUsage) {
        // 從當(dāng)前的倉(cāng)位移除
        remove(chunk);        
        // 移動(dòng)一個(gè)倉(cāng)位存放
        return move0(chunk);
    }
    return true;
}

PoolChunk

void free(long handle) {
    // 拿到handle包含的memoryMapIdx,也就是滿二叉樹(shù)的節(jié)點(diǎn)id
    int memoryMapIdx = memoryMapIdx(handle);
    // 拿到handle包含的subpage的index
    int bitmapIdx = bitmapIdx(handle);
    
    // 如果不等于0袱院,說(shuō)明空間已經(jīng)細(xì)分到了subpage
    if (bitmapIdx != 0) { // free a subpage
        // 拿到對(duì)應(yīng)的PoolSubpage屎慢,用來(lái)替Page管理subPage的對(duì)象
        PoolSubpage<T> subpage = subpages[subpageIdx(memoryMapIdx)];
        assert subpage != null && subpage.doNotDestroy;

        // 拿到elemsize的head,來(lái)同步對(duì)subpage進(jìn)行free
        PoolSubpage<T> head = arena.findSubpagePoolHead(subpage.elemSize);
        synchronized (head) {
            if (subpage.free(head, bitmapIdx & 0x3FFFFFFF)) {
                return;
            }
        }
    }
    // 將釋放的空間大小體現(xiàn)在freeBytes中忽洛,供需要的人知曉
    freeBytes += runLength(memoryMapIdx);
    // 將id節(jié)點(diǎn)的value重置成原生的depth腻惠,make space reuse
    setValue(memoryMapIdx, depth(memoryMapIdx));
    // 更新從id開(kāi)始到root沿途的value
    updateParentsFree(memoryMapIdx);
}

updateParentsFree

private void updateParentsFree(int id) {    
    int logChild = depth(id) + 1;
    while (id > 1) {
        int parentId = id >>> 1;
        byte val1 = value(id);
        byte val2 = value(id ^ 1);
        logChild -= 1; 
        
        // 如果左右子節(jié)點(diǎn)都等于logChild,那么父節(jié)點(diǎn)一定是logChild-1
        if (val1 == logChild && val2 == logChild) {
            setValue(parentId, (byte) (logChild - 1));
        } else {
        // 如果左右節(jié)點(diǎn)不相等欲虚,那么父節(jié)點(diǎn)取最小的那個(gè)
            byte val = val1 < val2 ? val1 : val2;
            setValue(parentId, val);
        }

        id = parentId;
    }
}

PoolSubpage

boolean free(PoolSubpage<T> head, int bitmapIdx) {
    if (elemSize == 0) {
        return true;
    }
    // 將bitmap里面之前占用的bit位清0集灌,表示邏輯上釋放空間
    int q = bitmapIdx >>> 6;
    int r = bitmapIdx & 63;
    assert (bitmap[q] >>> r & 1) != 0;
    bitmap[q] ^= 1L << r;
    
    // 將該位置設(shè)置下個(gè)可用的位置
    setNextAvail(bitmapIdx);
    
    // 如果之前還沒(méi)有位置, 經(jīng)過(guò)上面的處理, 想必已經(jīng)騰出了位置
    // 那么加入到head后面, 等待對(duì)外提供subpage
    if (numAvail ++ == 0) {
        addToPool(head);
        return true;
    }

    if (numAvail != maxNumElems) {
        return true;
    } else {
        // 如果整個(gè)page都被釋放
        if (prev == next) {
            return true;
        }

        doNotDestroy = false;
        removeFromPool();
        return false;
    }
}

removeFromPool

// 整個(gè)實(shí)現(xiàn)就是自旋,將head解綁复哆。
// 我們知道head好比是arena初始的一個(gè)index欣喧,用這個(gè)head能定位所有相同elemsize的內(nèi)存空間
// 那么這個(gè)PoolSubpage最終會(huì)被GC掉
private void removeFromPool() {
    assert prev != null && next != null;
    prev.next = next;
    next.prev = prev;
    next = null;
    prev = null;
}
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請(qǐng)聯(lián)系作者
  • 序言:七十年代末,一起剝皮案震驚了整個(gè)濱河市梯找,隨后出現(xiàn)的幾起案子唆阿,更是在濱河造成了極大的恐慌,老刑警劉巖锈锤,帶你破解...
    沈念sama閱讀 218,546評(píng)論 6 507
  • 序言:濱河連續(xù)發(fā)生了三起死亡事件驯鳖,死亡現(xiàn)場(chǎng)離奇詭異,居然都是意外死亡久免,警方通過(guò)查閱死者的電腦和手機(jī)浅辙,發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 93,224評(píng)論 3 395
  • 文/潘曉璐 我一進(jìn)店門,熙熙樓的掌柜王于貴愁眉苦臉地迎上來(lái)阎姥,“玉大人摔握,你說(shuō)我怎么就攤上這事《〖模” “怎么了氨淌?”我有些...
    開(kāi)封第一講書人閱讀 164,911評(píng)論 0 354
  • 文/不壞的土叔 我叫張陵泊愧,是天一觀的道長(zhǎng)。 經(jīng)常有香客問(wèn)我盛正,道長(zhǎng)删咱,這世上最難降的妖魔是什么? 我笑而不...
    開(kāi)封第一講書人閱讀 58,737評(píng)論 1 294
  • 正文 為了忘掉前任豪筝,我火速辦了婚禮痰滋,結(jié)果婚禮上,老公的妹妹穿的比我還像新娘续崖。我一直安慰自己敲街,他們只是感情好,可當(dāng)我...
    茶點(diǎn)故事閱讀 67,753評(píng)論 6 392
  • 文/花漫 我一把揭開(kāi)白布严望。 她就那樣靜靜地躺著多艇,像睡著了一般。 火紅的嫁衣襯著肌膚如雪像吻。 梳的紋絲不亂的頭發(fā)上峻黍,一...
    開(kāi)封第一講書人閱讀 51,598評(píng)論 1 305
  • 那天,我揣著相機(jī)與錄音拨匆,去河邊找鬼姆涩。 笑死,一個(gè)胖子當(dāng)著我的面吹牛惭每,可吹牛的內(nèi)容都是我干的骨饿。 我是一名探鬼主播,決...
    沈念sama閱讀 40,338評(píng)論 3 418
  • 文/蒼蘭香墨 我猛地睜開(kāi)眼台腥,長(zhǎng)吁一口氣:“原來(lái)是場(chǎng)噩夢(mèng)啊……” “哼样刷!你這毒婦竟也來(lái)了?” 一聲冷哼從身側(cè)響起览爵,我...
    開(kāi)封第一講書人閱讀 39,249評(píng)論 0 276
  • 序言:老撾萬(wàn)榮一對(duì)情侶失蹤置鼻,失蹤者是張志新(化名)和其女友劉穎,沒(méi)想到半個(gè)月后蜓竹,有當(dāng)?shù)厝嗽跇?shù)林里發(fā)現(xiàn)了一具尸體箕母,經(jīng)...
    沈念sama閱讀 45,696評(píng)論 1 314
  • 正文 獨(dú)居荒郊野嶺守林人離奇死亡,尸身上長(zhǎng)有42處帶血的膿包…… 初始之章·張勛 以下內(nèi)容為張勛視角 年9月15日...
    茶點(diǎn)故事閱讀 37,888評(píng)論 3 336
  • 正文 我和宋清朗相戀三年俱济,在試婚紗的時(shí)候發(fā)現(xiàn)自己被綠了嘶是。 大學(xué)時(shí)的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片。...
    茶點(diǎn)故事閱讀 40,013評(píng)論 1 348
  • 序言:一個(gè)原本活蹦亂跳的男人離奇死亡蛛碌,死狀恐怖聂喇,靈堂內(nèi)的尸體忽然破棺而出,到底是詐尸還是另有隱情,我是刑警寧澤希太,帶...
    沈念sama閱讀 35,731評(píng)論 5 346
  • 正文 年R本政府宣布克饶,位于F島的核電站,受9級(jí)特大地震影響誊辉,放射性物質(zhì)發(fā)生泄漏矾湃。R本人自食惡果不足惜,卻給世界環(huán)境...
    茶點(diǎn)故事閱讀 41,348評(píng)論 3 330
  • 文/蒙蒙 一堕澄、第九天 我趴在偏房一處隱蔽的房頂上張望邀跃。 院中可真熱鬧,春花似錦蛙紫、人聲如沸拍屑。這莊子的主人今日做“春日...
    開(kāi)封第一講書人閱讀 31,929評(píng)論 0 22
  • 文/蒼蘭香墨 我抬頭看了看天上的太陽(yáng)僵驰。三九已至,卻和暖如春裁蚁,著一層夾襖步出監(jiān)牢的瞬間,已是汗流浹背继准。 一陣腳步聲響...
    開(kāi)封第一講書人閱讀 33,048評(píng)論 1 270
  • 我被黑心中介騙來(lái)泰國(guó)打工枉证, 沒(méi)想到剛下飛機(jī)就差點(diǎn)兒被人妖公主榨干…… 1. 我叫王不留,地道東北人移必。 一個(gè)月前我還...
    沈念sama閱讀 48,203評(píng)論 3 370
  • 正文 我出身青樓室谚,卻偏偏與公主長(zhǎng)得像,于是被迫代替她去往敵國(guó)和親崔泵。 傳聞我的和親對(duì)象是個(gè)殘疾皇子秒赤,可洞房花燭夜當(dāng)晚...
    茶點(diǎn)故事閱讀 44,960評(píng)論 2 355

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