/**

 * 通過“死循環(huán)”的方式來正確的添加節(jié)點

 */

private Node enq(final Node node) {

    // 不斷循環(huán)，直至CAS插入節(jié)點成功

    for (;;) {

        Node t = tail;

        if (t == null) { 

            // 當尾節(jié)點為null，此時需要初始化頭節(jié)點和尾節(jié)點

            if (compareAndSetHead(new Node()))

                tail = head;

        } else {

            // 插入節(jié)點前驅(qū)節(jié)點指向原先尾節(jié)點

            node.prev = t;

            // CAS插入至同步隊列的尾節(jié)點

            if (compareAndSetTail(t, node)) {

                t.next = node;

                return t;

            }

        }

    }

}

/**

 * “死循環(huán)”獲取同步狀態(tài)，并且當前僅當前驅(qū)節(jié)點是頭節(jié)點是才能夠嘗試獲取同步狀態(tài)

 */

final boolean acquireQueued(final Node node, int arg) {

    boolean failed = true;

    try {

        boolean interrupted = false;

        // 不斷循環(huán)

        for (;;) {

            // 獲取當前節(jié)點的前驅(qū)節(jié)點，如果前驅(qū)節(jié)點為null將會拋出空指針異常

            final Node p = node.predecessor();

            // 如果當前節(jié)點的前驅(qū)節(jié)點是頭節(jié)點，嘗試獲取同步狀態(tài)

            if (p == head && tryAcquire(arg)) {

                // 設(shè)置當前節(jié)點為頭節(jié)點，并且將節(jié)點線程和節(jié)點的前驅(qū)節(jié)點置為null，help GC

                setHead(node);

                p.next = null; // help GC

                failed = false;

                return interrupted;

            }

            // 如果不符合條件，則判斷當前節(jié)點前驅(qū)節(jié)點的waitStatus狀態(tài)來決定是否需要掛起LockSupport.park(this);

            if (shouldParkAfterFailedAcquire(p, node) &&

                parkAndCheckInterrupt())

                interrupted = true;

        }

    } finally {

        // 失敗則取消

        if (failed)

            cancelAcquire(node);

    }

}

package com.liziba.jsw;

/**

 * <p>

 *		for死循環(huán)測試

 * </p>

 *

 * @Author: Liziba

 * @Date: 2021/6/21 11:36

 */

public class Test {



    private static void m1() {

        for (;;) {



        }

    }

    

}

package com.liziba.jsw;



/**

 * <p>

 *		while死循環(huán)測試

 * </p>

 *

 * @Author: Liziba

 * @Date: 2021/6/21 11:36

 */

public class Test {

    

    private static void m2() {

        while (true){



        }

    }

    

}