电子技术论坛_中国专业的电子工程师学习交流社区-中电网技术论坛

标题: Java并发编程-再谈 AbstractQueuedSynchronizer 1 ：独占模式（2） [打印本页]

作者: look_w 时间: 2019-1-17 19:37 标题: Java并发编程-再谈 AbstractQueuedSynchronizer 1 ：独占模式（2）

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方法让当前线程阻塞。

欢迎光临电子技术论坛_中国专业的电子工程师学习交流社区-中电网技术论坛 (http://bbs.eccn.com/)