Java集合-ArrayBlockingQueue

特性

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

BlockingQueue：定义了队列的入队出队的方法
AbstractQueue：入队出队的基本操作

成员变量

组成：一个对象数组+1把锁ReentrantLock+2个条件Condition

// 使用数组存储元素
final Object[] items;
// 取元素的指针  记录下一次操作的位置
int takeIndex;
// 放元素的指针   记录下一次操作的位置
int putIndex;
// 元素数量
int count;
// 保证并发访问的锁
final ReentrantLock lock;
// 等待出队的条件 消费者监视器
private final Condition notEmpty;
// 等待入队的条件   生产者监视器
private final Condition notFull;

构造器

//必须传入容量，可以控制重入锁是公平还是非公平
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();
}
public ArrayBlockingQueue(int capacity, boolean fair, Collection<? extends E> c) {this(capacity, fair);// final修饰的变量不会发生指令重排final ReentrantLock lock = this.lock;// 保证可见性 不是为了互斥  防止指令重排 保证item的安全lock.lock(); try {int i = 0;try {for (E e : c) {checkNotNull(e);items[i++] = e;}} catch (ArrayIndexOutOfBoundsException ex) {throw new IllegalArgumentException();}count = i;putIndex = (i == capacity) ? 0 : i;} finally {lock.unlock();}
}