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

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

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

独占模式release流程上面整理了独占模式的acquire流程，看到了等待的Node是如何构建成一个数据结构的，下面看一下释放的时候做了什么，release方法的实现为：

1
2
3
4
5
6
7
8
9

public final boolean release(int arg) {
if (tryRelease(arg)) {
      Node h = head;
      if (h != null && h.waitStatus != 0)
         unparkSuccessor(h);
      return true;
}
return false;
}

tryRelease同样是子类去实现的，表示当前动作我执行完了，要释放我执行当前动作的资格，讲这个资格让给其它线程，然后tryRelease释放成功，获取到head节点，如果head节点的waitStatus不为0的话，执行unparkSuccessor方法，顾名思义unparkSuccessor意为unpark头结点的继承者，方法实现为：

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

private void unparkSuccessor(Node node) {
      /*
      * If status is negative (i.e., possibly needing signal) try
      * to clear in anticipation of signalling.  It is OK if this
      * fails or if status is changed by waiting thread.
      */
      int ws = node.waitStatus;
      if (ws < 0)
         compareAndSetWaitStatus(node, ws, 0);

      /*
      * Thread to unpark is held in successor, which is normally
      * just the next node.  But if cancelled or apparently null,
      * traverse backwards from tail to find the actual
      * non-cancelled successor.
      */
      Node s = node.next;
      if (s == null || s.waitStatus > 0) {
         s = null;
         for (Node t = tail; t != null && t != node; t = t.prev)
            if (t.waitStatus <= 0)
                  s = t;
      }
      if (s != null)
         LockSupport.unpark(s.thread);
}

这段代码比较好理解，整理一下流程：

头节点的waitStatus<0，将头节点的waitStatus设置为0
拿到头节点的下一个节点s，如果s==null或者s的waitStatus>0（被取消了），那么从队列尾巴开始向前寻找一个waitStatus<=0的节点作为后继要唤醒的节点

最后，如果拿到了一个不等于null的节点s，就利用LockSupport的unpark方法让它取消阻塞。

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