Spring boot使用多线程过程步骤解析
作者:MisMe 发布时间:2023-04-03 04:54:50
标签:Spring,boot,多,线程,步骤
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
0
投稿
猜你喜欢
- @Resource和@Autowired是Spring Framework中两种常用的注入方式,它们的作用是在Spring容器中自动装配Be
- Base64是网络上最常见的用于传输8Bit字节代码的编码方式之一,大家可以查看RFC2045~RFC2049,上面有MIME的详细规范。
- 得到选中项的value值并拼接成一个字符串返回public string GetChecked(CheckBoxList checkList
- java中删除 数组中的指定元素要如何来实现呢,如果各位对于这个算法不是很清楚可以和小编一起来看一篇关于java中删除 数组中的指定元素的例
- 一、访问控制url匹配在前面讲解了认证中所有常用配置,主要是对http.formLogin()进行操作。而在配置类中 http.author
- 这两天实现了下新手引导需要的遮罩镂空shader效果,记录一下。1、圆形镂空shader代码:  
- 前言:数据抽象是一种仅向用户显示基本细节的属性。不向用户显示琐碎或非必需的单元。例如:汽车被视为汽车而不是其单个组件。数据抽象也可以定义为仅
- 参数设置java程序启动参数 -D是用来做什么的呢? 官方解释如下:Set a system property value. If valu
- Selenium 是目前用的最广泛的Web UI 自动化测试框架。 本系列文章,将深入简出来讲解selenium 的用法阅读目录seleni
- 之前学习了设计模式原型模式,在原型模式中就提到了对象的深拷贝。深拷贝指的是拷贝一个对象时,不仅仅把对象的引用进行复制,还把该对象引用的值也一
- 1.简介这是一个用于实现像微信朋友圈和微博的类似的九宫格图片展示控件,通过自定义viewgroup实现,使用方便。 多图根据屏幕适配,单张图
- 一、项目结构二、pom.xml<?xml version="1.0" encoding="UTF-8&q
- JLabel 对象可以显示文本、图像或同时显示二者。可以通过设置垂直和水平对齐方式,指定标签显示区中标签内容在何处对齐。默认情况下,标签在其
- 1.插入排序这个打麻将或者打扑克的很好理解, 比如有左手有一副牌1,2,4,7 ,来一张3的牌, 是不是就是手拿着这张牌从右往左插到2,4之
- 前段时间摸索了java调用matlab东西,不说学的有多深,也算有结果了,达到目的了。也即用java程序可以调用matlab中函数了。&nb
- 近期遇到了DateTime到底是值类型还是引用类型的疑惑,顺势较深入地了解一下DateTime相关的内容结论:DateTime是值类型,因为
- Java实现简单台球桌问题,供大家参考,具体内容如下需求:使小球可以在桌面上移动,移动到桌面边缘将被弹回,显示小区的移动素材:小球照片桌球照
- c++换行符有哪些\n 换行,光标移到下一行的开头;endl,把缓冲槽的内容输出到控制台;\r 回车,光标移到当前行的开头,不会换到下一行,
- 1. 自动化装配介绍Spring Boot针对mvc做了大量封装,简化开发者的使用,内部是如何管理资源配置,Bean配置,环境变量配置以及启
- 1.鼠标右击我的电脑–》属性–》高级系统设置2.把下面的变量名称和电脑文件的本地路径填进去即可(注意:变量值后面后面不要带分号)jdk环境变