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的一些重要的方法。