天天看點

7. SOFAJRaft源碼分析—如何實作一個輕量級的對象池?

前言

我在看SOFAJRaft的源碼的時候看到了使用了對象池的技術,看了一下感覺要吃透的話還是要新開一篇文章來講,内容也比較充實,大家也可以學到之後運用到實際的項目中去。

這裡我使用RecyclableByteBufferList來作為講解的例子:

RecyclableByteBufferList

public final class RecyclableByteBufferList extends ArrayList<ByteBuffer> implements Recyclable {

    private transient final Recyclers.Handle handle;

    private static final Recyclers<RecyclableByteBufferList> recyclers = new Recyclers<RecyclableByteBufferList>(512) {

        @Override
        protected RecyclableByteBufferList newObject(final Handle handle) {
            return new RecyclableByteBufferList(
                    handle);
        }
    };

	  //擷取一個RecyclableByteBufferList執行個體
    public static RecyclableByteBufferList newInstance(final int minCapacity) {
        final RecyclableByteBufferList ret = recyclers.get();
        //容量不夠的話,進行擴容
        ret.ensureCapacity(minCapacity);
        return ret;
    }
	  //回收RecyclableByteBufferList對象
    @Override
    public boolean recycle() {
        clear();
        this.capacity = 0;
        return recyclers.recycle(this, handle);
    }
}
           

我在上面将RecyclableByteBufferList擷取對象的方法和回收對象的方法給列舉出來了,擷取執行個體的時候會通過recyclers的get方法去擷取,回收對象的時候會去調用list的clear方法清空list裡面的内容之後再去調用recyclers的recycle方法進行回收。

如果recyclers裡面沒有對象可以擷取,那麼會調用newObject方法建立一個對象,然後将handle對象傳入構造器中進行執行個體化。

對象池Recyclers

資料結構

7. SOFAJRaft源碼分析—如何實作一個輕量級的對象池?
  1. 每一個 Recyclers 對象包含一個

    ThreadLocal<Stack<T>> threadLocal

    執行個體;

    每一個線程包含一個 Stack 對象,該 Stack 對象包含一個 DefaultHandle[],而 DefaultHandle 中有一個屬性 T value,用于存儲真實對象。也就是說,每一個被回收的對象都會被包裝成一個 DefaultHandle 對象

  2. ThreadLocal<Map<Stack<?>, WeakOrderQueue>> delayedRecycled

    每一個線程對象包含一個 Map<Stack<?>, WeakOrderQueue>,存儲着為其他線程建立的 WeakOrderQueue 對象,WeakOrderQueue 對象中存儲一個以 Head 為首的 Link 數組,每個 Link 對象中存儲一個 DefaultHandle[] 數組,用于存放回收對象。
7. SOFAJRaft源碼分析—如何實作一個輕量級的對象池?

假設線程A建立的對象

  1. 線程A回收RecyclableByteBufferList時,直接将RecyclableByteBufferList的DefaultHandle 對象壓入 Stack 的 DefaultHandle[] 中;
  2. 線程B回收RecyclableByteBufferList時,會首先從其 Map<Stack<?>, WeakOrderQueue> 對象中擷取 key=線程A的Stack 對象的 WeakOrderQueue,然後直接将RecyclableByteBufferList的DefaultHandle 對象(内部包含RecyclableByteBufferList對象)壓入該 WeakOrderQueue 中的 Link 連結清單中的尾部 Link 的 DefaultHandle[]中,同時,這個 WeakOrderQueue 會與線程 A 的 Stack 中的 head 屬性進行關聯,用于後續對象的 pop 操作;
  3. 當線程 A 從對象池擷取對象時,如果線程 A 的 Stack 中有對象,則直接彈出;如果沒有對象,則先從其 head 屬性所指向的 WeakorderQueue 開始周遊 queue 連結清單,将 RecyclableByteBufferList 對象從其他線程的 WeakOrderQueue 中轉移到線程 A 的 Stack 中(一次 pop 操作隻轉移一個包含了元素的 Link),再彈出。

Recyclers靜态代碼塊

