脚本之家 服务器常用软件
快捷导航
您的位置：首页 → 软件编程 → java → java并发编程工具类ArrayBlockingQueue

java并发编程工具类JUC之ArrayBlockingQueue

 更新时间：2021年05月31日 15:45:34   作者：字母哥博客  
类ArrayBlockingQueue是BlockingQueue接口的实现类，它是有界的阻塞队列，内部使用数组存储队列元素，通过代码给大家说明如何初始化一个ArrayBlockingQueue，并向其中添加一个对象，对java并发编程工具类ArrayBlockingQueue相关知识感兴趣的朋友一起看看吧

Java BlockingQueue接口java.util.concurrent.BlockingQueue表示一个可以存取元素，并且线程安全的队列。换句话说，当多线程同时从 JavaBlockingQueue中插入元素、获取元素的时候，不会导致任何并发问题（元素被插入多次、处理多次等问题）。

从java BlockingQueue可以引申出一个概念：阻塞队列，是指队列本身可以阻塞线程向队列里面插入元素，或者阻塞线程从队列里面获取元素。比如：当一个线程尝试去从一个空队列里面获取元素的时候，这个线程将被阻塞直到队列内元素数量不再为空。当然，线程是否会被阻塞取决于你调用什么方法从BlockingQueue获取元素，有的方法会阻塞线程，有的方法会抛出异常等等，下文我们会详细介绍。

类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的时候就已经进行过说明。

以上就是java并发编程工具类JUC之ArrayBlockingQueue的详细内容，更多关于java并发编程工具类ArrayBlockingQueue的资料请关注脚本之家其它相关文章！

您可能感兴趣的文章:

相关文章

  • springboot+dubbo+validation 进行rpc参数校验的实现方法

    springboot+dubbo+validation 进行rpc参数校验的实现方法

    这篇文章主要介绍了springboot+dubbo+validation 进行rpc参数校验的实现方法，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
    2019-09-09
  • 将Dubbo服务打包成Jar包的操作步骤

    将Dubbo服务打包成Jar包的操作步骤

    Dubbo 是一款流行的 Java RPC 框架,它提供了高性能、透明化的 RPC 远程服务调用方案,在开发基于 Dubbo 的服务时,我们通常需要将服务代码打包成可发布的 JAR 包,本文将详细介绍如何将 Dubbo 服务打包成 JAR 包,并提供相应的配置和步骤,需要的朋友可以参考下
    2024-12-12
  • Java调用ChatGPT的实现代码

    Java调用ChatGPT的实现代码

    这篇文章主要介绍了Java调用ChatGPT的实现代码,本文通过实例代码给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下
    2023-02-02
  • 95%的Java程序员人都用不好Synchronized详解

    95%的Java程序员人都用不好Synchronized详解

    这篇文章主要为大家介绍了95%的Java程序员人都用不好Synchronized详解，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步，早日升职加薪
    2023-03-03
  • 基于Java HttpClient和Htmlparser实现网络爬虫代码

    基于Java HttpClient和Htmlparser实现网络爬虫代码

    这篇文章主要介绍了基于Java HttpClient和Htmlparser实现网络爬虫代码的相关资料,需要的朋友可以参考下
    2015-12-12
  • 解析Mybatis的insert方法返回数字-2147482646的解决

    解析Mybatis的insert方法返回数字-2147482646的解决

    这篇文章主要介绍了解析Mybatis的insert方法返回数字-2147482646的解决，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
    2021-04-04
  • SpringBoot集成POI实现Excel导入导出的示例详解

    SpringBoot集成POI实现Excel导入导出的示例详解

    Apache POI 是用Java编写的免费开源的跨平台的 Java API，Apache POI提供API给Java程序对Microsoft Office格式档案读和写的功能。本文主要介绍通过SpringBoot集成POI工具实现Excel的导入和导出功能，需要的可以参考一下
    2022-07-07
  • 猜数游戏java实现代码

    猜数游戏java实现代码

    这篇文章主要为大家详细介绍了java实现猜数游戏代码，文中示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下
    2020-12-12
  • Java中的内存分配图解

    Java中的内存分配图解

    这篇文章主要介绍了Java中的内存分配图解,Java 程序运行时，需要在内存中分配空间。为了提高运算效率，就对空间进行了不同区域的划分，因为每一片区域都有特定的处理数据方式和内存管理方式,需要的朋友可以参考下
    2023-08-08
  • java安全编码指南之:对象构建操作

    java安全编码指南之:对象构建操作

    这篇文章主要介绍了java安全编码指南之:对象构建操作，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧
    2020-09-09

最新评论