线程池工作机制

Posted 2023-02-17

参考技术A

ThreadPoolExecutor 是线程池的核心实现类，用来执行被提交的任务

corePoolSize 核心线程数

maximumPoolSize 最大线程数

线程池中允许的最大线程数。

keepAliveTime 线程空闲时的存活时间

当线程没有执行任务时，继续存活的时间。当线程池中的线程数量大于核心线程数时，即时没有新任务提交，核心线程外的线程也不会立即销毁，而是等待keepAliveTime才会销毁。

unit 线程空闲时的存活时间单位

workQueue 阻塞队列

阻塞队列：1）支持阻塞的插入方法：当队列满时，队列会阻塞插入元素的线程，直到队列不满；2）支持阻塞的移除方法：在队列为空时，获取元素的线程会等待队列变为非空

生产者和消费者模式 能够解决并发问题，通过平衡生产线程和消费线程的工作能力来提高程序整体处理数据的速度。通过阻塞队列来进行通信，生产者生产完数据不用等待消费者处理，直接扔给阻塞队列，消费者也直接从阻塞队列中取数据，既能够解耦，又平衡两者的处理能力。

常用阻塞队列：

threadFactory 创建线程的工厂

handler 拒绝策略

当阻塞队列满了，且没有空闲的工作线程，继续提交任务会采取一种策略处理新任务。线程池提供了4中策略：

1）AbortPolicy：直接抛出异常，默认策略

2）CallerRunsPolicy：用调用者所在的线程来执行任务

3）DiscardPolicy：直接丢弃任务

4）DiscardOldestPolicy：丢弃阻塞队列中最靠前的任务

也可以自己根据应用场景（如记录日志或持久化储存不能处理的任务）实现RejectedExecutionHandler接口，自定义拒绝策略。

看下ThreadPoolExecutor的execute方法：

流程图：

提交任务：

关闭线程池：遍历线程池中的工作线程，然后逐个调用interrupt方法来中断线程。