private static final int DEFAULT_INITIAL_MAX_CAPACITY_PER_THREAD = 4 * 1024; // Use 4k instances as default.
private static final int DEFAULT_MAX_CAPACITY_PER_THREAD;
private static final int INITIAL_CAPACITY;

static {
    // 每個線程的最大對象池容量
    int maxCapacityPerThread = SystemPropertyUtil.getInt("jraft.recyclers.maxCapacityPerThread", DEFAULT_INITIAL_MAX_CAPACITY_PER_THREAD);
    if (maxCapacityPerThread < 0) {
        maxCapacityPerThread = DEFAULT_INITIAL_MAX_CAPACITY_PER_THREAD;
    }

    DEFAULT_MAX_CAPACITY_PER_THREAD = maxCapacityPerThread;
    if (LOG.isDebugEnabled()) {
        if (DEFAULT_MAX_CAPACITY_PER_THREAD == 0) {
            LOG.debug("-Djraft.recyclers.maxCapacityPerThread: disabled");
        } else {
            LOG.debug("-Djraft.recyclers.maxCapacityPerThread: {}", DEFAULT_MAX_CAPACITY_PER_THREAD);
        }
    }
    // 設定初始化容量資訊
    INITIAL_CAPACITY = Math.min(DEFAULT_MAX_CAPACITY_PER_THREAD, 256);
}

 public static final Handle NOOP_HANDLE = new Handle() {};
           

Recyclers會在靜态代碼塊中做一些對象池容量初始化的工作,初始化了最大對象池容量和初始化容量資訊。

從對象池中擷取對象

Recyclers#get

// 線程變量,儲存每個線程的對象池資訊,通過 ThreadLocal 的使用,避免了不同線程之間的競争情況
private final ThreadLocal<Stack<T>> threadLocal = new ThreadLocal<Stack<T>>() {

    @Override
    protected Stack<T> initialValue() {
        return new Stack<>(Recyclers.this, Thread.currentThread(), maxCapacityPerThread);
    }
};

public final T get() {
    if (maxCapacityPerThread == 0) {
        return newObject(NOOP_HANDLE);
    }
    //從threadLocal中擷取一個棧對象
    Stack<T> stack = threadLocal.get();
    //拿出棧頂元素
    DefaultHandle handle = stack.pop();
    //如果棧裡面沒有元素,那麼就執行個體化一個
    if (handle == null) {
        handle = stack.newHandle();
        handle.value = newObject(handle);
    }
    return (T) handle.value;
}
           

Get方法會從threadLocal中去擷取資料,如果擷取不到,那麼會初始化一個Stack,并傳入目前Recyclers執行個體,目前線程,與最大容量。然後從stack中pop拿出棧頂元素,如果擷取的元素為空,那麼直接調用newHandle建立一個DefaultHandle執行個體,并調用Recyclers實作類的newObject擷取實作類的執行個體。也就是說DefaultHandle是用來封裝真正的對象的執行個體。

從stack中申請一個對象

Stack(Recyclers<T> parent, Thread thread, int maxCapacity) {
    this.parent = parent;
    this.thread = thread;
    this.maxCapacity = maxCapacity;
    elements = new DefaultHandle[Math.min(INITIAL_CAPACITY, maxCapacity)];
}

DefaultHandle pop() {
    int size = this.size;
    if (size == 0) {
        if (!scavenge()) {
            return null;
        }
        size = this.size;
    }
    //size表示整個stack中的大小
    size--;
    //擷取最後一個元素
    DefaultHandle ret = elements[size];
    if (ret.lastRecycledId != ret.recycleId) {
        throw new IllegalStateException("recycled multiple times");
    }
    // 清空回收資訊,以便判斷是否重複回收
    ret.recycleId = 0;
    ret.lastRecycledId = 0;
    this.size = size;
    return ret;
}
           

擷取對象的邏輯也比較簡單,當 Stack 中的 DefaultHandle[] 的 size 為 0 時,需要從其他線程的 WeakOrderQueue 中轉移資料到 Stack 中的 DefaultHandle[],即 scavenge方法,該方法下面再聊。當 Stack 中的 DefaultHandle[] 中最終有了資料時,直接擷取最後一個元素

對象池回收對象

