java-ArrayBlockingQueue详解

在Java并发编程中,ArrayBlockingQueue是一个非常常用的工具类。它是一个由数组支持的有界阻塞队列,提供了线程安全的队列操作。

1.ArrayBlockingQueue概述

ArrayBlockingQueue是一个基于数组实现的阻塞队列,它继承自AbstractQueue并实现了BlockingQueue接口。这个队列在创建时需要指定一个固定的大小,之后这个大小就不能再改变了。当队列满时,如果再有新的元素试图加入队列,那么这个操作会被阻塞;同样地,如果队列为空,那么从队列中取元素的操作也会被阻塞。这种特性使得ArrayBlockingQueue非常适合作为生产者-消费者模式中的缓冲区。

2.ArrayBlockingQueue的核心特性

2.1.线程安全性

ArrayBlockingQueue是线程安全的,它通过内部锁机制保证了在多线程环境下的安全性。因此,在多线程环境中,你可以放心地使用它而不需要担心数据的一致性问题。

2.2.阻塞控制

ArrayBlockingQueue提供了阻塞控制机制。当队列满时,尝试向队列中添加元素的线程会被阻塞,直到队列中有空间可用;同样,当队列为空时,尝试从队列中取出元素的线程也会被阻塞,直到队列中有元素可供消费。这种机制可以有效地控制生产者和消费者的速度,避免资源的浪费。

2.3.有界性

ArrayBlockingQueue的有界性可以防止队列无限制地增长,从而避免内存溢出。在实际应用中,这种有界性可以作为系统的一个流量控制阀,当系统过载时,通过阻塞或拒绝请求来保护系统。

3.ArrayBlockingQueue的使用

3.1.创建ArrayBlockingQueue

创建一个ArrayBlockingQueue非常简单,只需要指定队列的大小即可:

int queueSize = 10;
BlockingQueue<Integer> queue = new ArrayBlockingQueue<>(queueSize);

3.2.生产者-消费者模式

ArrayBlockingQueue常用于生产者-消费者模式。生产者负责生成数据并添加到队列中,而消费者则从队列中取出数据并处理。下面是一个简单的生产者-消费者示例:

import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.BlockingQueue;public class ProducerConsumerExample {public static void main(String[] args) {BlockingQueue<Integer> queue = new ArrayBlockingQueue<>(5);Thread producer = new Thread(() -> {for (int i = 0; i < 10; i++) {try {System.out.println("生产者生产了数据:" + i);queue.put(i);Thread.sleep(200);} catch (InterruptedException e) {e.printStackTrace();}}});Thread consumer = new Thread(() -> {while (true) {try {Integer data = queue.take();System.out.println("消费者消费了数据:" + data);} catch (InterruptedException e) {e.printStackTrace();}}});producer.start();consumer.start();}
}

运行结果:

生产者生产了数据:0
消费者消费了数据:0
生产者生产了数据:1
消费者消费了数据:1
生产者生产了数据:2
消费者消费了数据:2
生产者生产了数据:3
消费者消费了数据:3
生产者生产了数据:4
消费者消费了数据:4
生产者生产了数据:5
消费者消费了数据:5
生产者生产了数据:6
消费者消费了数据:6
生产者生产了数据:7
消费者消费了数据:7
生产者生产了数据:8
消费者消费了数据:8
生产者生产了数据:9
消费者消费了数据:9

在这个示例中,我们创建了一个大小为5的ArrayBlockingQueue,然后启动了一个生产者线程和一个消费者线程。生产者线程会生成10个数据,并尝试将它们添加到队列中;消费者线程则会不断地从队列中取出数据并处理。由于队列的大小只有5,因此当生产者生产了5个数据后,它会被阻塞,直到消费者消费了一些数据释放出空间。同样地,当队列为空时,消费者线程也会被阻塞,直到生产者生产了新的数据。

4.ArrayBlockingQueue的最佳实践

4.1.选择合适的队列大小

队列的大小应根据具体的应用场景来设置。如果设置得太小,可能会导致频繁的阻塞和上下文切换,影响性能;如果设置得太大,可能会浪费内存资源。因此,在选择队列大小时,需要综合考虑系统的负载、内存资源和性能要求等因素。

4.2.合理使用阻塞方法

