学习JUC源码（3）——Condition等待队列（源码分析结合图文理解）

　　在Java多线程中的wait/notify通信模式结尾就已经介绍过，Java线程之间有两种种等待/通知模式，在那篇博文中是利用Object监视器的方法（wait()，notify()、notifyAll()）实现的，然而在实际生产环境中不推荐使用此方法，建议使用condition的等待通知模式，JUC包中很多核心实现也确实证实了这点，所以这必然是学习JUC包源码的基础。

　　如果之前阅读过前不久介绍同步队列的博文学习JUC源码（1）——AQS同步队列（源码分析结合图文理解），就能更好理解Condition等待队列了，都是基于AQS.Node实现的队列，两者是同步器实现的核心所在！

　　主要参考资料《Java并发编程艺术》（有需要的小伙伴可以找我，我这里只有电子PDF）同时结合ReentranLock、AQS、ArrayBlockingQueue等源码。

 

 

一、Condition等待队列介绍 1、对比Object监视器方法与Condition方法

以下对比图来源于《Java并发编程艺术》，可以清楚看到Condition比Object监视器更加灵活，支持中断响应等。

2、Condition方法使用介绍

我们先看下阻塞队列ArrayBlockingQueue中关于condition的经典应用，这里使用就是condition的等待通知模式实现有界阻塞队列，即简单总结：当队列满时，阻塞插入线程，队列空时，获取元素的线程等待。

/** Condition for waiting takes */ private final Condition notEmpty; /** Condition for waiting puts */ private final Condition notFull; public void put(E e) throws InterruptedException { checkNotNull(e); final ReentrantLock lock = this.lock; lock.lockInterruptibly(); try { // 队列满时等待 while (count == items.length) notFull.await(); enqueue(e); } finally { lock.unlock(); } } public E take() throws InterruptedException { final ReentrantLock lock = this.lock; lock.lockInterruptibly(); try { // 队列空时进入Condition等待队列等待 while (count == 0) notEmpty.await(); return dequeue(); } finally { lock.unlock(); } }