我們再來看看RecyclableByteBufferList是怎麼回收對象的。

RecyclableByteBufferList#recycle

public boolean recycle() {
    clear();
    this.capacity = 0;
    return recyclers.recycle(this, handle);
}
           

RecyclableByteBufferList回收對象的時候首先會調用clear方法清空屬性,然後調用recyclers的recycle方法進行對象回收。

Recyclers#recycle

public final boolean recycle(T o, Handle handle) {
    if (handle == NOOP_HANDLE) {
        return false;
    }

    DefaultHandle h = (DefaultHandle) handle;
    //stack在執行個體化的時候會在構造器中傳入一個Recyclers作為parent
    //是以這裡是校驗一下,如果不是目前線程的, 直接不回收了
    if (h.stack.parent != this) {
        return false;
    }
    if (o != h.value) {
        throw new IllegalArgumentException("o does not belong to handle");
    }
    h.recycle();
    return true;
}
           

這裡會接着調用DefaultHandle的recycle方法進行回收

DefaultHandle

static final class DefaultHandle implements Handle {
    //在WeakOrderQueue的add方法中會設定成ID
    //在push方法中設定成為OWN_THREAD_ID
    //在pop方法中設定為0
    private int lastRecycledId;
    //隻有在push方法中才會設定OWN_THREAD_ID
    //在pop方法中設定為0
    private int recycleId;
    //目前的DefaultHandle對象所屬的Stack
    private Stack<?> stack;
    private Object value;

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

    public void recycle() {
        Thread thread = Thread.currentThread();
        //如果目前線程正好等于stack所對應的線程,那麼直接push進去
        if (thread == stack.thread) {
            stack.push(this);
            return;
        }
        // we don't want to have a ref to the queue as the value in our weak map
        // so we null it out; to ensure there are no races with restoring it later
        // we impose a memory ordering here (no-op on x86)
        // 如果不是目前線程,則需要延遲回收,擷取目前線程存儲的延遲回收WeakHashMap
        Map<Stack<?>, WeakOrderQueue> delayedRecycled = Recyclers.delayedRecycled.get();
        // 目前 handler 所在的 stack 是否已經在延遲回收的任務隊列中
        // 并且 WeakOrderQueue是一個多線程間可以共享的Queue
        WeakOrderQueue queue = delayedRecycled.get(stack);
        if (queue == null) {
            delayedRecycled.put(stack, queue = new WeakOrderQueue(stack, thread));
        }
        queue.add(this);
    }
}
           

DefaultHandle在執行個體化的時候會傳入一個stack執行個體,代表目前執行個體是屬于這個stack的。

是以在調用recycle方法的時候,會判斷一下,目前的線程是不是stack所屬的線程,如果是那麼直接push到stack裡面就好了,不是則調用延遲隊列delayedRecycled;

從delayedRecycled隊列中擷取Map<Stack<?>, WeakOrderQueue> delayedRecycled ,根據stack作為key來擷取WeakOrderQueue,然後将目前的DefaultHandle執行個體放入到WeakOrderQueue中。

同線程回收對象

Stack#push

void push(DefaultHandle item) {
    // (item.recycleId | item.lastRecycleId) != 0 等價于 item.recycleId!=0 && item.lastRecycleId!=0
    // 當item開始建立時item.recycleId==0 && item.lastRecycleId==0
    // 當item被recycle時,item.recycleId==x,item.lastRecycleId==y 進行指派
    // 當item被pop之後, item.recycleId = item.lastRecycleId = 0
    // 是以當item.recycleId 和 item.lastRecycleId 任何一個不為0,則表示回收過
    if ((item.recycleId | item.lastRecycledId) != 0) {
        throw new IllegalStateException("recycled already");
    }
    // 設定對象的回收id為線程id資訊,标記自己的被回收的線程資訊
    item.recycleId = item.lastRecycledId = OWN_THREAD_ID;

    int size = this.size;
    if (size >= maxCapacity) {
        // Hit the maximum capacity - drop the possibly youngest object.
        return;
    }
    // stack中的elements擴容兩倍,複制元素,将新數組指派給stack.elements
    if (size == elements.length) {
        elements = Arrays.copyOf(elements, Math.min(size << 1, maxCapacity));
    }

    elements[size] = item;
    this.size = size + 1;
}
           