ArrayBlockingQueue提供了多种阻塞方法,如puttakeofferpoll等。在使用这些方法时,需要根据具体的需求来选择合适的方法。例如,如果你希望当队列满时生产者线程能够阻塞等待空间可用,那么可以使用put方法;如果你希望生产者线程在队列满时能够立即返回并做其他处理,那么可以使用offer方法。

4.3.避免死锁

在使用ArrayBlockingQueue时,需要注意避免死锁的发生。例如,不要在持有其他锁的情况下调用ArrayBlockingQueue的阻塞方法,否则可能会导致死锁。此外,还需要注意避免循环等待和饥饿等问题。

4.4.考虑使用公平策略

ArrayBlockingQueue的构造函数允许指定一个公平性参数。如果设置为true,等待时间最长的线程将优先获得访问队列的机会。但需要注意的是,公平性可能会降低性能。因此,在决定是否使用公平策略时,需要综合考虑系统的性能和公平性要求。

5.源码详解

5.1.主要属性

// 用于存储队列元素的数组
final Object[] items;// 队列的容量
int count;// 控制并发访问的锁
final ReentrantLock lock;// 队列不满时的等待条件
private final Condition notFull;// 队列不为空时的等待条件
private final Condition notEmpty;// 队列中等待取数据的线程数
final AtomicInteger waitingConsumers = new AtomicInteger();// 队列中等待插入数据的线程数
final AtomicInteger waitingProducers = new AtomicInteger();

5.2.构造函数

ArrayBlockingQueue 提供了几种构造函数,其中最基本的两个是接受队列容量和指定是否公平的构造函数。

public ArrayBlockingQueue(int capacity) {this(capacity, false);
}public ArrayBlockingQueue(int capacity, boolean fair) {if (capacity <= 0)throw new IllegalArgumentException();this.items = new Object[capacity];lock = new ReentrantLock(fair);notEmpty = lock.newCondition();notFull = lock.newCondition();
}

5.3.入队操作

put(E e)offer(E e) 是两种入队操作,其中 put 方法在队列满时会阻塞,而 offer 方法在队列满时会立即返回失败或者根据提供的超时时间等待。

public void put(E e) throws InterruptedException {checkNotNull(e);final ReentrantLock lock = this.lock;lock.lockInterruptibly();try {while (count == items.length)notFull.await();enqueue(e);} finally {lock.unlock();}
}public boolean offer(E e, long timeout, TimeUnit unit)throws InterruptedException {checkNotNull(e);long nanos = unit.toNanos(timeout);final ReentrantLock lock = this.lock;lock.lockInterruptibly();try {while (count == items.length) {if (nanos <= 0)return false;nanos = notFull.awaitNanos(nanos);}enqueue(e);return true;} finally {lock.unlock();}
}private void enqueue(E x) {// 队列尾部插入元素final Object[] items = this.items;items[putIndex] = x;if (++putIndex == items.length)putIndex = 0;count++;// 通知可能在等待的消费者线程notEmpty.signal();
}

5.4.出队操作

take()poll() 是两种出队操作,其中 take 方法在队列空时会阻塞,而 poll 方法在队列空时会立即返回 null 或者根据提供的超时时间等待。

public E take() throws InterruptedException {final ReentrantLock lock = this.lock;lock.lockInterruptibly();try {while (count == 0)notEmpty.await();return dequeue();} finally {lock.unlock();}
}public E poll(long timeout, TimeUnit unit) throws InterruptedException {long nanos = unit.toNanos(timeout);final ReentrantLock lock = this.lock;lock.lockInterruptibly();try {while (count == 0) {if (nanos <= 0)return null;nanos = notEmpty.awaitNanos(nanos);}return dequeue();} finally {lock.unlock();}
}private E dequeue() {// 队列头部取出元素final Object[] items = this.items;@SuppressWarnings("unchecked")E x = (E) items[takeIndex];items[takeIndex] = null;if (++takeIndex == items.length)takeIndex = 0;count--;if (itrs != null)itrs.elementDequeued();// 通知可能在等待的生产者线程notFull.signal();return x;
}

6.总结

