在阻塞队列中，有一种需要结合数组使用的阻塞队列，那就是ArrayBlockingQueue。在其并发控制上，插入和读写的功能又与锁的使用密切相关。先看我们就java中ArrayBlockingQueue的概念、特点进行介绍，然后带领大家在实例中体会ArrayBlockingQueue的使用方法。
1.概念
是java并发包下一个以数组实现的阻塞队列， 是 BlockingQueue 接口的有界队列实现类，底层采用数组来实现。
2.特点
初始化一定容量的数组；
使用一个重入锁，默认使用非公平锁，入队和出队共用一个锁，互斥；
是有界设计，如果容量满无法继续添加元素直至有元素被移除；
使用时开辟一段连续的内存，如果初始化容量过大容易造成资源浪费，过小易添加失败。
3.实例
package TestBlockingQueue;
import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.linkedBlockingDeque;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
public class ThreadPoolTest implements Runnable {
@Override
public void run() {
synchronized (this) {
System.out.println(Thread.currentThread().getName());
try {
Thread.sleep(3000);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
public static void main(String[] args) {
// BlockingQueue queue = new linkedBlockingDeque();
BlockingQueue queue = new ArrayBlockingQueue(5);
ThreadPoolExecutor executor = new ThreadPoolExecutor(3, 6, 1,
TimeUnit.DAYS, queue);
for (int i = 0; i < 12; i++) {
executor.execute(new Thread(new ThreadPoolTest(), "TestThread"
.concat("" + i)));
int threadSize = queue.size();
System.out.println("线程队列大小为-->" + threadSize);
}
executor.shutdown();
}
} 运行结果
以上就是java中ArrayBlockingQueue的使用，需要我们先掌握数组和锁的基本概念，然后才能结合在一起使用。对这些基本知识掌握不够牢固的，可以在课后进行复习回顾。
