在 ArrayBlockingQueue 的源码中, 可以看到两个Condition对象

ReentrantLock lock = new ReentrantLock(fair);
Condition notEmpty = lock.newCondition();
Condition notFull =  lock.newCondition();

这两个condition是做什么的呢?

总结

看下源码, lock.newCondition() 是 Lock 接口中定义的方法, 在 ReentrantLock 的实现中 return AbstractQueuedSynchronizer.newCondition(), 而这个 AbstractQueuedSynchronizer.newCondition() 创建了 AbstractQueuedSynchronizer 的内部类 public class ConditionObject implements Condition, java.io.Serializable .

下面看见 ConditionObject 的类结构

总的来说, Lock + Condition ≈ Synchronized + Object.wait()/notify()

Condition中的await()方法相当于Object的wait()方法，Condition中的signal()方法相当于Object的notify()方法，Condition中的signalAll()相当于Object的notifyAll()方法.
不同的是, 同一个锁可以有多个 Condition, 提供多种情况的互不干扰的控制.

内部实现

ConditionObject 中使用Node类实现了一个链表, 用来缓存所有的等待线程.

• 每次执行await()等待时, 都会在addConditionWaiter()方法里使用当前await()所在的线程构建一个node对象, 并插入到等待链表中;
• 执行signal()时又会在transferForSignal()方法中从链表中移除顶部node, 并把该node内的thread从阻塞队列中转移到可运行队列中.