java中ArrayBlockingQueue的使用

在阻塞队列中，有一种需要结合数组使用的阻塞队列，那就是ArrayBlockingQueue。在其并发控制上，插入和读写的功能又与锁的使用密切相关。先看我们就java中ArrayBlockingQueue的概念、特点进行介绍，然后带领大家在实例中体会ArrayBlockingQueue的使用方法。

1.概念

是java并发包下一个以数组实现的阻塞队列， 是 BlockingQueue 接口的有界队列实现类，底层采用数组来实现。

2.特点

初始化一定容量的数组；

使用一个重入锁，默认使用非公平锁，入队和出队共用一个锁，互斥；

是有界设计，如果容量满无法继续添加元素直至有元素被移除；

使用时开辟一段连续的内存，如果初始化容量过大容易造成资源浪费，过小易添加失败。

3.实例

packageTestBlockingQueue;

importjava.util.concurrent.ArrayBlockingQueue;
importjava.util.concurrent.BlockingQueue;
importjava.util.concurrent.LinkedBlockingDeque;
importjava.util.concurrent.ThreadPoolExecutor;
importjava.util.concurrent.TimeUnit;

publicclassThreadPoolTestimplementsRunnable{

@Override
publicvoidrun(){
synchronized(this){
System.out.println(Thread.currentThread().getName());
try{
Thread.sleep(3000);
}catch(InterruptedExceptione){
e.printStackTrace();
}
}
}

publicstaticvoidmain(String[]args){
//BlockingQueue<Runnable>queue=newLinkedBlockingDeque<Runnable>();
BlockingQueue<Runnable>queue=newArrayBlockingQueue<Runnable>(5);
ThreadPoolExecutorexecutor=newThreadPoolExecutor(3,6,1,
TimeUnit.DAYS,queue);
for(inti=0;i<12;i++){
executor.execute(newThread(newThreadPoolTest(),"TestThread"
.concat(""+i)));
intthreadSize=queue.size();
System.out.println("线程队列大小为-->"+threadSize);
}
executor.shutdown();
}
}

运行结果

原文来自：https://www.py.cn