ArrayBlockingQueue是Java并发编程中一个非常实用的工具类。它提供了线程安全的阻塞队列实现,支持生产者-消费者模式,并允许通过队列的大小来控制系统的流量。在使用ArrayBlockingQueue时,需要注意选择合适的队列大小、合理使用阻塞方法、避免死锁和考虑使用公平策略等问题。通过合理地使用ArrayBlockingQueue,可以有效地提高系统的并发性能和稳定性。

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/619858.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

一周速递|全球车联网产业动态(2024年1月14日)

政策法规 1、1月9日&#xff0c;国家发展改革委、商务部、市场监管总局发布《关于支持广州南沙放宽市场准入与加强监管体制改革的意见》&#xff0c;提出加快智能&#xff08;网联&#xff09;汽车多场景试点应用及商业化运营&#xff0c;推动电动垂直起降飞行器&#xff08;e…

对快速排序思想的进一步理解,分而治之,欧几里得算法(常用求最大公约数的方法)

自己找到的最优的快排的代码 快速排序 思想 分而治之使用欧几里得算法&#xff08;辗转相除法&#xff09;来求解一个应用题 假设有一块地&#xff0c;现在用这个同样大小的正方形来铺满&#xff0c;求所可用的最大的正方形地砖的面积 这两个方法放在一起是因为这个欧几里得要…

Linux环境之Ubuntu安装Docker流程

今天分享Linux环境之Ubuntu安装docker流程&#xff0c;Docker 是目前非常流行的容器&#xff0c;对其基本掌握很有必要。下面我们通过阿里云镜像的方式安装&#xff1a; 本来今天准备用清华大学镜像安装呢&#xff0c;好像有点问题&#xff0c;于是改成阿里云安装了。清华安装…

抓交通肇事犯(python)

问题描述&#xff1a; 一辆卡车违反交通规则&#xff0c;撞人后逃跑。现场有三人目击该事件&#xff0c;但都没有记住车号&#xff0c;只记下了车号的一些特征。甲说&#xff1a;牌照的前两位数字是相同的&#xff1b;乙说&#xff1a;牌照的后两位数字是相同的&#xff0c;但…

GVM垃圾收集器

Serial收集器&#xff08;新生代&#xff09; Serial&#xff08;串行&#xff09;收集器是最基本、历史最悠久的垃圾收集器&#xff0c;采用“标记-复制”算法负责新生代的垃圾收集。它是Hotspot虚拟机运行在客户端模式下的默认新生代收集器。 它是一个单线程收集器。它会使用…

软件测试学到这个程度,面试轻松拿下20K

很多人认为&#xff0c;软件测试是一个简单的职位&#xff0c;职业生涯走向也不会太好&#xff0c;但是随着时间的推移&#xff0c;软件测试行业的变化&#xff0c;人们开始对软件测试行业的认知有了新的高度&#xff0c;越来越多的人开始关注这个行业&#xff0c;开始重视这个…

v-if控制div内容显示,克隆这个div但是v-if没有效果

问题描述&#xff1a; 我的子页面打印的时候通过isPdf来隐藏“选择参加人员”按钮。 我子页面有个el-dialog&#xff0c;el-dialog里面有个大的div它的id为app-pre-meet-add&#xff0c;在子页面我通过isPdf来显示我想要的内容。现在我在父页面先通过this.$refs.child.control…

常用电容功能以及型号

电容在电子电路中具有多种重要作用&#xff0c;以下是其主要功能&#xff1a; 1. **隔直流、通交流**&#xff1a;电容器对直流电压有阻断作用&#xff08;理想情况下完全阻止直流通过&#xff09;&#xff0c;而对于交流信号则可以允许通过。这是因为电容器可以通过充放电过程…

分布式缓存

分布式缓存 缓存雪崩 缓存雪崩我们可以简单的理解为&#xff1a;由于原有缓存失效&#xff0c;新缓存未到期间所有原本应该访问缓存的请求都去查询数据库了&#xff0c;而对数据库 CPU 和内存造成巨大压力&#xff0c;严重的会造成数据库宕机。从而形成一系列连锁反应&#xf…

225.【2023年华为OD机试真题(C卷)】游戏分组(DFS深度优先搜索-JavaPythonC++JS实现)

