Java并发编程-再谈 AbstractQueuedSynchronizer 1 ：独占模式（2）

look_w

acquireQueued队列构建好了，下一步就是在必要的时候从队列里面拿出一个Node了，这就是acquireQueued方法，顾名思义，从队列里面acquire。看下acquireQueued方法的实现：

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21

final boolean acquireQueued(final Node node, int arg) {     boolean failed = true;     try {         boolean interrupted = false;         for (;;) {             final Node p = node.prevecessor();             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);     } }

这段代码描述了几件事：

• 从第6行的代码获取节点的前驱节点p，第7行的代码判断p是前驱节点并tryAcquire我们知道，只有当前第一个持有Thread的节点才会尝试acquire，如果节点acquire成功，那么setHead方法，将当前节点作为head、将当前节点中的thread设置为null、将当前节点的prev设置为null，这保证了数据结构中头结点永远是一个不带Thread的空节点
• 如果当前节点不是前驱节点或者tryAcquire失败，那么执行第13行~第15行的代码，做了两步操作，首先判断在acquie失败后是否应该park，其次park并检查中断状态

看一下第一步shouldParkAfterFailedAcquire代码做了什么：

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27

private static boolean shouldParkAfterFailedAcquire(Node prev, Node node) {     int ws = prev.waitStatus;     if (ws == Node.SIGNAL)         /*          * This node has already set status asking a release          * to signal it, so it can safely park.          */         return true;     if (ws > 0) {         /*          * prevecessor was cancelled. Skip over prevecessors and          * indicate retry.          */         do {             node.prev = prev = prev.prev;         } while (prev.waitStatus > 0);         prev.next = node;     } else {         /*          * waitStatus must be 0 or PROPAGATE.  Indicate that we          * need a signal, but don't park yet.  Caller will need to          * retry to make sure it cannot acquire before parking.          */         compareAndSetWaitStatus(prev, ws, Node.SIGNAL);     }     return false; }

这里每个节点判断它前驱节点的状态，如果：

• 它的前驱节点是SIGNAL状态的，返回true，表示当前节点应当park
• 它的前驱节点的waitStatus>0，相当于CANCELLED（因为状态值里面只有CANCELLED是大于0的），那么CANCELLED的节点作废，当前节点不断向前找并重新连接为双向队列，直到找到一个前驱节点waitStats不是CANCELLED的为止
• 它的前驱节点不是SIGNAL状态且waitStatus<=0，此时执行第24行代码，利用CAS机制，如果waitStatus的前驱节点是0那么更新为SIGNAL状态

如果判断判断应当park，那么parkAndCheckInterrupt方法：

1 2 3 4

private final boolean parkAndCheckInterrupt() {       LockSupport.park(this);       return Thread.interrupted(); }

利用LockSupport的park方法让当前线程阻塞。