Netty分散式從recycler物件回收站獲取物件過程剖析

2022-03-29 19:01:31

從物件回收站中獲取物件

我們回顧上一小節demo的main方法中

從回收站獲取物件

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我們會在之後的小節進行分析