返回顶部
首页 > 资讯 > 精选 >BlockingQueue接口及ArrayBlockingQueue实现类的方法
  • 279
分享到

BlockingQueue接口及ArrayBlockingQueue实现类的方法

2023-06-27 10:06:11 279人浏览 安东尼
摘要

这篇文章主要介绍“BlockingQueue接口及ArrayBlockingQueue实现类的方法”的相关知识,小编通过实际案例向大家展示操作过程,操作方法简单快捷,实用性强,希望这篇“BlockingQueue接口及ArrayBlocki

这篇文章主要介绍“BlockingQueue接口及ArrayBlockingQueue实现类的方法”的相关知识,小编通过实际案例向大家展示操作过程,操作方法简单快捷,实用性强,希望这篇“BlockingQueue接口及ArrayBlockingQueue实现类的方法”文章能帮助大家解决问题。

队列是一种 FIFO(先进先出)的数据结构,本文要讲的 BlockingQueue 也是一种队列,而且强调了线程安全的特性。

BlockingQueue全称:java.util.concurrent.BlockingQueue。它是是一个线程安全的队列接口,多个线程能够以并发的方式从队列中插入数据,取出数据的同时不会出现线程安全的问题。

生产者和消费者例子

BlockingQueue 通常用于消费者线程向队列存入数据,消费者线程从队列中取出数据,具体如下

  1. 生产者线程不停的向队列中插入数据,直到队列满了,生产者线程被阻塞

  2. 消费者线程不停的从队列中取出数据,直到队列为空,消费者线程被阻塞

(推荐教程:Java教程)

BlockingQueue 方法

BlockingQueue 提供 4 种不同类型的方法用于插入数,取出数据以及检查数据,具体如下

  1. 操作失败,抛出异常

  2. 无论成功/失败,立即返回 true/false

  3. 如果队列为空/满,阻塞当前线程

  4. 如果队列为空/满,阻塞当前线程并有超时机制插入add(o) offer(o) put(o) offer(o, timeout, timeunit)取出remove(o) poll() take() poll(timeout, timeunit)检查element() peek()

BlockingQueue 的具体实现类

BlockingQueue 只是一个接口,在实际开发中有如下的类实现了该接口。

  1. ArrayBlockingQueue

  2. DelayQueue

  3. LinkedBlockingQueue

  4. PriorityBlockingQueue

  5. SynchronousQueue

ArrayBlockingQueue 的使用

这里以 BlockingQueue 接口的具体实现类 ArrayBlockingQueue 举例。通过 ArrayBlockingQueue实现一个消费者和生产者多线程模型。

核心内容如下:

  1. ArrayBlockingQueue 作为生产者和消费者的数据容器

  2. 通过 ExecutorService 启动 3 个线程,2 两个生产者,1 个消费者

  3. 指定数据总量

生产者线程

ArrayBlockingQueueProducer

