( 六）类似Object监视器方法的Condition接口

Dear 丶 2022-01-27 10:19 197阅读 0赞

在[《有关线程、并发的基本概念》][Link 1]中，我们利用synchronized关键字、Queue队列、以及Object监视器方法实现了生产者消费者，介绍了有关线程的一些基本概念。Object类提供的wait的方法和notifyAll方法，与之对应的是Condition接口提供是await和signalAll。await(或wait)是让当前线程进入等待状态并释放锁，signalAll(或notifyAll)则是唤醒等待中的线程，使得等待中的线程有竞争锁的资格，注意只是资格，并不代表被唤醒的线程就一定会获得锁。

Condition接口的具体实现还是在AbstractQueuedSynchronizer中的内部实现的——AbstractQueuedSynchronizer$ConditionObject。ConditionObject中维护了一个“等待队列”，注意这个和AQS同步器维护的“同步队列”不同。AQS所维护的同步队列是当前等待资源（同步状态）的队列，当前线程获取同步状态失败时，同步器会将当前线程以及等待状态等信息构造成一个节点并加入到同步队列中，同时阻塞当前线程，当同步状态被所持有的线程释放时会将同步队列中的首节点唤醒重新获取同步状态。而每个Condition维护一个等待队列，该队列的作用是一个等待signal信号的队列。这两者之间的关系是一个协同的关系，用下图的说明它们之间的协同过程：

1. AQS的同步队列如下图所示，一个头结点head指向队首，一个tail指向队尾，当线程调用lock()方法获取锁而未成功时，线程被构造成节点加入到队尾。（图中NodeA是同步队列的第一个节点，也就是获得同步状态的节点）

![630246-20170530235236852-980741823.png][]

2.NodeA调用await()方法时，NodeA从AQS同步队列中移除，自然也就释放了锁，NodeA此时被加入到Condition的等待队列中，等待signal信号，如下图所示。

![630246-20170530235347196-1175840153.png][]

3.执行完第2步后，此时NodeB在同步队列中处于第一个节点位置，即获取到了锁，如果NodeB此时执行signal(或者signalAll)方法，NodeA将会从Condition等待队列中被移除即被唤醒，加入到同步队列中，此时NodeA仅仅是被唤醒有了在同步队列中争夺资源的资格，并不代表被唤醒后就立即获得锁，如下图所示。

![630246-20170530235422133-1426171474.png][]

4. 最后NodeB在signal执行完毕后，调用unLock方法释放锁，此时NodeA处于队首，并争夺同步状态。

以上是AQS的“同步队列”和Condition的“等待队列”之间相互协作的过程，下面从源码解析Condition的主要方法await、signal、signalAll。

1 public final void await() throws InterruptedException{
     2     if (Thread.interrupted())    //线程被中断则抛出中断异常
     3         throw new InterruptedException();
     4     Node node = addConditionWaiter();    //将线程构造为Node节点
     5     long savedState = fullyRelease(node);    //释放锁，返回同步状态
     6     int interruptMode = 0;
     7     while (!isOnSyncQueue(node)) {    //循环判断当前节点是否在同步队列中
     8         LockSupport.park(this);
     9         if ((interruptMode = checkInterruptWhileWaiting(node)) != 0)
    10             break;    //检查节点在处于等待状态时是否被中断
    11 　　}
    12 　　//在跳出了循环，即被signal唤醒后重新加入了同步队列后，开始重新竞争锁
    13 　　if (acquireQueued(node, savedState) && interruptMode != THROW_IE)    //acquireQueued自旋获取锁，具体分析见《从AbstractQueuedSynchronizer(AQS)说起——独占模式的锁获取与释放》中对获取同步状态的解析
    14 　　　　interruptMode = REINTERRUPT;    
    15 　　if (node.nextWaiter != null) 
    16     　　unlinkCancelledWaiters();    //如果节点从等待状态转换为在同步队列中，并且也已经获得了锁，此时将断开此节点后面的等待节点
    17 　　if (interruptMode != 0)
    18     　　reportInterruptAfterWait(interruptMode);
    19  }

在获取锁的线程调用await时，首先会将线程构造为Node节点并释放锁，此时线程被移出同步队列加入到Condition等待队列中，接着在第7行就会while循环判断节点是否在同步队列中，当没有线程调用signal方法的时候显然线程不在同步队列，并将一直循环，直到有线程调用signal方法该线程才会被唤醒加入到同步队列中，此时才会跳出循环。

signal和signalAll方法的异同在和notify和notifyAll一样。signal只会唤醒等待队列中位于队首的节点使其具有竞争锁的资格，而signalAll则会唤醒等待队列中所有节点使所有节点都具有竞争锁的资格。

1 public final void signal() {
    2     if (!isHeldExclusively())    //判断当前线程是否持有锁
    3         throw new IllegalMonitorStateException();
    4     Node first = firstWaiter;
    5     if (first != null)
    6         doSignal(first);        //唤醒等待队列中的第一个节点
    7 }

对比signalAll方法，不同点在于第6行是唤醒等待队列中的所有节点——doSignalAll(first)，不再贴出代码。

private void doSignal(Node first) {
        do {
            if ((firstWaiter = first.nextWaiter) == null)
                lastWaiter = null;
            first.nextWaiter = null;
    } while (!transferForSignal(first) && (first = firstWaiter) != null)    //transferForSignal方法将处于等待队列中的节点添加到同步队列中
    }

至于doSignalAll则是循环调用transferForSignal使得所有节点都被唤醒加入到同步队列中。

*　　*当节点从等待队列中加入到同步队列中时，呼应await中的循环等待节点是否在同步队列中，await和signal的协同配合也就很清晰明了了。

[Link 1]: http://www.cnblogs.com/yulinfeng/p/6845222.html
[630246-20170530235236852-980741823.png]: /images/20220127/745b753e1231442c96cd691d421d50a7.png
[630246-20170530235347196-1175840153.png]: /images/20220127/c986d208d4fa486a950b5e22e2f40cee.png
[630246-20170530235422133-1426171474.png]: /images/20220127/fdaa6ae7b3a94856a9010e1e85fa3a5b.png