技术文章 > java >  java基础 > 正文

java ArrayBlockingQueue源码探讨

小妮浅浅

在我们学习了ArrayBlockingQueue的基本内容后,需要进一步的对其源码进行探索,找出其中的一些方法,以及对用法的原理上有更深刻的理解。下面我们就ArrayBlockingQueue类的定义进行解析,找寻其参数、构造方法、同步机制的概念,进一步在其中分析源码。

1. 类的定义

public class ArrayBlockingQueue<E> extends AbstractQueue<E>
        implements BlockingQueue<E>, java.io.Serializable

类的定义中可以看出

ArrayBlockingQueue是一个泛型类

ArrayBlockingQueue继承了AbstractQueue类,AbstractQueue是一个抽象类(模板方法)

ArrayBlockingQueue实现了BlockingQueue接口,表示一个阻塞队列

ArrayBlockingQueue实现了java.io.Serializable,表示支持序列化

2.参数

/** 队列中存放的值 */
    final Object[] items;
 
    /** 值的索引,这是取出位置的索引*/
    int takeIndex;
 
    /** 值的索引,这是插入位置的索引*/
    int putIndex;
 
    /** 队列中有多少个元素 */
    int count;

3.构造方法

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();
}

通过构造方法我们可以得出以下两个结论:

1)ArrayBlockingQueue初始化时必须传入容量,也就是数组的大小;

(2)可以通过构造方法控制重入锁的类型是公平锁还是非公平锁。

4.同步机制

以上就是关于java ArrayBlockingQueue源码的探讨,相信现在对于 ArrayBlockingQueue的使用和理解上都没有太多的问题。在接下来的文章中,会不断带来ArrayBlockingQueue的一些重要的方法。

免费视频教程
本文原创发布python学习网,转载请注明出处,感谢您的尊重!
相关文章
 java线程池的运行流程
 java线程池创建方式
 java线程池异常的处理方法
 java线程池的工作队列有哪几个
 BlockingQueue在java中的使用
 java中ArrayBlockingQueue的使用
相关视频章节
 网络爬虫
 云端部署Web应用程序视频
 Web应用框架Flask和文件模板
 Web应用程序开发概述
 继承和多态
作者信息
推荐视频
视频教程分类