1.BlockingQueue:支持两个附加操作的 Queue，这两个操作是：检索元素时等待队列变为非空，以及存储元素时等待空间变得可用。

　　2.BlockingQueue 不接受 null 元素。

　　3.BlockingQueue 可以是限定容量的。

　　4.BlockingQueue 实现是线程安全的。Queue不是线程安全的。因此可以将Blockingqueue用于用于生产者-使用者队列。

　　根据Api修改的一个例子，大家可以修改自己体验BlockingQueue的使用

　　package test;

　　import java.util.concurrent.ArrayBlockingQueue;

　　import java.util.concurrent.BlockingQueue;

　　/**

　　* 生产者

　　* @author wasw100

　　*/

　　class Producer implements Runnable {

　　private final BlockingQueue queue;

　　Producer(BlockingQueue q) {

　　queue = q;

　　}

　　public void run() {

　　try {

　　for (int i = 0; i < 3; i++) {

　　queue.put(produce());

　　System.out.println("生产后："+queue.peek());

　　}

　　} catch (InterruptedException ex) {

　　ex.printStackTrace();

　　}

　　}

　　Character produce() {

　　char c = (char) (Math.random() * 26 + 'A');

　　System.out.println("生产前：" + c);

　　return c;

　　}

　　}

　　/**

　　* 消费者

　　* @author wasw100

　　*/

　　class Consumer implements Runnable {

　　private final BlockingQueue queue;

　　Consumer(BlockingQueue q) {

　　queue = q;

　　}

　　public void run() {

　　try {

　　while (true) {

　　consume(queue.take());

　　//Thread.sleep(100);

　　}

　　} catch (InterruptedException ex) {

　　ex.printStackTrace();

　　}

　　}

　　void consume(Character c) {

　　System.out.println("消费：" + c);

　　}

　　}

　　/**

　　* 一个生产者、两个消费者

　　*

　　* @author wasw100

　　*/

　　class Setup {

　　public static void main(String[] args) {

　　BlockingQueue q = new ArrayBlockingQueue(1);

　　Producer p = new Producer(q);

　　Consumer c1 = new Consumer(q);

　　Consumer c2 = new Consumer(q);

　　new Thread(p).start();

　　new Thread(c1).start();

　　new Thread(c2).start();

　　}

　　}