同線程回收對象 DefaultHandle#recycle 步驟:

  1. stack 先檢測目前的線程是否是建立 stack 的線程,如果不是,則走異線程回收邏輯;如果是,則首先判斷是否重複回收,然後判斷 stack 的 DefaultHandle[] 中的元素個數是否已經超過最大容量(4k),如果是,直接傳回;
  2. 判斷目前的 DefaultHandle[] 是否還有空位,如果沒有,以 maxCapacity 為最大邊界擴容 2 倍,之後拷貝舊數組的元素到新數組,然後将目前的 DefaultHandle 對象放置到 DefaultHandle[] 中
  3. 最後重置 stack.size 屬性

異線程回收對象

WeakOrderQueue

static final class Stack<T> {
    //使用volatile可以立即讀取到該queue
	  private volatile WeakOrderQueue head;
}
WeakOrderQueue(Stack<?> stack, Thread thread) {
    head = tail = new Link();
    //使用的是WeakReference ,作用是在poll的時候,如果owner不存在了
    // 則需要将該線程所包含的WeakOrderQueue的元素釋放,然後從連結清單中删除該Queue。
    owner = new WeakReference<>(thread);
    //假設線程B和線程C同時回收線程A的對象時,有可能會同時建立一個WeakOrderQueue,就坑同時設定head,是以這裡需要加鎖
    synchronized (stackLock(stack)) {
        next = stack.head;
        stack.head = this;
    }
}
           

建立WeakOrderQueue對象的時候會初始化一個WeakReference的owner,作用是在poll的時候,如果owner不存在了, 則需要将該線程所包含的WeakOrderQueue的元素釋放,然後從連結清單中删除該Queue。

然後給stack加鎖,假設線程B和線程C同時回收線程A的對象時,有可能會同時建立一個WeakOrderQueue,就坑同時設定head,是以這裡需要加鎖。

以head==null的時候為例

加鎖:

線程B先執行,則head = 線程B的queue;之後線程C執行,此時将目前的head也就是線程B的queue作為線程C的queue的next,組成連結清單,之後設定head為線程C的queue

不加鎖:

線程B先執行 next = stack.head此時線程B的queue.next=null->線程C執行next = stack.head;線程C的queue.next=null-> 線程B執行stack.head = this;設定head為線程B的queue -> 線程C執行stack.head = this;設定head為線程C的queue,此時線程B和線程C的queue沒有連起來。

WeakOrderQueue#add

void add(DefaultHandle handle) {
    // 設定handler的最近一次回收的id資訊,标記此時暫存的handler是被誰回收的
    handle.lastRecycledId = id;

    Link tail = this.tail;
    int writeIndex;
    // 判斷一個Link對象是否已經滿了:
    // 如果沒滿,直接添加;
    // 如果已經滿了,建立一個新的Link對象,之後重組Link連結清單,然後添加元素的末尾的Link(除了這個Link,前邊的Link全部已經滿了)
    if ((writeIndex = tail.get()) == LINK_CAPACITY) {
        this.tail = tail = tail.next = new Link();
        writeIndex = tail.get();
    }
    tail.elements[writeIndex] = handle;
    // 如果使用者在将DefaultHandle對象壓入隊列後,将Stack設定為null
    // 但是此處的DefaultHandle是持有stack的強引用的,則Stack對象無法回收;
    //而且由于此處DefaultHandle是持有stack的強引用,WeakHashMap中對應stack的WeakOrderQueue也無法被回收掉了,導緻記憶體洩漏
    handle.stack = null;
    // we lazy set to ensure that setting stack to null appears before we unnull it in the owning thread;
    // this also means we guarantee visibility of an element in the queue if we see the index updated
    // tail本身繼承于AtomicInteger,是以此處直接對tail進行+1操作
    tail.lazySet(writeIndex + 1);
}
           

