SpringBoot使用多线程
一 概述
1 为什么使用多线程
在我们开发系统过程中，经常会处理一些好费时间的任务（如向数据库中插入上百万数据，将会导致系统阻塞），这个时候就会自然想到使用多线程。
当数据量大的时候，一个新的线程满足不了系统的要求，但是只有少量的请求可以直接new一个新线程，如下代码。
// 少量请求可以这样做
new Thread(){
@Override
public void run() {
//TODO异步任务
}
}.start();
2 为什么使用Spring来实现多线程
- 使用Spring比使用JDK原生的并发API更简单。（
@Async就能解决）。 - 一般的开发环境都会集成Spring框架，Bean也都交给Spring来管理，因此，Spring实现多线程更简单。
3 为什么需要使用异步（多线程）
传统的调用方式：调用一个服务，需要等待服务调用完成后，才能执行后面的代码，因此，需要等待时间。
使用异步的方式：调用一个服务的同时，继续执行后面的代码，几乎是不需要多少的等待时间。
二 SpringBoot使用多线程
1 如何使用
在 SpringBoot 中对其进行了简化处理，只需要配置一个类型为 java.util.concurrent.TaskExecutor
或其子类（ 一般使用 Spring 提供的ThreadPoolTaskExecutor 类）的Bean，并在配置类或直接在程序入口类上声明注解 @EnableAsync。
调用也简单，在由Spring管理的对象的方法上标注注解 @Async，显式调用即可生效。
2 配置多线程
- 通过新增配置类的方式，使用 ThreadPoolTaskExecutor配置Bean
@Configuration
// 通过注解启用异步任务
@EnableAsync
public class ThreadConfig {
@Bean
public ThreadPoolTaskExecutor executor(){
ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
//配置核心线程数
executor.setCorePoolSize(15);
//配置最大线程数
executor.setMaxPoolSize(30);
//配置队列大小
executor.setQueueCapacity(1000);
//线程的名称前缀
executor.setThreadNamePrefix("Executor-");
//线程活跃时间（秒）
//executor.setKeepAliveSeconds(60);
//等待所有任务结束后再关闭线程池
executor.setWaitForTasksToCompleteOnShutdown(true);
//设置拒绝策略
//executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
//执行初始化
executor.initialize();
return executor;
}
}
- 如果只是简单的参数配置，那么直接在配置文件中加入如下配置即可
# 多线程配置
spring:
task:
execution:
pool:
core-size: 8
max-size: 256
keep-alive: 60000
queue-capacity: 256
thread-name-prefix: test
- 注意，以上通过yaml配置的方式，需要在启动类上加上多线程的启动注解。
// 通过注解启用异步任务
@EnableAsync
@SpringBootApplication
public class DbpmsApplication {
public static void main(String[] args) {
SpringApplication.run(DbpmsApplication.class, args);
}
}
3 使用多线程
- service层
public interface Test{
// 不能有返回值，如果需要返回值需要callback方法
void saveObject(String str);
}
- service实现层
// 注解不再是@Override而是@Async
@Async
public void saveObject(String str){
// 打印线程名，看是否开启了多线程
String tName=Thread.currentThread().getName();
System.err.println("调用的线程名字："+tName);
// 可以在下方添加保存数据库操作
}
- 测试类
@Test
void testMd503() {
sysLogService.saveObject("张三");
sysLogService.saveObject("李四");
sysLogService.saveObject("王五");
sysLogService.saveObject("赵六");
}
- 打印结果
- 如果不通过@Async注解的方式声明并创建多线程，也可以直接通过注入的ThreadPoolTaskExecutor类的execute方法来创建多线程，如下所示。
@RestController
@RequestMapping("/test")
public class ThreadPoolController {
@Autowired
private SysLogService sysLogService;
// 注入线程池类
@Autowired
private ThreadPoolTaskExecutor executor;
@GetMapping("/test")
public Results test(){
// 线程异步导入数据库,会异步开始执行新增方法,同时原线程不会等待，继续执行。实现了异步操作。
executor.execute(() -> sysLogService.saveObject("张三"););
Results results = Results.success();
return results;
}
}