Java中Queue和BlockingQueue的区别

cloudskyme

发布于 2018-03-20 14:19:17

6310

发布于 2018-03-20 14:19:17

文章被收录于专栏：cloudskymecloudskyme

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

本文参与腾讯云自媒体分享计划，分享自作者个人站点/博客。

原始发表：2011-05-09 ，如有侵权请联系 cloudcommunity@tencent.com 删除

java