ThreadPoolExecutor构造参数以及执行流程

简介: ThreadPoolExecutor构造参数以及执行流程

ThreadPoolExecutor 构造参数

ThreadPoolExecutor 是 Java 中 java.util.concurrent 包提供的一个强大的线程池实现。它提供了多种构造方法,但最常用的构造函数如下:

ThreadPoolExecutor(
    int corePoolSize,
    int maximumPoolSize,
    long keepAliveTime,
    TimeUnit unit,
    BlockingQueue<Runnable> workQueue,
    ThreadFactory threadFactory,
    RejectedExecutionHandler handler
)

下面是每个参数的详细说明:

  • 「corePoolSize」: 核心线程数 —— 线程池中始终保持的线程数,即使它们处于空闲状态。除非设置了 allowCoreThreadTimeOut,否则它们不会因为闲置超时而被回收。
  • 「maximumPoolSize」: 最大线程数 —— 线程池中允许的最大线程数。当工作队列满了之后,线程池会创建新线程,直到达到这个最大值。
  • 「keepAliveTime」: 空闲线程的存活时间 —— 当线程数超过核心线程数时,这是超过核心线程数的线程在空闲时要等待新任务的最长时间。
  • 「unit」: keepAliveTime 的时间单位 —— TimeUnit 是一个枚举,提供了时间单位,如 TimeUnit.SECONDS
  • 「workQueue」: 工作队列 —— 用于在执行任务之前保存任务的队列。这个队列将仅保存由 execute 方法提交的 Runnable 任务。
  • 「threadFactory」: 线程工厂 —— 用于创建新线程的工厂。使用自定义 ThreadFactory 可以自定义线程的名称、优先级、守护进程状态等。
  • 「handler」: 拒绝策略 —— 当线程池和工作队列都满了时,定义任务的拒绝策略。例如,ThreadPoolExecutor.AbortPolicy 是一个拒绝策略,它将抛出 RejectedExecutionException

ThreadPoolExecutor 执行流程

线程池的工作流程大致如下:

  1. 「新任务提交」: 当一个新任务被提交到线程池时,线程池会根据当前线程数量和工作队列状态采取以下行动之一:
  • 如果当前运行的线程数少于 corePoolSize,则创建并启动一个新线程来处理任务,即使其他工作线程处于空闲状态。
  • 如果运行的线程数等于或大于 corePoolSize,则将任务添加到工作队列。
  • 如果工作队列已满,且运行的线程数少于 maximumPoolSize,则创建并启动一个新线程来处理任务。
  • 如果工作队列已满,且运行的线程数等于 maximumPoolSize,则根据拒绝策略处理无法执行的任务。
  1. 「任务执行」: 线程池中的线程会从工作队列中取出任务并执行它们。一旦线程完成了任务,它会再次从队列中获取下一个任务(如果有的话)。
  2. 「线程终止」: 当一个线程没有任务执行,并且超过了 keepAliveTime,如果当前运行的线程数超过 corePoolSize,这个线程将被终止,以减少资源消耗。
  3. 「线程池关闭」: 当我们调用 shutdown() 方法时,线程池将不再接受新任务,但会继续处理工作队列中的所有剩余任务。调用 shutdownNow() 方法将尝试停止所有正在执行的任务,并停止处理工作队列中的任务。

通过合理配置这些参数,可以创建一个既能够处理动态变化的负载,又能够有效管理系统资源的线程池。

相关文章
|
2天前
|
Dubbo 安全 Java
ThreadPoolExecutor线程池参数及其设置规则
ThreadPoolExecutor线程池参数及其设置规则
17 1
|
2天前
|
Java
Java线程池ThreadPoolExcutor源码解读详解01-参数说明
`ThreadPoolExecutor`是Java中用于创建线程池的类,其构造函数包含核心线程数`corePoolSize`、最大线程数`maximumPoolSize`、空闲线程存活时间`keepAliveTime`、时间单位`unit`、工作队列`workQueue`、线程工厂`threadFactory`和拒绝策略`handler`等参数。`corePoolSize`是始终保持的线程数,除非设置`allowCoreThreadTimeOut`。当线程数超过核心线程数时,新任务会放入工作队列,直到队列满且线程数未达到`maximumPoolSize`,才会创建新线程处理。
41 0
|
9月前
|
存储 缓存 Java
Java线程池-当任务渐增时的处理-各个参数的含义
Java线程池-当任务渐增时的处理-各个参数的含义
47 0
|
2天前
|
Java
Java 方法(方法的调用机制、方法的传参机制)
Java 方法(方法的调用机制、方法的传参机制)
44 0
|
2天前
|
Java
通过生活案例快速 Get 线程池七个参数和工作原理
通过生活案例快速 Get 线程池七个参数和工作原理
61 0
|
2天前
|
Java API
线程池(关于变量捕获、线程数、针对ThreadPoolExecutor的构造方法参数的解释、自实现线程池)
线程池(关于变量捕获、线程数、针对ThreadPoolExecutor的构造方法参数的解释、自实现线程池)
|
10月前
|
Java
线程池的核心参数及执行原理你知道嘛?
线程池是一种管理和复用线程的机制,它可以提高线程的利用率和系统的性能。
278 0
|
8月前
|
存储 Java
线程池的核心参数和执行流程
本章主要讲解了线程池的核心参数和执行流程
81 0
|
9月前
|
缓存 Java 数据库连接
线程的创建、Lambda函数式接口?Runnable和Callable之间的适配?动态修改线程任务?这里带你图解Java线程池
上面只是提到了对于Thread执行任务的一种动态实现方法,肯定还有其他的。 那么动态实现有什么好处呢? 当我们有很多个任务的时候,我们如果一直使用new,再让gc的话,那么对于系统资源的消耗无疑是巨大的。 那么这个时候,如果我们固定一下,专门拿几个线程来处理并发任务呢?但是当并发任务很多又该怎么办? 这个时候就引入了池化思想 —— Pool 什么是池? 在学JDBC的时候我们知道了连接池,在学Spring的时候,我们又接触到了对象池。 其实按理来说线程池应该是大家在初学JavaSE的时候应该就遇到的,这里我们再来讲一下。 线程池,就是用一个容器来管理线程,这个容器叫做池(Poo
89 0
线程的创建、Lambda函数式接口?Runnable和Callable之间的适配?动态修改线程任务?这里带你图解Java线程池
|
9月前
|
消息中间件 前端开发 NoSQL
如何判断线程池任务执行完?
如何判断线程池任务执行完?
188 0
如何判断线程池任务执行完?