线程池是高级开发必备的技能之一，线程池在实际开发中使用频率非常高非常重要，这里介绍一下线程池的基本使用方法
一、频繁的创建线程有什么缺点？
1、经常创建和销毁线程会消耗非常大的资源，例如并发情况下的线程，对性能影响很大
二、使用线程池的思路：
1、提前把多个线程创建好，放入线程池中，使用时直接获取，使用完放回池中
三、使用线程池的好处：
1、提高系统(性能)响应速度（减少创建新线程的时间）
2、降低资源消耗（重复利用线程池中的线程，不需要每次都创建）
3、便于线程参数配置管理
四、使用 new ThreadPoolExecutor 传统方式创建线程池，(推荐此方式，创建线程池对象交给Spring容器管理)
1、配置线程池实例，代码如下
package com.hkl.mpjoin.configure;
import lombok.extern.slf4j.Slf4j;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import java.util.concurrent.*;
/**
* <p>Description：配置线程池</p>
* <p>Author：hkl</p>
* <p>Date：2022/9/15</p>
*/
@Slf4j
@Configuration
public class ExecutorsConfigure {
/**
* <p>线程池</p>
*
* @author hkl
* @date 2022/11/23
*/
@Bean
public ExecutorService executorService() {
ExecutorService executorService = new ThreadPoolExecutor(
5,
20,
60,
TimeUnit.SECONDS,
new ArrayBlockingQueue<>(200),
new ThreadPoolExecutor.AbortPolicy()
);
return executorService;
}
/**
* <p>日程线程池</p>
*
* @author hkl
* @date 2022/11/23
*/
@Bean
public ScheduledExecutorService scheduledExecutorService() {
ScheduledExecutorService scheduledExecutorService = new ScheduledThreadPoolExecutor(
5,
new ThreadPoolExecutor.AbortPolicy()
);
return scheduledExecutorService;
}
}
线程池参数解释：
| 参数 |
说明 |
| corePoolSize |
1、核心线程数，用于处理任务的主要线程，优先启用核心线程，一直存在不会被销毁 |
| maximumPoolSize |
1、允许存在的最大线程数(也叫活跃线程数) 2、核心线程被全部占用时，开始启用活动线程数，当活动活动线程数等于核心线程数时，此时不再继续增加活动线程数，而是把任务丢进工作队列，当工作队列也满了还在继续增加任务，那么就继续增加活动线程数直至最大
3、如果工作队列满了，活动线程数也达到最大了，还在增加任务，此时会触发拒绝策略 |
| keepAliveTime |
1、保持除核心线程外的线程存在时间 |
| unit |
1、保持除核心线程外的线程存在时间的单位，时分秒 |
| workQueue |
1、工作队列，核心线程全被占用后，新的任务存储到队列中。如果队列空间也满了之后会根据拒绝策略拒绝接收任务 |
五、使用线程池创建线程
//使用线程池处理任务
executorService.submit(() -> {
try {
Thread.sleep(2000);
} catch (InterruptedException e) {
throw new RuntimeException(e);
}
System.out.println("线程池任务执行了");
});
//开启异步任务，使用自定义线程池处理任务
CompletableFuture.supplyAsync(() -> {
try {
//模拟异步处理业务耗时
Thread.sleep(2000);
} catch (InterruptedException e) {
throw new RuntimeException(e);
}
System.out.println("线程池任务执行了");
return "aa";
}, executorService);
CompletableFuture 是JDK并发包中提供的创建异步任务的类，可以很方便的创建异步线程，最常用的是：
1、CompletableFuture.runAsync()
2、CompletableFuture.supplyAsync()
3、除这二者之外，还有很多，可以自行了解
说明：runAsync() 没有返回值，supplyAsync() 需要提供返回值
小结：
1、使用线程池创建线程比较方便，线程池中的线程可以复用(一旦空闲即可复用)
2、使用线程池可以对线程的数量、销毁时间、工作队列容量、拒绝处理策略等进行灵活配置
注意：
1、多线程是异步的，每个线程都是独立的，事务也是独立的
2、控制多线程中的事务一致性，参考：https://blog.csdn.net/hkl_Forever/article/details/129116451