🚀点击这里可直接跳转到本专栏,可查阅顶置最新的华为OD机试宝典~ 本专栏所有题目均包含优质解题思路,高质量解题代码(Java&Python&C++&JS分别实现),详细代码讲解,助你深入学习,深度掌握! 文章目录 一. 题目-游戏分组二.解题思路三.题解代码Python题解代码…

C++与Typescript的区别

目录 一、C类模板和函数模板 1.类模板 2.函数模板 二&#xff0c;Typescript 的泛型声明 1.泛型函数 2.泛型类 为什么C和Typescript语言中主张模板和泛型 一、C类模板和函数模板 在C中&#xff0c;类模板和函数模板允许你为多种数据类型编写通用的代码。这就像每个人都有…

uniapp如何封装接口

在uniapp中封装接口可以使用uni.request方法&#xff0c;示例代码如下&#xff1a; // 封装接口 export function getGoodsList(params) {return new Promise((resolve, reject) > {uni.request({url: http://api.example.com/goods,method: GET,data: params,success: res…

山西电力市场日前价格预测【2024-01-14】

日前价格预测 预测说明&#xff1a; 如上图所示&#xff0c;预测明日&#xff08;2024-01-14&#xff09;山西电力市场全天平均日前电价为415.13元/MWh。其中&#xff0c;最高日前电价为851.84元/MWh&#xff0c;预计出现在18:15。最低日前电价为198.87元/MWh&#xff0c;预计…

使用 C++/WinRT 创作 API

如果 API 位于 Windows 命名空间中 这是你使用 Windows 运行时 API 最常见的情况。 对于元数据中定义的 Windows 命名空间中的每个类型&#xff0c;C/WinRT 都定义了 C 友好等效项&#xff08;称为投影类型 &#xff09;。 投影类型具有与 Windows 类型相同的完全限定名称&…

【LabVIEW FPGA入门】使用CompactRIO进行SPI和I2C通信

NI提供了 SPI and I2C Driver API&#xff1a;下载SPI and I2C Driver API - NI 该API使用FPGA数字I / O线与SPI或I2C设备进行通信。 选择数字硬件时&#xff0c;要考虑三个选项&#xff1a; NI Single-Board RIO硬件可同时使用SPI和I2C驱动程序。NI 9401 C系列模块与SPI驱动程…

类中,构造方法、普通方法、类方法、静态方法和魔术方法的区别

class ExampleClass:class_variable "I am a class variable"# 构造方法&#xff08;Constructor&#xff09;def __init__(self, instance_variable):self.instance_variable instance_variable# 普通方法&#xff08;Method&#xff09;def instance_method(self…

大型语言模型,用最少的数学和行话进行解释

本文来自于《Large language models, explained with a minimum of math and jargon》&#xff0c;不嵌入任何笔者的个人理解&#xff0c;只是对原文的总结与记录。 文章作者是Tim Lee和Sean Trott&#xff0c;Tim Lee是一位拥有计算机科学硕士学位的记者&#xff0c;Sean Trot…

【二十】【动态规划】879. 盈利计划、377. 组合总和 Ⅳ、96. 不同的二叉搜索树 ,三道题目深度解析

动态规划 动态规划就像是解决问题的一种策略&#xff0c;它可以帮助我们更高效地找到问题的解决方案。这个策略的核心思想就是将问题分解为一系列的小问题&#xff0c;并将每个小问题的解保存起来。这样&#xff0c;当我们需要解决原始问题的时候&#xff0c;我们就可以直接利…

关于jupyter突然打不开的问题

好久没有用python了&#xff0c;我的电脑环境是安装过anaconda和pycharm&#xff0c;但是有些简单的东西就希望在jupyter中测试一下&#xff0c;但是最近发现jupyter打不开了。 具体是&#xff1a; 在这里打开jupyter是可以的&#xff0c;但是在命令行就不行&#xff0c;表现为…

计算机毕业设计 | SpringBoot+vue的家庭理财 财务管理系统(附源码)

1&#xff0c;绪论 1.1 项目背景 网络的发展已经过去了七十多年&#xff0c;网络技术的发展&#xff0c;将会影响到人类的方方面面&#xff0c;网络的出现让各行各业都得到了极大的发展&#xff0c;为整个社会带来了巨大的生机。 现在许多的产业都与因特网息息相关&#xff…