Stack異線程push對象流程:

  1. 首先擷取目前線程的 Map<Stack<?>, WeakOrderQueue> 對象,如果沒有就建立一個空 map;
  2. 然後從 map 對象中擷取 key 為目前的 Stack 對象的 WeakOrderQueue;
  3. 如果擷取的WeakOrderQueue對象為null,那麼建立一個WeakOrderQueue對象,并将對象放入到map中,最後調用WeakOrderQueue#add添加對象

WeakOrderQueue 的建立流程:

  1. 建立一個Link對象,将head和tail的引用都設定為此對象
  2. 建立一個WeakReference指向owner對象,設定目前的 WeakOrderQueue 所屬的線程為目前線程。
  3. 先将原本的 stack.head 指派給剛剛建立的 WeakOrderQueue 的 next 節點,之後将剛剛建立的 WeakOrderQueue 設定為 stack.head(這一步非常重要:假設線程 A 建立對象,此處是線程 C 回收對象,則線程 C 先擷取其 Map<Stack<?>, WeakOrderQueue> 對象中 key=線程A的stack對象的 WeakOrderQueue,然後将該 Queue 指派給線程 A 的 stack.head,後續的 pop 操作打基礎),形成 WeakOrderQueue 的連結清單結構。

WeakOrderQueue#add添加對象流程

  1. 首先設定 item.lastRecycledId = 目前 WeakOrderQueue 的 id
  2. 然後看目前的 WeakOrderQueue 中的 Link 節點連結清單中的尾部 Link 節點的 DefaultHandle[] 中的元素個數是否已經達到 LINK_CAPACITY(16)
  3. 如果不是,則直接将目前的 DefaultHandle 元素插入尾部 Link 節點的 DefaultHandle[] 中,之後置空目前的 DefaultHandle 元素的 stack 屬性,最後記錄目前的 DefaultHandle[] 中的元素數量;
  4. 如果是,則建立一個 Link,并且放在目前的 Link 連結清單中的尾部節點處,與之前的 tail 節點連起來(連結清單),之後進行第三步的操作。

從異線程擷取對象

我再把pop方法搬下來一次:

DefaultHandle pop() {
    int size = this.size;
    // size=0 則說明本線程的Stack沒有可用的對象,先從其它線程中擷取。
    if (size == 0) {
        // 當 Stack<T> 此時的容量為 0 時,去 WeakOrder 中轉移部分對象到 Stack 中
        if (!scavenge()) {
            return null;
        }
        //由于在transfer(Stack<?> dst)的過程中,可能會将其他線程的WeakOrderQueue中的DefaultHandle對象傳遞到目前的Stack,
        //是以size發生了變化,需要重新指派
        size = this.size;
    }
    //size表示整個stack中的大小
    size--;
    //擷取最後一個元素
    DefaultHandle ret = elements[size];
    if (ret.lastRecycledId != ret.recycleId) {
        throw new IllegalStateException("recycled multiple times");
    }
    // 清空回收資訊,以便判斷是否重複回收
    ret.recycleId = 0;
    ret.lastRecycledId = 0;
    this.size = size;
    return ret;
}
           
  1. 首先擷取目前的 Stack 中的 DefaultHandle 對象中的元素個數。
  2. 如果為 0,則從其他線程的與目前的 Stack 對象關聯的 WeakOrderQueue 中擷取元素,并轉移到 Stack 的 DefaultHandle[] 中(每一次 pop 隻轉移一個有元素的 Link),如果轉移不成功,說明沒有元素可用,直接傳回 null;
  3. 如果轉移成功,則重置 size屬性 = 轉移後的 Stack 的 DefaultHandle[] 的 size,之後直接擷取 Stack 對象中 DefaultHandle[] 的最後一位元素,之後做防護性檢測,最後重置目前的 stack 對象的 size 屬性以及擷取到的 DefaultHandle 對象的 recycledId 和 lastRecycledId 回收标記,傳回 DefaultHandle 對象。

scavenge轉移

Stack#scavenge

boolean scavenge() {
	// continue an existing scavenge, if any
	// 掃描判斷是否存在可轉移的 Handler
	if (scavengeSome()) {
	    return true;
	}
	
	// reset our scavenge cursor
	prev = null;
	cursor = head;
	return false;
}
           

調用scavengeSome掃描判斷是否存在可轉移的 Handler,如果沒有,那麼就傳回false,表示沒有可用對象

