Netty分布式從recycler對象回收站獲取對象的方法

本篇內容主要講解“Netty分布式從recycler對象回收站獲取對象的方法”，感興趣的朋友不妨來看看。本文介紹的方法操作簡單快捷，實用性強。下面就讓小編來帶大家學習“Netty分布式從recycler對象回收站獲取對象的方法”吧!

從對象回收站中獲取對象

從回收站獲取對象

public static void main(String[] args){
    User user1 = RECYCLER.get();
    user1.recycle();
    User user2 = RECYCLER.get();
    user2.recycle();
    System.out.println(user1==user2);
}

這個通過Recycler的get方法獲取對象, 我們跟到get方法中:

public final T get() {
    if (maxCapacityPerThread == 0) {
        return newObject((Handle<T>) NOOP_HANDLE);
    }
    Stack<T> stack = threadLocal.get();
    DefaultHandle<T> handle = stack.pop();
    if (handle == null) {
        handle = stack.newHandle();
        handle.value = newObject(handle);
    }
    return (T) handle.value;
}

首先判斷maxCapacityPerThread是否為0, maxCapacityPerThread代表stack最多能緩存多少個對象, 如果緩存0個, 說明對象將一個都不會回收

這個通過調用newObject創建一個對象, 并傳入一個NOOP_HANDLE, NOOP_HANDLE是一個handle, 我們看其定義:

private static final Handle NOOP_HANDLE = new Handle() {
    @Override
    public void recycle(Object object) {
        
    }
};

這里的recycle方法是一個空實現, 代表不進行任何對象回收

回到get方法中

我們看第二步 

Stack<T> stack = threadLocal.get(); 

這里通過FastThreadLocal對象拿到當前線程的stack, 有關FastThreadLocal獲取對象的邏輯之前小節剖析過, 這里不再贅述

獲取stack之后, 從stack中pop出一個handle, 這個handle做用我們稍后分析

如果取出的對象為null, 說明當前回收站內沒有任何對象, 通常第一次執行到這里對象還沒回收, 這里就會是null, 這樣則會通過stack.newHandle()創建一個handle

創建出來的handle的value屬性, 通過我們重寫的newObject方法進行賦值, 也就是我們demo中的user

我們跟進newHandle方法

DefaultHandle<T> newHandle() {
    return new DefaultHandle<T>(this);
}

這里創建一個DefaultHandle對象, 并傳入this, 這里的this是當前stack

跟到DefaultHandle的構造方法中:

DefaultHandle(Stack<?> stack) {
    this.stack = stack;
}

這里初始化了stack屬性

DefaultHandle中還有個value的成員變量

private Object value;

這里的value就用來綁定回收的對象本身

回到get方法中:

分析handle, 我們回到上一步:

DefaultHandle<T> handle = stack.pop();

我們分析從stack中彈出一個handle的邏輯

跟到pop方法中

DefaultHandle<T> pop() {
    int size = this.size;
    if (size == 0) {
        if (!scavenge()) {
            return null;
        }
        size = this.size;
    }
    size --;
    DefaultHandle ret = elements[size];
    elements[size] = null;
    if (ret.lastRecycledId != ret.recycleId) {
        throw new IllegalStateException("recycled multiple times");
    }
    ret.recycleId = 0;
    ret.lastRecycledId = 0;
    this.size = size;
    return ret;
}

首先拿到size, size表示當前stack的對象數

如果size為0, 則調用scavenge方法, 這個方法是異線程回收對象的方法, 我們放在之后的小節進行分析

size大于零, 則size進行自減, 代表取出一個元素

然后通過size的數組下標的方式將handle取出

之后將當前下標設置為null

最后將屬性recycleId, lastRecycledId, size進行賦值

recycleId和lastRecycledId我們會在之后的小節進行分析

回到get方法中:

public final T get() {
    if (maxCapacityPerThread == 0) {
        return newObject((Handle<T>) NOOP_HANDLE);
    }
    Stack<T> stack = threadLocal.get();
    DefaultHandle<T> handle = stack.pop();
    if (handle == null) {
        handle = stack.newHandle();
        handle.value = newObject(handle);
    }
    return (T) handle.value;
}

無論是從stack中彈出的handle, 還是創建的handle, 最后都要通過handle.value拿到我們實際使用的對象

到此，相信大家對“Netty分布式從recycler對象回收站獲取對象的方法”有了更深的了解，不妨來實際操作一番吧！這里是億速云網站，更多相關內容可以進入相關頻道進行查詢，關注我們，繼續學習！