线程池构造方法的认识

线程池中构造方法的认识

文章目录

线程池中构造方法的认识
- corePoolSize (核心线程数)
- maximumPoolSize（最大线程数）
- keepAliveTime(非核心线程的空闲超时时间)
- TimeUnit
- workQueue
- threadFactory
- RejectedExecutionHandler拒绝策略

标准库中提供了一个ThreadPoolExecutor类,这个类中最复杂的就是构造方法,而且这个类中由于构造方法过于复杂
而且有缺陷,所以就对外提供了创建实例的 “工厂方法” ,这样的方法其实就是普通的静态方法.

工厂方法的内部有给我们提供构造想要的实例的代码实现,所以我们只需要通过工厂方法的方法名来获取我们想要的实例即可.

线程池是Java标准库中的Java.util.concurrent.ThreadPoolExecutor类中.

标准库中提供了一个 Java.util.concurrent.ThreadPoolExecutor类

这个类中的构造方法比较多,我们主要了解参数最多最复杂的那个构造方法

我们来一个一个的解释:

corePoolSize 核心线程数和maxmumPoolSize最大线程数分别都是什么?都有什么区别?

corePoolSize (核心线程数)

corePoolSize 是线程池的基本大小，表示在没有任务执行时，线程池维护的线程数。即使这些线程当前处于空闲状态，它们也会被保留在池中。
当有新任务提交到线程池时，如果当前池中的线程数小于 corePoolSize，则会创建一个新线程来执行任务，即使其他线程处于空闲状态。
如果任务数超过 corePoolSize，而任务队列未满，新任务将被放入任务队列而不是新建线程（除非线程池已满）。

maximumPoolSize（最大线程数）

maximumPoolSize 表示线程池的最大大小，即线程池中允许的最大线程数。
当任务队列已满且池中线程数小于 maximumPoolSize 时，线程池会创建新的线程来执行任务，直到达到最大线程数。
超过最大线程数的任务将被拒绝（默认是抛出 RejectedExecutionException 异常，但可以通过设置拒绝策略来进行不同的处理）。

区别：

在池中运行的线程数将在 corePoolSize 和 maximumPoolSize 之间进行动态调整。
当任务数增加时，线程池会尽可能地扩展到 maximumPoolSize；当任务数减少时，线程池会逐渐收缩到 corePoolSize。
corePoolSize 提供了一种在任务轻量时保持一定线程数的机制，以提高任务的响应速度。
而 maximumPoolSize 提供了在负载较大时临时增加线程数以处理额外任务的机制。
在构建 ThreadPoolExecutor 时，合理设置 corePoolSize 和 maximumPoolSize 是关键，以确保线程池能够在不同负载下表现出理想的性能。

keepAliveTime(非核心线程的空闲超时时间)

keepAliveTime 表示非核心线程的空闲超时时间，即当线程池中的线程数大于核心线程数时，
空闲的非核心线程在经过一定时间后会被终止并从线程池中移除。
如果线程池的线程数超过核心线程数，但有一些线程在一段时间内没有执行任务，
这些线程就被认为是空闲的。keepAliveTime 就是指定这些空闲线程的最大存活时间。

TimeUnit

TimeUnit 是一个枚举类型，用于表示时间单位。它规定了 keepAliveTime的时间单位，
包括 NANOSECONDS、MICROSECONDS、MILLISECONDS、SECONDS、MINUTES、HOURS 和 DAYS。
当设置 keepAliveTime 时，需要同时指定时间单位，以便正确地解释超时时间。
例如，通过设置 TimeUnit.SECONDS可以将超时时间单位设置为秒。

workQueue

workQueue 是 ThreadPoolExecutor 中的一个参数，用于指定任务队列。
线程池的任务队列主要用于存储提交但尚未被执行的任务。用户可以手动传入一个任务队列，
这样可以根据实际需求选择不同的队列实现，以满足特定的场景和性能要求。例如，在某些场景下，对响应时间要求较高，可以选择同步队列；而在某些场景下，
对系统资源的使用有更高的要求，可以选择有界队列或无界队列。手动传入任务队列是为了提供更大的灵活性和定制性。

这个参数允许用户自定义创建新线程的方式，从而可以控制线程的创建过程，包括线程的名字、优先级、守护状态等。

threadFactory

threadFactory 参数是一个实现了 ThreadFactory 接口的对象。ThreadFactory 是一个简单的接口，它只有一个方法：Thread newThread(Runnable r)。当线程池需要创建一个新线程时，会调用这个方法。

RejectedExecutionHandler拒绝策略

线程池的拒绝策略

线程池的任务队列已经满了(工作线程已经忙不过来了)如果又有别人
往里面添加新的任务,怎么办?

这个策略对于我们实现高并发服务器,是十分有意义的

Java中的线程池在面临无法接受新任务的情况时，会执行拒绝策略。
拒绝策略定义了在线程池饱和时如何处理新任务的策略。
ThreadPoolExecutor 提供了几种内置的拒绝策略，同时也允许用户自定义拒绝策略。

以下是Java中常见的拒绝策略：

AbortPolicy（默认策略）：
- AbortPolicy是 ThreadPoolExecutor的默认拒绝策略。
  当任务无法被提交时，会抛出 RejectedExecutionException 异常。
CallerRunsPolicy：
- CallerRunsPolicy拒绝策略将会把任务返回给提交任务的线程执行。这种方式，
  虽然可能导致调用线程变慢，但是不会抛出异常。
DiscardPolicy：
- DiscardPolicy拒绝策略会默默地丢弃无法处理的任务，不会抛出异常。
DiscardOldestPolicy：
- DiscardOldestPolicy拒绝策略会丢弃队列中等待时间最久的任务，然后将新任务加入队列。同样，不会抛出异常。

用户还可以通过实现 RejectedExecutionHandler 接口来定义自己的拒绝策略。
自定义拒绝策略需要实现 RejectedExecutionHandler接口的 rejectedExecution方法，
该方法定义了任务被拒绝时的处理逻辑。

示例代码：

public class CustomRejectedHandler implements RejectedExecutionHandler {
    @Override
    public void rejectedExecution(Runnable r, ThreadPoolExecutor executor) {
        // 自定义处理逻辑，例如记录日志、通知等
        System.err.println("Task rejected: " + r.toString());
    }
}

// 使用自定义拒绝策略
ThreadPoolExecutor executor = new ThreadPoolExecutor(
    corePoolSize,       // 核心线程数
    maximumPoolSize,    // 最大线程数
    keepAliveTime,      // 非核心线程的空闲超时时间
    TimeUnit.SECONDS,   // 时间单位
    workQueue,          // 任务队列
    new CustomRejectedHandler()  // 自定义拒绝策略
);