Spring的异步线程处理
时间:2022-07-28
本文章向大家介绍Spring的异步线程处理,主要内容包括其使用实例、应用技巧、基本知识点总结和需要注意事项,具有一定的参考价值,需要的朋友可以参考一下。
Spring封装了JDK的线程池和线程调用,并使用标签就可以开启多线程调用。
先进行一个Spring的线程池配置
@Configuration
@EnableAsync
public class ThreadPoolConfig implements AsyncConfigurer {
@Bean
@Override
public Executor getAsyncExecutor() {
ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
executor.setCorePoolSize(Runtime.getRuntime().availableProcessors());
executor.setMaxPoolSize(Runtime.getRuntime().availableProcessors() * 5);
executor.setQueueCapacity(Runtime.getRuntime().availableProcessors() * 2);
executor.setThreadNamePrefix("this-executor-");
executor.initialize();
return executor;
}
@Bean
@Override
public AsyncUncaughtExceptionHandler getAsyncUncaughtExceptionHandler() {
return new SimpleAsyncUncaughtExceptionHandler();
}
}
再编写一个Service的异步方法调用,这里是带返回值的,不带返回值的方法比较简单,这里就不举例了。
@Service
@Slf4j
public class ThreadTasks {
/**
* 如果异步方法有返回值,一定要使用Future包装,否则无法返回
* @return
* @throws InterruptedException
*/
@Async
public Future<String> startTask() throws InterruptedException {
Thread.sleep(3000);
log.info("this is async task");
return new AsyncResult<>("123456");
}
}
最后写一个Controller,对该异步方法进行调用
@RestController
public class AsyncTaskController {
@Autowired
private ThreadTasks tasks;
@GetMapping("/users-anon/useTask")
public String useSyncTask() throws InterruptedException, ExecutionException {
Future<String> future = tasks.startTask();
return future.get();
}
}
最后运行下来,我们可以看到每次都是不同的线程执行
2020-09-21 16:33:53.027 INFO [user-center,3e635fca3d1259da,d30e8b6372922137,false] 1126 --- [this-executor-1] com.cloud.user.service.ThreadTasks : this is async task
2020-09-21 16:35:27.664 INFO [user-center,9b68efbb2c848d7b,895ed921f6c8fe03,false] 1126 --- [this-executor-2] com.cloud.user.service.ThreadTasks : this is async task
- GeForce驱动EULA更新惹争议,NVIDIA的理由是这样的
- 关于HTML面试题汇总之visibility
- 加密狗进场暴富开始?请别侮辱区块链和游戏
- 程序猿的日常——Java基础之clone、序列化、字符串、数组
- [你必须知道的.NET] 第四回:后来居上:class和struct
- oc 中随机数的用法(arc4random() 、random()、CCRANDOM_0_1()
- 央行出台条码支付新规;美团打车将在7大城市上线;国产人工智能平台型芯片首发;苹果就降速门致歉
- 阿三又让全球看笑话,无人驾驶的地铁名不副实,还直接跑到大街上
- 盘点:2017年度这些科学大事件,哪个给您印象最深?
- 跳台阶问题
- mac下使用github
- CSS3新特性应用之结构与布局
- 程序猿的日常——Java基础之equals与hashCode
- 贾康:智能金融需在发展和规范中掌握理性权衡点
- java教程
- Java快速入门
- Java 开发环境配置
- Java基本语法
- Java 对象和类
- Java 基本数据类型
- Java 变量类型
- Java 修饰符
- Java 运算符
- Java 循环结构
- Java 分支结构
- Java Number类
- Java Character类
- Java String类
- Java StringBuffer和StringBuilder类
- Java 数组
- Java 日期时间
- Java 正则表达式
- Java 方法
- Java 流(Stream)、文件(File)和IO
- Java 异常处理
- Java 继承
- Java 重写(Override)与重载(Overload)
- Java 多态
- Java 抽象类
- Java 封装
- Java 接口
- Java 包(package)
- Java 数据结构
- Java 集合框架
- Java 泛型
- Java 序列化
- Java 网络编程
- Java 发送邮件
- Java 多线程编程
- Java Applet基础
- Java 文档注释
- 企业面试题|最常问的MySQL面试题集合(二)
- 值得一看的35个Redis面试题总结
- 容器技术|Docker三剑客之docker-machine
- 企业面试题|最常问的MySQL面试题集合(三)
- 「微服务架构」API版本控制最佳实践介绍
- 2020年最新字节、阿里、腾讯、爱奇艺等BAT Android社招高频面试题,押题99.98%!
- 使用镜像部署 Hexo 静态页面
- 基于zmq RPC简单C++实现
- App为什么会crash?一篇文章带你探究根本原因 ,事情没有你想得那么简单!
- MySQL 8.0新特性 — 用户管理
- Java15的新特性
- ZooKeeper到底为Kafka的做了什么牺牲?
- Flutter原理:三棵重要的树(渲染过程、布局约束、应用视图的构建等)
- FlutterDojo设计之道—状态管理之路(六)
- Day9.函数进阶