在阻塞队列中，有一种需要结合数组使用的阻塞队列，那就是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<Runnable> queue = new LinkedBlockingDeque<Runnable>();
        BlockingQueue<Runnable> queue = new ArrayBlockingQueue<Runnable>(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的使用，需要我们先掌握数组和锁的基本概念，然后才能结合在一起使用。对这些基本知识掌握不够牢固的，可以在课后进行复习回顾。