Java中Queue和BlockingQueue的区别

时间:2022-05-04
本文章向大家介绍Java中Queue和BlockingQueue的区别,主要内容包括其使用实例、应用技巧、基本知识点总结和需要注意事项,具有一定的参考价值,需要的朋友可以参考一下。

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