Stack#scavengeSome

boolean scavengeSome() {
    WeakOrderQueue cursor = this.cursor;
    if (cursor == null) {
        cursor = head;
        // 如果head==null,表示目前的Stack對象沒有WeakOrderQueue,直接傳回
        if (cursor == null) {
            return false;
        }
    }

    boolean success = false;
    WeakOrderQueue prev = this.prev;
    do {
        // 從目前的WeakOrderQueue節點進行 handler 的轉移
        if (cursor.transfer(this)) {
            success = true;
            break;
        }
        // 周遊下一個WeakOrderQueue
        WeakOrderQueue next = cursor.next;
        // 如果 WeakOrderQueue 的實際持有線程因GC回收了
        if (cursor.owner.get() == null) {
            // If the thread associated with the queue is gone, unlink it, after
            // performing a volatile read to confirm there is no data left to collect.
            // We never unlink the first queue, as we don't want to synchronize on updating the head.
            // 如果目前的WeakOrderQueue的線程已經不可達了
            //如果該WeakOrderQueue中有資料,則将其中的資料全部轉移到目前Stack中
            if (cursor.hasFinalData()) {
                for (;;) {
                    if (cursor.transfer(this)) {
                        success = true;
                    } else {
                        break;
                    }
                }
            }
            //将目前的WeakOrderQueue的前一個節點prev指向目前的WeakOrderQueue的下一個節點,
            // 即将目前的WeakOrderQueue從Queue連結清單中移除。友善後續GC
            if (prev != null) {
                prev.next = next;
            }
        } else {
            prev = cursor;
        }

        cursor = next;

    } while (cursor != null && !success);

    this.prev = prev;
    this.cursor = cursor;
    return success;
}
           
  1. 首先設定目前操作的 WeakOrderQueue cursor,如果為 null,則指派為 stack.head 節點,如果 stack.head 為 null,則表明外部線程沒有回收過目前線程建立的 對象,外部線程在回收對象的時候會建立一個WeakOrderQueue,并将stack.head 指向新建立的WeakOrderQueue對象,則直接傳回 false;如果不為 null,則繼續向下執行;
  2. 首先對目前的 cursor 進行元素的轉移,如果轉移成功,則跳出循環,設定 prev 和 cursor 屬性;
  3. 如果轉移不成功,擷取下一個線程 Y 中的與目前線程的 Stack 對象關聯的 WeakOrderQueue,如果該 queue 所屬的線程 Y 還可達,則直接設定 cursor 為該 queue,進行下一輪循環;如果該 queue 所屬的線程 Y 不可達了,則判斷其内是否還有元素,如果有,全部轉移到目前線程的 Stack 中,之後将線程 Y 的 queue 從查詢 queue 連結清單中移除。

transfer轉移

