关于spring:java并发编程工具类JUC第二篇ArrayBlockingQueue

37次阅读

共计 2147 个字符，预计需要花费 6 分钟才能阅读完成。

类 ArrayBlockingQueue 是BlockingQueue接口的实现类，它是 有界的 阻塞队列，外部应用数组存储队列元素。这里的“有界”是指存储容量存在下限，不能有限存储元素。在同一时间内存储容量存在着一个上限值，这个上限度在初始实例化的时候指定，之后便不能批改了。

ArrayBlockingQueue外部采纳 FIFO (First In, First Out)先进先出的办法实现队列数据的存取，队首的元素是在队列中保留工夫最长的元素对象，队尾的元素是在队列中保留工夫最短的元素对象。

上面的代码阐明如何初始化一个ArrayBlockingQueue，并向其中增加一个对象：

BlockingQueue queue = new ArrayBlockingQueue(1024);
queue.put("1");   // 向队列中增加元素
Object object = queue.take();   // 从队列中取出元素

BlockingQueue能够通过泛型来限定队列中存储数据的类型，上面的代码以 String 为泛型，示意该队列只能存储 String 类型。

BlockingQueue<String> queue = new ArrayBlockingQueue<String>(1024);
queue.put("1");
String string = queue.take();

在后面的文章中咱们已经讲过：BlockingQueue 常常被用于生产生产的缓冲队列。上面咱们就应用 ArrayBlockingQueue 来真正的实现一个生产生产的例子。

类 BlockingQueueExample 开启两个独立线程，一个是 Producer 生产者线程，负责向队列中增加数据；另一个是 Consumer 消费者线程，负责从队列中取出数据进行解决。

public class BlockingQueueExample {public static void main(String[] args) throws Exception {
        // 应用 ArrayBlockingQueue 初始化一个 BlockingQueue，指定容量的下限为 1024
        BlockingQueue queue = new ArrayBlockingQueue(1024);
        
        Producer producer = new Producer(queue);  // 生产者
        Consumer consumer = new Consumer(queue);  // 消费者

        new Thread(producer).start();  // 开启生产者线程
        new Thread(consumer).start();  // 开启消费者线程

        Thread.sleep(4000);
    }
}

类 Producer 为生产者，每隔 10 秒钟应用 put() 办法向队列中放入一个对象，放入三次。在这 10 秒的距离内，队列数据被消费者取走之后将导致消费者线程阻塞。

public class Producer implements Runnable{

    protected BlockingQueue queue = null;

    public Producer(BlockingQueue queue) {this.queue = queue;}

    public void run() {
        try {queue.put("1");
            Thread.sleep(10000);
            queue.put("2");
            Thread.sleep(10000);
            queue.put("3");
        } catch (InterruptedException e) {e.printStackTrace();
        }
    }
}

上面的代码是消费者类 Consumer，它从队列中获取待处理的元素对象，并调用System.out 将其打印进去。

public class Consumer implements Runnable{

    protected BlockingQueue queue = null;

    public Consumer(BlockingQueue queue) {this.queue = queue;}

    public void run() {
        try {System.out.println(queue.take());
            System.out.println(queue.take());
            System.out.println(queue.take());
        } catch (InterruptedException e) {e.printStackTrace();
        }
    }
}

下面的代码打印后果是每隔 10 秒打印一次，因为其中 take() 办法在队列内没有元素能够取到的时候，会阻塞以后的消费者线程，让其处于期待状态，这个办法咱们在上一节介绍 BlockingQueue 的时候就曾经进行过阐明。

本文转载注明出处（必须带连贯，不能只转文字）：字母哥博客 – zimug.com

感觉对您有帮忙的话，帮我点赞、分享！您的反对是我不竭的创作能源！。另外，笔者最近一段时间输入了如下的精品内容，期待您的关注。