品易云推流 关闭
文章详情页
文章 > java基础 > java ArrayBlockingQueue源码探讨

java ArrayBlockingQueue源码探讨

java ArrayBlockingQueue源码

头像

小妮浅浅

2021-01-11 13:46:572585浏览 · 0收藏 · 0评论

在我们学习了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的一些重要的方法。

关注

关注公众号,随时随地在线学习

本教程部分素材来源于网络,版权问题联系站长!

底部广告图