回顾：

阻塞队列，英文名叫BlockingQueue。首先他是一种队列，联系之前中介绍的Queue与Collection，我们就很容易开始今天的阻塞队列的学习了。来看一下他们的接口定义：

Queue：

（方法很简单，就不一一注释解释其作用了。）

public interface Queue
    
      extends Collection
     
       {       boolean add(E e);    boolean offer(E e);    E remove();    E poll();    E element();      E peek();}
     
    

BlockingQueue：

      因为是继承自Queue，方法基本类似，就不再写了。主要方法有三个：add，remove，element（用于检查）。

      那到底什么是阻塞队列呢？联系前面的例子，在篮子中没有馒头时，生成者要放入馒头消费者才能食用；在篮子里装满馒头时，生产者就不能继续生产了，要等人去吃。阻塞队列就是生产者存放馒头的容器，消费者从中取出元素，也就是那个篮子。

public interface BlockingQueue
    
      extends Queue
     
       {...... }
     
    

      BlockingQueue的实现类有很多，这里介绍一个很简单的ArrayBlockingQueue。他是一个数据结构组成的阻塞队列，按照FIFO先进先出的方式排序。

继续来看他的定义，下面只列举了常用的两个方法：

public class ArrayBlockingQueue
    
      extends AbstractQueue
     
              implements BlockingQueue
      
       , java.io.Serializable {				//放入元素    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 {            while (count == 0)                notEmpty.await();            return dequeue();        } finally {            lock.unlock();        }    }		}
      
     
    

来个例子：

//Capacity为3的阻塞队列		final BlockingQueue queue = new  ArrayBlockingQueue(3);		for (int i = 0; i < 2; i++) {			//1、放馒头线程			new Thread() {				@Override				public void run() {					while (true) {						try {							Thread.sleep((long) (Math.random() * 10000));							System.out.println(Thread.currentThread().getName()									+ "准备放馒头!");							//每次放入一个馒头							queue.put(1);							System.out.println(Thread.currentThread().getName()									+ "已经放了馒头，" + "队列目前有" + queue.size()									+ "个馒头");						} catch (InterruptedException e) {							e.printStackTrace();						}					}				}			}.start();		}		//2、取馒头线程		new Thread() {			@Override			public void run() {				while (true) {					try {						Thread.sleep((long) (Math.random() * 10000));						System.out.println(Thread.currentThread().getName()								+ "准备取馒头!");						//拿走一个						queue.take();						System.out.println(Thread.currentThread().getName()								+ "已经取走馒头，" + "队列目前有" + queue.size() + "个馒头");					} catch (InterruptedException e) {						e.printStackTrace();					}				}			}		}.start();	}

部分执行结果：

对比：

       和之前手动实现生产者消费者的例子相比，这次的实现就简单多了。不再需要去管篮子里的“取”和“放”的操作，不用关心线程的同步互斥问题，不用关心篮子是空了还是满了。只需要简单的调用put或take方法即可，把复杂的阻塞问题教给BlockingQueue去处理，但是原理还是一样的。