线程池的三种队列：SynchronousQueue、LinkedBlockingQueue 和ArrayBlockingQueue

男娘i 2022-11-20 09:53 170阅读 0赞

## 使用方法： ##

## SynchronousQueue ##

private static ExecutorService cachedThreadPool = new ThreadPoolExecutor(4, 
    Runtime.getRuntime().availableProcessors() * 2, 
    0, 
    TimeUnit.MILLISECONDS, 
    new SynchronousQueue<>(), 
    r -> new Thread(r, "ThreadTest"),
    new ThreadPoolExecutor.AbortPolicy());

参数分别为：  
1.corePoolSize：线程池中的常驻核心线程数

2.maximumPoolSize：线程池能够容纳同时执行的最大线程数，此值必须大于1，Runtime.getRuntime().availableProcessors() \* 2 这个意思是处理器核心数\*2

3.keepAliveTime：多余的空闲线程的存活时间，当空闲时间达到keepAliveTime值时，多余空闲线程会被销毁直到只剩下corePoolSize个线程为止。

4.unit：keepAliveTime的单位

5.workQueue：任务队列，被提交但尚未执行的任务

6.threadFactory：表示生成线程池中工作线程的线程工厂，用于创建线程一般用默认的即可

7.handIer：拒绝策略，表示当队列满了并且工作线程大于等于线程池的最大线程数(maximumPoolSize)

说明：

SynchronousQueue没有容量，是无缓存等待队列，是一个不存储元素的阻塞队列，会直接将任务交给消费者，必须等待队列中的添加元素被消费后才能继续添加新的元素。

拥有公平（FIFO）和非公平(LIFO)策略，非公平策略会导致一些数据永远无法被消费的情况

使用SynchronousQueue阻塞队列一般要求maximumPoolSizes为无界(Integer.MAX\_VALUE)，避免线程拒绝执行操作。

## LinkBlockingQueue ##

private static ExecutorService cachedThreadPool = new ThreadPoolExecutor(4,
    Runtime.getRuntime().availableProcessors() * 2, 
    0, 
    TimeUnit.MILLISECONDS, 
    new LinkedBlockingQueue<>(), 
    r -> new Thread(r, "ThreadTest"));

说明：

LinkedBlockingQueue是一个无界缓存等待队列。当前执行的线程数量达到corePoolSize的数量时，剩余的元素会在阻塞队列里等待。（所以在使用此阻塞队列时，maximumPoolSize就相当于无效了），每个线程完全独立于其他线程。生产者和消费者使用独立的锁来控制数据的同步，即在高并发的情况下可以并行操作队列中的数据。

注：

这个队列需要注意的是，虽然通常称其为一个无界队列，但是可以人为指定队列大小，而且由于其用于记录队列大小的参数是int类型字段，所以通常意义上的无界其实就是队列长度为Integer.MAX\_VALUE，且在不指定队列大小的情况下，也会默认队列大小为Integer.MAX\_VALUE，等同于如下：

private static ExecutorService cachedThreadPool = new ThreadPoolExecutor(4, 
    Runtime.getRuntime().availableProcessors() * 2, 
    0, 
    TimeUnit.MILLISECONDS, 
    new LinkedBlockingQueue<>(Integer.MAX_VALUE), 
    r -> new Thread(r, "ThreadTest"));

## ArrayBlockIngQueue ##

private static ExecutorService cachedThreadPool = new ThreadPoolExecutor(4, 
    Runtime.getRuntime().availableProcessors() * 2, 
    0, 
    TimeUnit.MILLISECONDS, 
    new ArrayBlockingQueue<>(32), 
    r -> new Thread(r, "ThreadTest"));

说明：

ArrayBlockingQueue是一个有界缓存等待队列，可以指定缓存队列的大小，当正在执行的线程数等于corePoolSize时，多余的元素缓存在ArrayBlockingQueue队列中等待有空闲的线程时继续执行，当ArrayBlockingQueue已满时，加入ArrayBlockingQueue失败，会开启新的线程去执行，当线程数达到最大的maximumPoolSize时，再有新的元素尝试加入ArrayBlockingQueue时会报错。