专业网站建设效果显著,ps做阿里网站分辨率设置,济南做网站多钱,重庆点优建设网站公司吗线程池中构造方法的认识 文章目录 线程池中构造方法的认识corePoolSize (核心线程数)maximumPoolSize#xff08;最大线程数#xff09;keepAliveTime(非核心线程的空闲超时时间)TimeUnitworkQueuethreadFactoryRejectedExecutionHandler拒绝策略 标准库中提供了一个ThreadPo…线程池中构造方法的认识 文章目录 线程池中构造方法的认识corePoolSize (核心线程数)maximumPoolSize最大线程数keepAliveTime(非核心线程的空闲超时时间)TimeUnitworkQueuethreadFactoryRejectedExecutionHandler拒绝策略 标准库中提供了一个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 {Overridepublic 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() // 自定义拒绝策略
);