boolean transfer(Stack<?> dst) {
        //尋找第一個Link
        Link head = this.head;
        // head == null,沒有存儲資料的節點,直接傳回
        if (head == null) {
            return false;
        }
        // 讀指針的位置已經到達了每個 Node 的存儲容量,如果還有下一個節點,進行節點轉移
        if (head.readIndex == LINK_CAPACITY) {
            //判斷目前的Link節點的下一個節點是否為null,如果為null,說明已經達到了Link連結清單尾部,直接傳回,
            if (head.next == null) {
                return false;
            }
            // 否則,将目前的Link節點的下一個Link節點指派給head和this.head.link,進而對下一個Link節點進行操作
            this.head = head = head.next;
        }
        // 擷取Link節點的readIndex,即目前的Link節點的第一個有效元素的位置
        final int srcStart = head.readIndex;
        // 擷取Link節點的writeIndex,即目前的Link節點的最後一個有效元素的位置
        int srcEnd = head.get();
        // 本次可轉移的對象數量(寫指針減去讀指針)
        final int srcSize = srcEnd - srcStart;
        if (srcSize == 0) {
            return false;
        }
        // 擷取轉移元素的目的地Stack中目前的元素個數
        final int dstSize = dst.size;
        // 計算期盼的容量
        final int expectedCapacity = dstSize + srcSize;
        // 期望的容量大小與實際 Stack 所能承載的容量大小進行比對,取最小值
        if (expectedCapacity > dst.elements.length) {
            final int actualCapacity = dst.increaseCapacity(expectedCapacity);
            srcEnd = Math.min(srcStart + actualCapacity - dstSize, srcEnd);
        }

        if (srcStart != srcEnd) {
            // 擷取Link節點的DefaultHandle[]
            final DefaultHandle[] srcElems = head.elements;
            // 擷取目的地Stack的DefaultHandle[]
            final DefaultHandle[] dstElems = dst.elements;
            // dst數組的大小,會随着元素的遷入而增加,如果最後發現沒有增加,那麼表示沒有遷移成功任何一個元素
            int newDstSize = dstSize;
            //// 進行對象轉移
            for (int i = srcStart; i < srcEnd; i++) {
                DefaultHandle element = srcElems[i];
                // 表明自己還沒有被任何一個 Stack 所回收
                if (element.recycleId == 0) {
                    element.recycleId = element.lastRecycledId;
                //  避免對象重複回收
                } else if (element.recycleId != element.lastRecycledId) {
                    throw new IllegalStateException("recycled already");
                }
                // 将可轉移成功的DefaultHandle元素的stack屬性設定為目的地Stack
                element.stack = dst;
                // 将DefaultHandle元素轉移到目的地Stack的DefaultHandle[newDstSize ++]中
                dstElems[newDstSize++] = element;
                // 設定為null,清楚暫存的handler資訊,同時幫助 GC
                srcElems[i] = null;
            }
            // 将新的newDstSize指派給目的地Stack的size
            dst.size = newDstSize;

            if (srcEnd == LINK_CAPACITY && head.next != null) {
                // 将Head指向下一個Link,也就是将目前的Link給回收掉了
                // 假設之前為Head -> Link1 -> Link2,回收之後為Head -> Link2
                this.head = head.next;
            }
            // 設定讀指針位置
            head.readIndex = srcEnd;
            return true;
        } else {
            // The destination stack is full already.
            return false;
        }
    }
}
           
  1. 尋找 cursor 節點中的第一個 Link如果為 null,則表示沒有資料,直接傳回;
  2. 如果第一個 Link 節點的 readIndex 索引已經到達該 Link 對象的 DefaultHandle[] 的尾部,則判斷目前的 Link 節點的下一個節點是否為 null,如果為 null,說明已經達到了 Link 連結清單尾部,直接傳回,否則,将目前的 Link 節點的下一個 Link 節點指派給 head ,進而對下一個 Link 節點進行操作;
  3. 擷取 Link 節點的 readIndex,即目前的 Link 節點的第一個有效元素的位置
  4. 擷取 Link 節點的 writeIndex,即目前的 Link 節點的最後一個有效元素的位置
  5. 計算 Link 節點中可以被轉移的元素個數,如果為 0,表示沒有可轉移的元素,直接傳回
  6. 擷取轉移元素的目标 Stack 中目前的元素個數(dstSize)并計算期盼的容量 expectedCapacity,如果 expectedCapacity 大于目标Stack 的長度(dst.elements.length),則先對目的地 Stack 進行擴容,計算 Link 中最終的可轉移的最後一個元素的下标;
  7. 如果發現目的地 Stack 已經滿了( srcStart != srcEnd為false),則直接傳回 false
  8. 擷取 Link 節點的 DefaultHandle[] (srcElems)和目标 Stack 的 DefaultHandle[](dstElems)
  9. 根據可轉移的起始位置和結束位置對 Link 節點的 DefaultHandle[] 進行循環操作
  10. 将可轉移成功的 DefaultHandle 元素的stack屬性設定為目标 Stack(element.stack = dst),将 DefaultHandle 元素轉移到目的地 Stack 的 DefaultHandle[newDstSize++] 中,最後置空 Link 節點的 DefaultHandle[i]
  11. 如果目前被周遊的 Link 節點的 DefaultHandle[] 已經被掏空了(srcEnd == LINK_CAPACITY),并且該 Link 節點還有下一個 Link 節點
  12. 重置目前 Link 的 readIndex