1. 线程池使用方式
示例代码：
// 一池N线程
Executors.newFixedThreadPool(int)
// 一个任务一个任务执行，一池一线程
Executors.newSingleThreadExecutorO
// 线程池根据需求创建线程，可扩容，遇强则强
Executors.newCachedThreadPool()
// 自定义线程池方式
new ThreadPoolExecutor(...)
注：一般在工作中都是根据业务场景进行自定义线程池，进行使用；
自定义线程池方法；详见后面章节：自定义线程池
2. 线程池底层工作原理
a. 线程池参数：
线程池，具有多个参数：具有各自的含义：
七参数：
- corePoolSize：核心线程数，一直保持活跃状态的线程
- maximumPoolSize：最大线程数，线程池能容纳的最大线程数量
- keepAliveTime：空闲线程存活时间，非核心线程的空闲存活时间
- unit：存活的时间单位，非核心线程的空闲存活时间单位
- workQueue：存放未执行任务的队列
- threadFactory：线程工厂，创建线程的工厂类
- handler：拒绝策略，队列满了和达到最大线程数后的拒绝策略
如图：
b. 线程池的拒绝策略
AbortPolicy：默认，直接抛出RejectedExcutionException异常，阻止系统正常运行
CallerRunsPolicy：该策略既不会抛弃任务，也不会抛出异常，而是将某些任务回退到调用者
DiscardPolicy：直接丢弃任务，不予任何处理也不抛出异常，如果允许任务丢失，这是一种好方案
DiscardOldestPolicy：抛弃队列中等待最久的任务，然后把当前任务加入队列中尝试再次提交当前任务
c. 线程池底层工作原理
在创建了线程池后，如果设置了核心线程数（corePoolSize），则线程池中的线程数会先创建相应数量的核心线程。如果没有任务到达，这些核心线程会保持活动状态。
当调用execute()方法添加一个请求任务时，线程池会根据以下判断来决定任务的执行方式：
- 如果正在运行的线程数量小于核心线程数（corePoolSize），则会立即使用核心线程来执行任务。
- 如果正在运行的线程数量大于或等于核心线程数，但任务队列未满，则任务会被放入队列中等待执行。
- 如果队列已满且正在运行的线程数量小于最大线程数（maximumPoolSize），则会创建非核心线程来执行任务。
- 这里需要注意，是先执行新的任务，队列里的任务不会执行，详见：5. 注意事项
- 如果队列已满且正在运行的线程数量已达到最大线程数，且拒绝策略允许，那么线程池会启动拒绝策略来处理新任务。
当一个线程完成任务时，它会从队列中取下一个任务来执行，或者在没有任务的情况下进入等待状态。
当一个线程空闲时间超过设定的keepAliveTime时，线程池会根据以下判断来决定线程的命运：
- 如果当前运行的线程数大于核心线程数（corePoolSize），则空闲线程会被终止。
- 线程池的所有任务完成后，它最终会收缩到核心线程数的大小。
注意事项：
在Java中java.util.concurrent.ThreadPoolExecutor线程池的默认行为是，当任务队列已满且再来一个新任务时，创建的新线程会被用来执行新来的任务而不是队列里已有的任务。
线程工作原理示意图：
3. 自定义线程池
a. 介绍：
前面提到过，一般在工作中都是根据业务场景进行自定义线程池；西面是阿里巴巴开发手册的说明；
b. 实现：
实现代码如下：
import org.jetbrains.annotations.NotNull;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import java.util.concurrent.*;
/**
* @author xxx
* @version 1.0
* @date xxx
*/
@Configuration
public class ThreadPoolExecutorConfig {
@Bean
public ThreadPoolExecutor threadPoolExecutor() {
// 创建自定义线程池
int corePoolSize = 2; // 核心线程数
int maxPoolSize = 4; // 最大线程数
long keepAliveTime = 10; // 线程空闲时间
TimeUnit unit = TimeUnit.SECONDS; // 时间单位
BlockingQueue<Runnable> workQueue = new ArrayBlockingQueue<>(10); // 任务队列
ThreadFactory threadFactory = Executors.defaultThreadFactory(); // 线程工厂
RejectedExecutionHandler handler = new ThreadPoolExecutor.AbortPolicy(); // 拒绝策略
// 创建ThreadPoolExecutor对象
ThreadPoolExecutor threadPool = new ThreadPoolExecutor(
corePoolSize,
maxPoolSize,
keepAliveTime,
unit,
workQueue,
threadFactory,
handler
);
return threadPool;
}
}
4. 线程池参数的选择原则
仅供参考：具体的线程池参数，需要根据业务场景，进行合理的测试选择
一般原则：
在使用java.util.concurrent.ThreadPoolExecutor自定义线程池时，参数的设置需要根据具体的业务场景和需求进行调整。以下是一些常用的业务场景和设置原则：
短时任务场景：
corePoolSize (n+1)：可以设置较小的值，例如CPU核心数加1。
maximumPoolSize (2n)：根据系统负载情况和任务的短时性来设置。通常可以设置为核心线程数的两倍或者根据系统资源进行调整。
workQueue：可以选择容量较小的队列，例如SynchronousQueue，以避免任务积压。长时任务场景：
corePoolSize：可以设置为一个相对较大的值，以确保有足够的线程处理任务。
maximumPoolSize：根据系统负载和任务的长时性来设置。如果长时任务较多，可以将最大线程数设置得较大一些。
keepAliveTime 和 TimeUnit：根据任务的处理时长和系统的响应时间来设置空闲线程的存活时间。I/O密集型任务场景：
corePoolSize(2n)：可以设置为较大的值，以充分利用系统资源，加速I/O操作。
maximumPoolSize：根据系统负载和I/O操作的并发数来设置，可以设置得比较大以应对高并发的情况。
workQueue：可以选择一个适当大小的队列，以充分缓冲I/O任务，但不至于占用过多内存。CPU密集型任务场景：
corePoolSize：可以根据CPU核心数设置，以充分利用系统的多核处理能力。
maximumPoolSize：可以设置得比较大，以应对突发的CPU密集型任务，但不要超过系统负载的承受范围。
workQueue：选择一个合适大小的队列来缓冲任务，避免因任务积压导致性能下降。
设置原则：
要根据具体的业务需求和系统特点来选择参数。
要根据实际情况进行监控和调优，以确保线程池能够有效地处理任务并保持系统的稳定性和性能。
要平衡资源的利用和系统的响应能力，避免设置过大或过小的参数，导致资源浪费或性能问题。
