Spring boot使用多线程过程步骤解析
作者:MisMe 时间:2023-04-03 04:54:50
Spring中实现多线程,其实非常简单,只需要在配置类中添加@EnableAsync就可以使用多线程。在希望执行的并发方法中使用@Async就可以定义一个线程任务。通过spring给我们提供的ThreadPoolTaskExecutor就可以使用线程池。
第一步,先在Spring Boot主类中定义一个线程池,比如:
package com.jmxf.core.config;
import java.util.concurrent.Executor;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.annotation.EnableAsync;
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
@Configuration
@EnableAsync // 启用异步任务
public class AsyncConfiguration {
// 组件计算
@Bean("zjExecutor")
public Executor asyncExecutor() {
ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
//核心线程数5:线程池创建时候初始化的线程数
executor.setCorePoolSize(5);
//最大线程数5:线程池最大的线程数,只有在缓冲队列满了之后才会申请超过核心线程数的线程
executor.setMaxPoolSize(10);
//缓冲队列500:用来缓冲执行任务的队列
executor.setQueueCapacity(500);
//允许线程的空闲时间60秒:当超过了核心线程出之外的线程在空闲时间到达之后会被销毁
executor.setKeepAliveSeconds(60);
//线程池名的前缀:设置好了之后可以方便我们定位处理任务所在的线程池
executor.setThreadNamePrefix("DailyAsync-");
executor.initialize();
return executor;
}
}
有很多你可以配置的东西。默认情况下,使用SimpleAsyncTaskExecutor。
第二步,使用线程池
在定义了线程池之后,我们如何让异步调用的执行任务使用这个线程池中的资源来运行呢?方法非常简单,我们只需要在@Async注解中指定线程池名即可,比如:
package com.jmxf.service.fkqManage.zj;
import org.springframework.scheduling.annotation.Async;
@Service
public class CentreZj {
/**
* 多线程执行 zj计算推数
* @param fkqZj
* @throws Exception
*/
@Async("zjExecutor")
public CompletableFuture<String> executeZj (FkqZj fkqZj) {
if(fkqZj == null) return;
String zjid = fkqZj.getZjid();
FkqHdzjdm zjdm = getZjdm(zjid);
String zjlj = zjdm.getZjlj();
if(StringUtils.isBlank(zjlj)) return;
Object bean = ApplicationContextProvider.getBean(zjlj);
Method method;
try {
method = bean.getClass().getMethod("refresh",String.class);
method.invoke(bean,zjid);
} catch (Exception e) {
e.printStackTrace();
}
}
return CompletableFuture.completedFuture(zjid);
}
executeZj方法被标记为Spring的 @Async 注解,表示它将在一个单独的线程上运行。该方法的返回类型是 CompleetableFuture 而不是 String,这是任何异步服务的要求。
第三步,调用测试
List<CompletableFuture<String>> executeZjs = new ArrayList<>();
for (FkqZj fkqZj : zjs) {
CompletableFuture<String> executeZj = centreZj.executeZj(fkqZj);
executeZjs.add(executeZj);
}
//等待所以子线程结束后 返回结果
for (CompletableFuture<String> completableFuture : executeZjs) {
CompletableFuture.allOf(completableFuture).join();
}
注意事项
异步方法和调用方法一定要写在不同的类中 ,如果写在一个类中,是没有效果的!
原因:
spring对@Transactional注解时也有类似问题,spring扫描时具有@Transactional注解方法的类时,是生成一个代理类,由代理类去开启关闭事务,而在同一个类中,方法调用是在类体内执行的,spring无法截获这个方法调用。
来源:https://www.cnblogs.com/MisMe/p/13390092.html
标签:Spring,boot,多,线程,步骤
![](/images/zang.png)
![](/images/jiucuo.png)
猜你喜欢
Spring Batch批处理框架使用解析
2021-12-24 03:41:19
Android中WebView图片实现自适应的方法
2021-11-15 06:37:32
Java Resource路径整理总结
2021-11-24 06:52:31
C#多线程开发实战记录之线程基础
2022-11-03 03:21:45
![](https://img.aspxhome.com/file/2023/2/86962_0s.png)
Spring Shell应用程序开发流程解析
2021-06-28 23:20:50
WPF自定义TreeView控件样式实现QQ联系人列表效果
2023-02-01 06:34:17
![](https://img.aspxhome.com/file/2023/4/111284_0s.gif)
C# 使用Proxy代理请求资源的方法步骤
2022-07-16 22:20:37
![](https://img.aspxhome.com/file/2023/4/129614_0s.jpg)
java 多态性详解及常见面试题
2023-03-15 18:08:49
Android编程设计模式之状态模式详解
2021-06-12 15:26:28
![](https://img.aspxhome.com/file/2023/7/139177_0s.png)
java开发CPU流水线与指令乱序执行详解
2023-07-01 19:59:23
![](https://img.aspxhome.com/file/2023/4/83094_0s.png)
java_object的简单使用详解
2023-08-22 11:35:57
Unity的IPostBuildPlayerScriptDLLs实用案例深入解析
2022-12-23 00:12:38
Android编程之短信窃听器实现方法
2023-11-01 00:48:22
Java Lock锁多线程中实现流水线任务
2023-08-09 17:44:02
![](https://img.aspxhome.com/file/2023/1/106161_0s.png)
java序列化与反序列化的使用方法汇总
2022-02-27 14:47:25
通过实例解析传统jar包引用方式
2022-08-01 05:14:06
java判断两个时间是不是同一天的方法
2022-09-23 03:09:16
Android自定义一个view ViewRootImpl绘制流程示例
2023-01-04 07:47:14
![](https://img.aspxhome.com/file/2023/8/123358_0s.png)
使用@SpringBootTest注解进行单元测试
2021-09-27 04:02:04
Java实现中英文词典功能
2021-06-20 18:25:56