tryAcquire()、addWaiter()、acquireQueued()三者的區(qū)別是什么

tryAcquire()、addWaiter()、acquireQueued()三者的區(qū)別是什么，針對(duì)這個(gè)問(wèn)題，這篇文章詳細(xì)介紹了相對(duì)應(yīng)的分析和解答，希望可以幫助更多想解決這個(gè)問(wèn)題的小伙伴找到更簡(jiǎn)單易行的方法。

tryAcquire()

final boolean nonfairTryAcquire(int acquires) {
      final Thread current = Thread.currentThread();
      int c = getState();
      if (c == 0) {
        if (compareAndSetState(0, acquires)) {
          setExclusiveOwnerThread(current);
          return true;
        }
      }
      else if (current == getExclusiveOwnerThread()) {
        int nextc = c + acquires;
        if (nextc < 0) // overflow
          throw new Error("Maximum lock count exceeded");
        setState(nextc);
        return true;
      }
      return false;
    }

先判斷state是否為0，如果為0就執(zhí)行上面提到的lock方法的前半部分，通過(guò)CAS操作將state的值從0變?yōu)?，否則判斷當(dāng)前線程是否為exclusiveOwnerThread，然后把state++，也就是重入鎖的體現(xiàn)，我們注意前半部分是通過(guò)CAS來(lái)保證同步，后半部分并沒(méi)有同步的體現(xiàn)，原因是：后半部分是線程重入，再次獲得鎖時(shí)才觸發(fā)的操作，此時(shí)當(dāng)前線程擁有鎖，所以對(duì)ReentrantLock的屬性操作是無(wú)需加鎖的。如果tryAcquire()獲取失敗，則要執(zhí)行addWaiter()向等待隊(duì)列中添加一個(gè)獨(dú)占模式的節(jié)點(diǎn)。

addWaiter()

/**
   * Creates and enqueues node for current thread and given mode.
   *
   * @param mode Node.EXCLUSIVE for exclusive, Node.SHARED for shared
   * @return the new node
   */
  private Node addWaiter(Node mode) {
    Node node = new Node(Thread.currentThread(), mode);
    // Try the fast path of enq; backup to full enq on failure
    Node pred = tail;
    if (pred != null) {
      node.prev = pred;
      if (compareAndSetTail(pred, node)) {
        pred.next = node;
        return node;
      }
    }
    enq(node);
    return node;
  }

這個(gè)方法的注釋?zhuān)簞?chuàng)建一個(gè)入隊(duì)node為當(dāng)前線程，Node.EXCLUSIVE 是獨(dú)占鎖, Node.SHARED 是共享鎖。
先找到等待隊(duì)列的tail節(jié)點(diǎn)pred，如果pred！=null，就把當(dāng)前線程添加到pred后面進(jìn)入等待隊(duì)列，如果不存在tail節(jié)點(diǎn)執(zhí)行enq()

private Node enq(final Node node) {
    for (;;) {
      Node t = tail;
      if (t == null) { // Must initialize
        if (compareAndSetHead(new Node()))
          tail = head;
      } else {
        node.prev = t;
        if (compareAndSetTail(t, node)) {
          t.next = node;
          return t;
        }
      }
    }
  }

這里進(jìn)行了循環(huán)，如果此時(shí)存在了tail就執(zhí)行同上一步驟的添加隊(duì)尾操作，如果依然不存在，就把當(dāng)前線程作為head結(jié)點(diǎn)。
插入節(jié)點(diǎn)后，調(diào)用acquireQueued()進(jìn)行阻塞

acquireQueued()

final boolean acquireQueued(final Node node, int arg) {
    boolean failed = true;
    try {
      boolean interrupted = false;
      for (;;) {
        final Node p = node.predecessor();
        if (p == head && tryAcquire(arg)) {
          setHead(node);
          p.next = null; // help GC
          failed = false;
          return interrupted;
        }
        if (shouldParkAfterFailedAcquire(p, node) &&
          parkAndCheckInterrupt())
          interrupted = true;
      }
    } finally {
      if (failed)
        cancelAcquire(node);
    }
  }

先獲取當(dāng)前節(jié)點(diǎn)的前一節(jié)點(diǎn)p，如果p是head的話就再進(jìn)行一次tryAcquire(arg)操作，如果成功就返回，否則就執(zhí)行shouldParkAfterFailedAcquire、parkAndCheckInterrupt來(lái)達(dá)到阻塞效果；

關(guān)于tryAcquire()、addWaiter()、acquireQueued()三者的區(qū)別是什么問(wèn)題的解答就分享到這里了，希望以上內(nèi)容可以對(duì)大家有一定的幫助，如果你還有很多疑惑沒(méi)有解開(kāi)，可以關(guān)注億速云行業(yè)資訊頻道了解更多相關(guān)知識(shí)。