Java中Queue和BlockingQueue的区别

内容主要来自jdk的api，大家可参考jdkapi

　　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();
   }
}