import org.slf4j.Logger;import org.slf4j.LoggerFactory;import java.util.concurrent.ArrayBlockingQueue;import java.util.concurrent.atomic.AtomicInteger;public class ArrayBlockingQueueProducer implements Runnable {    private static final Logger logger = LoggerFactory.getLogger(ArrayBlockingQueueProducer.class);    // 容器    private ArrayBlockingQueue<String> queue;    // 生产指定的数量    private AtomicInteger numberOfElementsToProduce;    public ArrayBlockingQueueProducer(ArrayBlockingQueue<String> queue, AtomicInteger numberOfElementsToProduce) {        this.queue = queue;        this.numberOfElementsToProduce = numberOfElementsToProduce;    }    @Override    public void run() {        try {            while (numberOfElementsToProduce.get() > 0) {                try {                    // 向队列中存入任务                    String task = String.fORMat("task_%s", numberOfElementsToProduce.getAndUpdate(x -> x-1));                    queue.put(task);                    logger.info("thread {}, produce task {}", Thread.currentThread().getName(), task);                    // 任务为0,生产者线程退出                    if (numberOfElementsToProduce.get() == 0) {                        break;                    }                } catch (Exception e) {                    e.printStackTrace();                }            }        } catch (Exception e) {            logger.error(this.getClass().getName().concat(". has error"), e);        }    }}

消费者线程

ArrayBlockingQueueConsumer

import org.slf4j.Logger;import org.slf4j.LoggerFactory;import java.util.concurrent.ArrayBlockingQueue;import java.util.concurrent.atomic.AtomicInteger;public class ArrayBlockingQueueConsumer implements Runnable {    private static final Logger logger = LoggerFactory.getLogger(ArrayBlockingQueueConsumer.class);    private ArrayBlockingQueue<String> queue;    private AtomicInteger numberOfElementsToProduce;    public ArrayBlockingQueueConsumer(ArrayBlockingQueue<String> queue, AtomicInteger numberOfElementsToProduce) {        this.queue = queue;        this.numberOfElementsToProduce = numberOfElementsToProduce;    }    @Override    public void run() {        try {            while (!queue.isEmpty() || numberOfElementsToProduce.get() >= 0) {                // 从队列中获取任务,并执行任务                String task = queue.take();                logger.info("thread {} consume task {}", Thread.currentThread().getName(),task);                // 队列中数据为空,消费者线程退出                if (queue.isEmpty()) {                    break;                }            }        } catch (Exception e) {            logger.error(this.getClass().getName().concat(". has error"), e);        }    }}

测试TestBlockingQueue

import com.ckjava.synchronizeds.appCache.WaitUtils;import java.util.concurrent.ArrayBlockingQueue;import java.util.concurrent.ExecutorService;import java.util.concurrent.Executors;import java.util.concurrent.atomic.AtomicInteger;public class TestBlockingQueue {    public static void main(String[] args) {        ArrayBlockingQueue<String> arrayBlockingQueue = new ArrayBlockingQueue<>(10);                ExecutorService executorService = Executors.newFixedThreadPool(3);        // 最多生产 5 个数据        AtomicInteger numberOfElementsToProduce = new AtomicInteger(5);        // 2 个生产者线程        executorService.submit(new ArrayBlockingQueueProducer(arrayBlockingQueue, numberOfElementsToProduce));        executorService.submit(new ArrayBlockingQueueProducer(arrayBlockingQueue, numberOfElementsToProduce));        // 1 个消费者线程        executorService.submit(new ArrayBlockingQueueConsumer(arrayBlockingQueue, numberOfElementsToProduce));        executorService.shutdown();        WaitUtils.waitUntil(() -> executorService.isTerminated(), 1000L);    }}

输出如下:

13:54:17.884 [pool-1-thread-3] INFO  c.c.b.ArrayBlockingQueueConsumer - thread pool-1-thread-3 consume task task_513:54:17.884 [pool-1-thread-1] INFO  c.c.b.ArrayBlockingQueueProducer - thread pool-1-thread-1, produce task task_513:54:17.884 [pool-1-thread-2] INFO  c.c.b.ArrayBlockingQueueProducer - thread pool-1-thread-2, produce task task_413:54:17.887 [pool-1-thread-3] INFO  c.c.b.ArrayBlockingQueueConsumer - thread pool-1-thread-3 consume task task_413:54:17.887 [pool-1-thread-2] INFO  c.c.b.ArrayBlockingQueueProducer - thread pool-1-thread-2, produce task task_213:54:17.887 [pool-1-thread-1] INFO  c.c.b.ArrayBlockingQueueProducer - thread pool-1-thread-1, produce task task_313:54:17.887 [pool-1-thread-3] INFO  c.c.b.ArrayBlockingQueueConsumer - thread pool-1-thread-3 consume task task_313:54:17.887 [pool-1-thread-2] INFO  c.c.b.ArrayBlockingQueueProducer - thread pool-1-thread-2, produce task task_113:54:17.887 [pool-1-thread-3] INFO  c.c.b.ArrayBlockingQueueConsumer - thread pool-1-thread-3 consume task task_213:54:17.887 [pool-1-thread-3] INFO  c.c.b.ArrayBlockingQueueConsumer - thread pool-1-thread-3 consume task task_1

关于“BlockingQueue接口及ArrayBlockingQueue实现类的方法”的内容就介绍到这里了,感谢大家的阅读。如果想了解更多行业相关的知识,可以关注编程网精选频道,小编每天都会为大家更新不同的知识点。

--结束END--

本文标题: BlockingQueue接口及ArrayBlockingQueue实现类的方法

本文链接: https://www.lsjlt.com/news/309898.html(转载时请注明来源链接)

有问题或投稿请发送至: 邮箱/279061341@qq.com    QQ/279061341

猜你喜欢
  • BlockingQueue接口及ArrayBlockingQueue实现类的方法
    这篇文章主要介绍“BlockingQueue接口及ArrayBlockingQueue实现类的方法”的相关知识,小编通过实际案例向大家展示操作过程,操作方法简单快捷,实用性强,希望这篇“BlockingQueue接口及ArrayBlocki...
    99+
    2023-06-27
  • ReadWriteLock接口及其实现ReentrantReadWriteLock方法
    Java并发包的locks包里的锁基本上已经介绍得差不多了,ReentrantLock重入锁是个关键,在清楚的了解了同步器AQS的运行机制后,实际上再分析这些锁就会显得容易得多,这章节主讲另外一个重要的锁——ReentrantReadWri...
    99+
    2023-05-31
    reentrantreadwritelock 接口 readwritelock
  • PHP调用API接口的方法及实现
    随着互联网、云计算和大数据时代的到来,越来越多的应用程序需要调用第三方的API接口来获取数据,实现数据互通和协同工作。PHP作为一种常用的服务器端语言,也可以通过调用API接口来实现不同系统的数据交互和整合。本文将介绍PHP调用API接口的...
    99+
    2023-10-10
    数据挖掘 网络爬虫 前端 服务器 git
  • java集合collection接口与子接口及实现类
    目录概要1 Collection接口的实现子类特性2 通过实现子类ArrayList体现Collection接口方法2.1 代码演示示例3 集合的遍历:①使用Iterator(迭代器...
    99+
    2024-04-02
  • JavaSet接口及常用实现类总结
    目录前言概述Set 无序性与不可重复性的理解无序性不可重复性Set 接口常用实现类HashSetLinkedHashSetTreeSet前言 Collection的另一个子接口就是S...
    99+
    2023-01-06
    Java Set接口 Java Set接口常用方法 Java Set
  • java中抽象类、抽象方法、接口与实现接口实例详解
    前言对于java中的抽象类,抽象方法,接口,实现接口等具体的概念就不在这里详细的说明了,网上书本都有很多解释,主要是我懒,下面通过一个例子来说明其中的精髓要点,能不能练成绝世武功,踏上封王之路,就看自己的的啦(不要误会,我指的只是我自己啦啦...
    99+
    2023-05-30
    java 抽象类 接口
  • C#接口的概念以及实现方式
    这篇文章主要讲解了“C#接口的概念以及实现方式”,文中的讲解内容简单清晰,易于学习与理解,下面请大家跟着小编的思路慢慢深入,一起来研究和学习“C#接口的概念以及实现方式”吧!C#接口是什么呢?C#接口(interface)用来定义一种程序的...
    99+
    2023-06-17
  • 使用Netty实现类似Dubbo的远程接口调用的实现方法
    目录一、Netty简介二、完整代码实现1、创建接口和实现类2、客户端代码实现及动态代理和异步转同步3、服务端代码实现4、自定义编码解码器5、编写测试客户端发送请求代码一、Netty简...
    99+
    2023-05-17
    Netty Dubbo远程接口调用 Netty Dubbo远程调用
  • spring注解识别一个接口的多个实现类方法
    1.比如有一个接口如下:public interface Filter { public String doFilter(String param); }...
    99+
    2023-05-31
    spring 注解 接口
  • Golang接口实现的方法是什么
    这篇文章主要介绍“Golang接口实现的方法是什么”的相关知识,小编通过实际案例向大家展示操作过程,操作方法简单快捷,实用性强,希望这篇“Golang接口实现的方法是什么”文章能帮助大家解决问题。Golang 接口是什么和C++、Java等...
    99+
    2023-07-05
  • Java集合之Set接口及其实现类精解
    目录Set接口概述HashSet实现类1、HashSet 具有以下特点: 2、HashSet 集合判断两个元素相等的标准3、向HashSet中添加元素的过程LinkedHashSet...
    99+
    2024-04-02
  • Java多线程Queue、BlockingQueue和使用BlockingQueue实现生产消费者模型方法解析
    Queue是什么队列,是一种数据结构。除了优先级队列和LIFO队列外,队列都是以FIFO(先进先出)的方式对各个元素进行排序的。无论使用哪种排序方式,队列的头都是调用remove()或poll()移除元素的。在FIFO队列中,所有新元素都插...
    99+
    2023-05-30
    java 多线程 生产消费者
  • Golang接口实现方式及示例分析
    Golang是一种静态类型、编译型语言,最初由Google设计和开发,在处理大规模项目时表现出色。Golang中的接口是一种重要的概念,它允许类型之间的互操作性,并支持多态。 Gola...
    99+
    2024-03-06
    接口 golang 示例
  • node+koa实现数据mock接口的方法
    基于node+koa实现的mock数据接口,Koa需要v7.6.0以上node版本,低于此版本请先升级node 目录结构 // server.js const Koa = require('koa'...
    99+
    2022-06-04
    接口 方法 数据
  • Net Framework接口的实现方法有哪些
    Net Framework接口的实现方法有哪些,相信很多没有经验的人对此束手无策,为此本文总结了问题出现的原因和解决方法,通过这篇文章希望你能解决这个问题。.Net Framework可以我们提供一个部署WEB应用程序的平台。它的出现就是为...
    99+
    2023-06-17
  • PHP实现短信接口的调用方法
    随着科技的不断发展,短信服务在现代社会中被广泛地应用,如何实现自己的短信接口调用也成为了一项重要的技能。其中,使用PHP实现短信接口的调用方法简单易懂、效率高,本文将为大家介绍一下具体的实现步骤。实现短信接口的注册首先,需要选择一个合适的短...
    99+
    2023-05-22
    PHP 调用方法 短信接口
  • 在 Go 中使用泛型类型结构实现接口方法
    问题内容 我想要一个接口,它可以将任何类型的参数传递给它的单个方法,并且我想要一个带有泛型的单个实现结构。 这是我的问题的超级简化版本: package main type MyIn...
    99+
    2024-02-06
    overflow
  • Java List接口与Iterator接口及foreach循环使用的方法
    这篇文章主要介绍“Java List接口与Iterator接口及foreach循环使用的方法”的相关知识,小编通过实际案例向大家展示操作过程,操作方法简单快捷,实用性强,希望这篇“Java List接口与Iterator...
    99+
    2023-06-30
  • Java中的List接口实现类解析
    目录Java的List接口实现类实现类ArrayList实现类LinkedList实现类VectorList三个实现类Java的List接口实现类 实现类ArrayList Arra...
    99+
    2024-04-02
  • 怎么在TypeScript中实现接口的类
    这篇文章主要介绍“怎么在TypeScript中实现接口的类”,在日常操作中,相信很多人在怎么在TypeScript中实现接口的类问题上存在疑惑,小编查阅了各式资料,整理出简单好用的操作方法,希望对大家解答”怎么在TypeScript中实现接...
    99+
    2023-07-05
软考高级职称资格查询
编程网,编程工程师的家园,是目前国内优秀的开源技术社区之一,形成了由开源软件库、代码分享、资讯、协作翻译、讨论区和博客等几大频道内容,为IT开发者提供了一个发现、使用、并交流开源技术的平台。
  • 官方手机版

  • 微信公众号

  • 商务合作