使用无界队列的线程池会不会引起内存急剧增长?

2026-05-29 10:284阅读0评论SEO资讯
  • 内容介绍
  • 文章标签
  • 相关推荐

本文共计488个文字,预计阅读时间需要2分钟。

使用无界队列的线程池会不会引起内存急剧增长?

Executors创建线程池的方式主要有以下几种:

1. Executors.newFixedThreadPool(10); // 使用LinkedBlockingQueue,无限制加入队列

2.Executors.newScheduledThreadPool(10); // 使用DelayedWorkQueue,队列满时阻塞

3.Executors.newSingleThreadScheduledExecutor(); // 单线程定时任务线程池

Executors创建线程池方式有如下几种:

Executors.newFixedThreadPool(10);//LinkedBlockingQueue 无限加入队列
Executors.newScheduledThreadPool(10);//DelayedWorkQueue 队列如果满了,阻塞
Executors.newSingleThreadScheduledExecutor();//DelayedWorkQueue 队列如果满了,阻塞
Executors.newCachedThreadPool();//SynchronousQueue 队列如果满了,抛异常
Executors.newSingleThreadExecutor();//LinkedBlockingQueue 无限加入队列

本文以Executors.newFixedThreadPool为例 定长线程池,核心线程数和最大线程数由用户传入,超出在队列等待,以下为相关源码。

//newFixedThreadPool创建线程池源码
public static ExecutorService newFixedThreadPool(int nThreads){
/**
* corePoolSize : 核心线程的数量为自定义输入nThreads

* maximumPoolSize : 最大线程的数量为自定义输入nThreads

* keepAliveTime : 0L

* unit : 秒

* workQueue : LinkedBlockingQueue
**/
return new ThreadPoolExecutor(nThreads, nThreads,
0L, TimeUnit.MILLISECONDS,
new LinkedBlockingQueue<Runnable>());
}

newFixedThreadPool和SingleThreadExecutor类似,唯一的区别就是核心线程数不同,并且由于使用的是LinkedBlockingQueue。LinkedBlockingQueue默认的最大任务数量是Integer.MAX_VALUE,非常大,可以理解为无限大吧;但是存在这种情况,当每个线程获取到一个任务后,执行时间比较长,导致workQueue里积压的任务越来越多,机器的内存使用不停的飙升,最后也会导致OOM。jdk7提供了7个阻塞队列,分别是:

ArrayBlockingQueue:一个由数组结构组成的有界阻塞队列 LinkedBlockingQueue:一个由链表结构组成的有界阻塞队列 PriorityBlockingQueue:一个支持优先级排序的无界阻塞队列 DelayQueue:一个使用优先级队列实现的无界阻塞队列 SynchronousQueue:一个不存储元素的阻塞队列 LinkedTransferQueue:一个由链表结构组成的无界阻塞队列 LinkedBlockingDueue:一个 由链表结构组成的双向阻塞队列

使用无界队列的线程池会不会引起内存急剧增长?

线程池工作原理图解:

本文共计488个文字,预计阅读时间需要2分钟。

使用无界队列的线程池会不会引起内存急剧增长?

Executors创建线程池的方式主要有以下几种:

1. Executors.newFixedThreadPool(10); // 使用LinkedBlockingQueue,无限制加入队列

2.Executors.newScheduledThreadPool(10); // 使用DelayedWorkQueue,队列满时阻塞

3.Executors.newSingleThreadScheduledExecutor(); // 单线程定时任务线程池

Executors创建线程池方式有如下几种:

Executors.newFixedThreadPool(10);//LinkedBlockingQueue 无限加入队列
Executors.newScheduledThreadPool(10);//DelayedWorkQueue 队列如果满了,阻塞
Executors.newSingleThreadScheduledExecutor();//DelayedWorkQueue 队列如果满了,阻塞
Executors.newCachedThreadPool();//SynchronousQueue 队列如果满了,抛异常
Executors.newSingleThreadExecutor();//LinkedBlockingQueue 无限加入队列

本文以Executors.newFixedThreadPool为例 定长线程池,核心线程数和最大线程数由用户传入,超出在队列等待,以下为相关源码。

//newFixedThreadPool创建线程池源码
public static ExecutorService newFixedThreadPool(int nThreads){
/**
* corePoolSize : 核心线程的数量为自定义输入nThreads

* maximumPoolSize : 最大线程的数量为自定义输入nThreads

* keepAliveTime : 0L

* unit : 秒

* workQueue : LinkedBlockingQueue
**/
return new ThreadPoolExecutor(nThreads, nThreads,
0L, TimeUnit.MILLISECONDS,
new LinkedBlockingQueue<Runnable>());
}

newFixedThreadPool和SingleThreadExecutor类似,唯一的区别就是核心线程数不同,并且由于使用的是LinkedBlockingQueue。LinkedBlockingQueue默认的最大任务数量是Integer.MAX_VALUE,非常大,可以理解为无限大吧;但是存在这种情况,当每个线程获取到一个任务后,执行时间比较长,导致workQueue里积压的任务越来越多,机器的内存使用不停的飙升,最后也会导致OOM。jdk7提供了7个阻塞队列,分别是:

ArrayBlockingQueue:一个由数组结构组成的有界阻塞队列 LinkedBlockingQueue:一个由链表结构组成的有界阻塞队列 PriorityBlockingQueue:一个支持优先级排序的无界阻塞队列 DelayQueue:一个使用优先级队列实现的无界阻塞队列 SynchronousQueue:一个不存储元素的阻塞队列 LinkedTransferQueue:一个由链表结构组成的无界阻塞队列 LinkedBlockingDueue:一个 由链表结构组成的双向阻塞队列

使用无界队列的线程池会不会引起内存急剧增长?

线程池工作原理图解: