程序地带

数组阻塞队列(ArrayBlockingQueue)源码解读与分析


生产者消费者模式最核心的部分是生产者与消费者之间的特殊容器,而阻塞队列是特殊容器最常见的实现。JDK中定义了阻塞队列接口BlockingQueue,JDK通过该接口为我们提供了很多种阻塞队列的实现,其中包括本节的主角ArrayBlockingQueue,该类位于java.util.concurrent.ArrayBlockingQueue.java。该类需要实现的核心方法如下,下面我们详细分析ArrayBlockingQueue的实现原理。 在这里插入图片描述


从名字可以看出它的存储结构就是一个数组,即基于数组实现了一个FIFO的阻塞队列。新元素都插入到队列尾部,于是最先进入的元素在队列头而最后进入的元素在队列尾部。该数组是有界的,所以构造时需要制定数组的大小。此外,该阻塞队列还提供公平和非公平两种模式。


在这里插入图片描述


在分析 ArrayBlockingQueue的实现原理之前我们先通过几个例子来了解它的使用。例子一中我们创建了一个 ArrayBlockingQueue对象,然后通过五个线程去生产数据并put到阻塞队列,二主线程则充当消费端,不断将阻塞队列中的数据取出消费。程序输出如下: 在这里插入图片描述


主要展示了阻塞队列空间满了产生阻塞,我们创建一个最大长度为4的阻塞队列,然后通过五个线程分别产生一个数据put到阻塞队列中,但由于阻塞队列最大长度为4,所以在put四个数据后会产生阻塞。


在这里插入图片描述


主要展示了阻塞队列为空时产生阻塞,我们创建一个最大长度为10的阻塞队列,然后没有生产者产生数据,却又一个消费者调用take消费数据。由于阻塞队列为空,所以产生了阻塞。 在这里插入图片描述


我们先看 ArrayBlockingQueue类的属性和构造函数。其中count变量表示队列的长度大小,takeIndex和putIndex分别表示队列入队和出队的索引,items是一个Object数组用于保存队列的元素,lock是并发控制锁,notEmpty和notFull分别表示队列非空时和非满时的条件。提供两个构造函数,我们在创建时指定队列的大小,另外一个是公平模式参数,默认是非公平的。锁对象使用的是ReentrantLock对象,公平机制也使用的是它的,它的公平机制我们在前面的章节中已经深入分析过了。notEmpty和notFull条件对象通过锁对象的newCondition创建。


在这里插入图片描述


put和take方法是阻塞队列的入队和出队方法,它们会间接调用enqueue和dequeue方法。其中put方法会检查入队的元素不能为null,需要先获取锁后才执行enqueue方法维护数组,如果数组长度已经达到最大长度则调用notFull条件的await方法等待。take方法会先获取锁后才执行dequeue方法维护数组,如果数组长度为0则调用notEmpty条件的await方法等待。


在这里插入图片描述


offer和poll方法则是支持超时的阻塞队列的入队和出java基础队方法,可以看到主要的区别就在于它们分别调用了notFull和notEmpty条件的awaitNanos方法进行等待。入队时如果超过指定的超时时间则会返回false,表示入队超时导致失败。而出队时如果超过指定的超时时间则会返回null,表示出队超时导致失败。 在这里插入图片描述


围绕着JDK中BlockingQueue的其中一种实现,即ArrayBlockingQueue。它的基本结构是使用数组来保存阻塞队列的元素,数组的长度有限制,并且提供了公平和非公平模式。对它的实现原理进行分析,为了方便我们仅保留了ArrayBlockingQueue最核心的源码,只有我们能理解透彻这些内容就已经能掌握它的实现原理了。推荐阅读


EOF


作  者:码农架构 出  处:https://www.cnblogs.com/ibytecoding/p/14280866.html 关于博主:目前任职蚂蚁金服,「公众号:码农架构」专注于系统架构、高可用、高性能、


版权声明:本文为博主原创文章,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接和本声明。
本文链接:https://blog.csdn.net/chinaherolts2008/article/details/112689207

随机推荐

poroto3 坑 枚举_protobuf3笔记

Protobuf3笔记文件后缀定义Proto的文件应以.proto为后缀。语法版本Proto文件的首行应指定语法版本:syntax="proto3";//"...

weixin_39625872 阅读(218)

poroto3 坑 枚举_proto3默认值与可选项

proto3默认值与可选项背景介绍目前开发的产品架构采用微服务架构,微服务之间通信的消息格式则使用的proto3标准协议格式。proto介绍全称ProtocolBuffers(下面简称P...

weixin_39746794 阅读(520)

Tensorflow2.0学习笔记-RNN字母预测

字母预测循环计算过程单个字符输出abcde作为一个循环,根据输入的一个字母预测出下一个字母,例如a->b,e->a…,把abcde设...

波波秀 阅读(332)

poroto3 坑 枚举_gRPC学习记录(三)--proto3知识

在上一篇中,得知proto文件是定义服务端和客户端通讯接口的标准,说白了就是客户端该传什么样的参数,服务端该返回什么样子的参数,客户端该怎么调用,是阻塞还是非阻塞,是同步还是异步,那么就需要对这个东西...

weixin_39877504 阅读(716)

单件类的安全实现

不安全的实现方法std::unique_ptr<Interface>instance_(nullptr);~Interface(){if(file_.isOpened()){file_.r...

瞻邈 阅读(463)