详解ConditionObject

什么是ConditionObject：

ConditionObject的应用：

源码分析await()方法：（前置）

进入await()方法：

进入addConditionWaiter()方法：

unlinkCancelledWaiters()方法

fullyRelease(node)方法：

源码分析signal()方法：

主体了解一下唤醒的流程：

signal():方法

doSignal(first);方法

transferForSignal(first)方法：

源码分析await()方法：（后置）

方法transferAfterCancelledWait(node)：

isOnSyncQueue()方法

acquireQueued(node, savedState)方法

reportInterruptAfterWait(int interruptMode)方法：

源码分析awaitNanos&signalAll方法

进入方法awaitNanos():

宏观理解方法实现

signalAll方法（）

什么是ConditionObject：

在synchronized里面我们可以使用wait()方法挂起线程，notify()方法唤醒线程，ReentrantLock也提供和了自己专属的方式达到这个要求。那就是await()方法和signal()方法。

注意在使用await()方法和signal()方法的线程必须拥有锁。

ConditionObject的应用：

我们的流程的分析：

首先我们的线程1开始时获取到锁资源吗，之后调用await()方法，将当前获得到锁的线程1挂起，这时我们的主线程开始获取锁，之后让主线程将线程1唤醒，之后线程1结束锁资源。大家可以直接运行一下代码看一下效果。

public class Show_Contidion {private static ReentrantLock lock = new ReentrantLock();
public static void main(String[] args)   {Condition condition = lock.newCondition();Thread t1 = new Thread(() -> {lock.lock();//开始获取到System.out.println("线程1获取到锁资源");try {//我是先睡眠，所以现在主线程要等到可以执行await（）时才可以获取资源Thread.sleep(5000);} catch (InterruptedException e) {throw new RuntimeException(e);}try {condition.await();//将线程挂起} catch (InterruptedException e) {throw new RuntimeException(e);}System.out.println("线程一再次获取到锁");});t1.start();try {Thread.sleep(1000);} catch (InterruptedException e) {throw new RuntimeException(e);}
lock.lock();System.out.println("主线程获取到锁");condition.signal();lock.unlock();}
}

源码分析await()方法：（前置）

首先我们在前置分析中，这是分析到线程挂起。后续的在后置中讲解，接着读。

看源码时发现对于单项链表，我们设置一个哨兵节点是很有必要的，这对于我们在写算法与数据结构时也有帮助。

进入await()方法：

在进入后我们发现这个方法是抽象的方法，接着直接去看他的实现类：

 void await() throws InterruptedException;

在前置方法里面我们先只是看到线程挂起的过程，在线程挂起之后的那部分我们在后续的后置部分讲解。

public final void await() throws InterruptedException {//判断是否出现中断，如果是中断直接抛出异常if (Thread.interrupted())throw new InterruptedException();//讲节点添加进condition单向链表Node node = addConditionWaiter();//讲持有的锁全部释放int savedState = fullyRelease(node);//设置中断的modeint interruptMode = 0;//如果不再AQS队列是，开始挂起线程 //因为是先释放的锁资源，如果在释放之后，其他的线程直接讲当前线程唤醒，那么他就直接进入AQS队列直接排队，准备抢占线程，那样的话，无需再次挂起线程。while (!isOnSyncQueue(node)) {LockSupport.park(this);//...后置代码在接下来讲解}
}