一. Condition 接口

1. Condition接口也提供了类似Object的监视器方法，与Lock配合可以实现等待/通知模式。 但是这两者在使用方式以及功能特性上还是有差别的。 

2. 支持多个等待队列个数 

3. 支持当前线程施放锁并进入等待状态 

4. 支持当前线程施放锁并进入等待状态，在等待状态中不响应中断 

5. 支持当前线程施放锁并进入超时等待状态 

6. 支持当前线程施放锁并进入等待状态到将来的某个时间 

7. 支持唤醒等待队列中的一个线程 

8. 支持唤醒等待队列中的全部线程 

package com.dcz.juc;

import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.Condition;
import java.util.concurrent.locks.ReentrantLock;

public class BoundedQueue<T> {

	private Object[] items;

	// 添加的下标，删除的下标和数组当前数量
	private int addIndex, removeIndex, count;
	// 重入锁
	private Lock lock = new ReentrantLock();
	// 空
	private Condition notEmpty = lock.newCondition();
	// 满
	private Condition notFull = lock.newCondition();

	// 初始化队列大小
	public BoundedQueue(int size) {
		items = new Object[size];
	}

	// 添加一个元素，如果数组满，则添加线程进入等待状态，直到有空位
	public void add(T t) throws InterruptedException {
		lock.lock();
		try {
			while (count == items.length) {
				// 数组满，进入等待状态
				notFull.await();
				// 入队
				items[addIndex] = t;
				if (++addIndex == items.length) {
					addIndex = 0;
				}
				++count;
				notEmpty.signal();
			}
		} finally {

			lock.unlock();
		}
	}

	// 由头部删除一个元素，如果数组空，则删除线程进入等待状态，直到有新添加元素
	public T remove() throws InterruptedException {
		lock.lock();
		try {
			while(count == 0){
				notEmpty.await();
				Object o = items[removeIndex];
				if(++removeIndex == items.length){
					removeIndex = 0;
				}
				--count;
				notFull.signal();
				return (T)o;
			}
		} finally {
			lock.unlock();
		}
		return null;
	}

}