一文搞懂SpringBoot如何利用@Async实现异步调用
作者:老顾聊技术 发布时间:2022-02-06 12:39:27
前言
异步调用几乎是处理高并发,解决性能问题常用的手段,如何开启异步调用?SpringBoot中提供了非常简单的方式,就是一个注解@Async。今天我们重新认识一下@Async,以及注意事项
简单使用
新建三个作业任务:
@Service
public class TaskDemo {
private static Logger logger = LoggerFactory.getLogger(TaskDemo.class);
public void execute1() {
logger.info("处理耗时任务1......开始");
try {
TimeUnit.SECONDS.sleep(3);
} catch (InterruptedException e) {
e.printStackTrace();
}
logger.info("处理耗时任务1......结束");
}
public void execute2() {
logger.info("处理耗时任务2......开始");
try {
TimeUnit.SECONDS.sleep(3);
} catch (InterruptedException e) {
e.printStackTrace();
}
logger.info("处理耗时任务2......结束");
}
public void execute3() {
logger.info("处理耗时任务3......开始");
try {
TimeUnit.SECONDS.sleep(3);
} catch (InterruptedException e) {
e.printStackTrace();
}
logger.info("处理耗时任务3......结束");
}
}
测试代码:
@RestController
public class TaskController {
@Autowired
private TaskDemo taskDemo;
@GetMapping("/task/test")
public String testTask() {
taskDemo.execute1();
taskDemo.execute2();
taskDemo.execute3();
return "ok";
}
}
执行后我们可以发现,上面的代码是同一个线程的同步执行,整体耗时9秒才完成。
异步处理
springboot的异步,是非常简单的,加2个注解即可
@Service
public class TaskDemo {
private static Logger logger = LoggerFactory.getLogger(TaskDemo.class);
@Async
public void execute1() {
logger.info("处理耗时任务1......开始");
try {
TimeUnit.SECONDS.sleep(3);
} catch (InterruptedException e) {
e.printStackTrace();
}
logger.info("处理耗时任务1......结束");
}
@Async
public void execute2() {
logger.info("处理耗时任务2......开始");
try {
TimeUnit.SECONDS.sleep(3);
} catch (InterruptedException e) {
e.printStackTrace();
}
logger.info("处理耗时任务2......结束");
}
@Async
public void execute3() {
logger.info("处理耗时任务3......开始");
try {
TimeUnit.SECONDS.sleep(3);
} catch (InterruptedException e) {
e.printStackTrace();
}
logger.info("处理耗时任务3......结束");
}
}
@SpringBootApplication
@EnableAsync
public class DemoApp {
public static void main(String[] args) {
SpringApplication.run(DemoApp.class,args);
}
}
增加了@Async和@EnableAsync两个注解
从执行结果发现,整个流程用了3秒,以及用了3个线程执行。完成了异步调用
异步回调
有些场景我们需要知道异步处理的任务什么时候完成,需要做额外的业务处理。如:我们需要在3个任务都完成后,提示一下给用户
@Service
public class TaskDemo {
private static Logger logger = LoggerFactory.getLogger(TaskDemo.class);
@Async
public Future<String> execute1() {
logger.info("处理耗时任务1......开始");
try {
TimeUnit.SECONDS.sleep(3);
} catch (InterruptedException e) {
e.printStackTrace();
}
logger.info("处理耗时任务1......结束");
return new AsyncResult<>("任务1 ok");
}
@Async
public Future<String> execute2() {
logger.info("处理耗时任务2......开始");
try {
TimeUnit.SECONDS.sleep(3);
} catch (InterruptedException e) {
e.printStackTrace();
}
logger.info("处理耗时任务2......结束");
return new AsyncResult<>("任务2 ok");
}
@Async
public Future<String> execute3() {
logger.info("处理耗时任务3......开始");
try {
TimeUnit.SECONDS.sleep(3);
} catch (InterruptedException e) {
e.printStackTrace();
}
logger.info("处理耗时任务3......结束");
return new AsyncResult<>("任务3 ok");
}
}
@RestController
public class TaskController {
private static Logger logger = LoggerFactory.getLogger(TaskController.class);
@Autowired
private TaskDemo taskDemo;
@GetMapping("/task/test")
public String testTask() throws InterruptedException {
Future<String> task1 = taskDemo.execute1();
Future<String> task2 = taskDemo.execute2();
Future<String> task3 = taskDemo.execute3();
while (true){
if (task1.isDone() && task2.isDone() && task3.isDone()){
break;
}
TimeUnit.SECONDS.sleep(1);
}
logger.info(">>>>>>3个任务都处理完成");
return "ok";
}
}
执行结果发现,在请求线程里面给用户提示了3个任务都处理完成了。
这段代码主要改变了什么:
1、把具体任务返回类型改为了Future类型对象
2、在调用任务时,循环判断任务是否处理完
自定义线程池
说到异步处理,一定要考虑到线程池,什么是线程池,小伙伴可自行网补。@Async的线程池定义比较方便,直接上代码:
@Configuration
public class ThreadPoolConfig {
@Bean(name = "taskPool01Executor")
public ThreadPoolTaskExecutor getTaskPool01Executor() {
ThreadPoolTaskExecutor taskExecutor = new ThreadPoolTaskExecutor();
//核心线程数
taskExecutor.setCorePoolSize(10);
//线程池维护线程的最大数量,只有在缓冲队列满了之后才会申请超过核心线程数的线程
taskExecutor.setMaxPoolSize(100);
//缓存队列
taskExecutor.setQueueCapacity(50);
//许的空闲时间,当超过了核心线程出之外的线程在空闲时间到达之后会被销毁
taskExecutor.setKeepAliveSeconds(200);
//异步方法内部线程名称
taskExecutor.setThreadNamePrefix("TaskPool-01-");
/**
* 当线程池的任务缓存队列已满并且线程池中的线程数目达到maximumPoolSize,如果还有任务到来就会采取任务拒绝策略
* 通常有以下四种策略:
* ThreadPoolExecutor.AbortPolicy:丢弃任务并抛出RejectedExecutionException异常。
* ThreadPoolExecutor.DiscardPolicy:也是丢弃任务,但是不抛出异常。
* ThreadPoolExecutor.DiscardOldestPolicy:丢弃队列最前面的任务,然后重新尝试执行任务(重复此过程)
* ThreadPoolExecutor.CallerRunsPolicy:重试添加当前的任务,自动重复调用 execute() 方法,直到成功
*/
taskExecutor.setRejectedExecutionHandler(new ThreadPoolExecutor.AbortPolicy());
taskExecutor.setWaitForTasksToCompleteOnShutdown(true);
taskExecutor.initialize();
return taskExecutor;
}
@Bean(name = "taskPool02Executor")
public ThreadPoolTaskExecutor getTaskPool02Executor() {
ThreadPoolTaskExecutor taskExecutor = new ThreadPoolTaskExecutor();
//核心线程数
taskExecutor.setCorePoolSize(10);
//线程池维护线程的最大数量,只有在缓冲队列满了之后才会申请超过核心线程数的线程
taskExecutor.setMaxPoolSize(100);
//缓存队列
taskExecutor.setQueueCapacity(50);
//许的空闲时间,当超过了核心线程出之外的线程在空闲时间到达之后会被销毁
taskExecutor.setKeepAliveSeconds(200);
//异步方法内部线程名称
taskExecutor.setThreadNamePrefix("TaskPool-02-");
/**
* 当线程池的任务缓存队列已满并且线程池中的线程数目达到maximumPoolSize,如果还有任务到来就会采取任务拒绝策略
* 通常有以下四种策略:
* ThreadPoolExecutor.AbortPolicy:丢弃任务并抛出RejectedExecutionException异常。
* ThreadPoolExecutor.DiscardPolicy:也是丢弃任务,但是不抛出异常。
* ThreadPoolExecutor.DiscardOldestPolicy:丢弃队列最前面的任务,然后重新尝试执行任务(重复此过程)
* ThreadPoolExecutor.CallerRunsPolicy:重试添加当前的任务,自动重复调用 execute() 方法,直到成功
*/
taskExecutor.setRejectedExecutionHandler(new ThreadPoolExecutor.AbortPolicy());
taskExecutor.setWaitForTasksToCompleteOnShutdown(true);
taskExecutor.initialize();
return taskExecutor;
}
}
定义了2个线程池Bean
@Service
public class TaskDemo {
private static Logger logger = LoggerFactory.getLogger(TaskDemo.class);
@Async("taskPool01Executor")
public Future<String> execute1() {
logger.info("处理耗时任务1......开始");
try {
TimeUnit.SECONDS.sleep(3);
} catch (InterruptedException e) {
e.printStackTrace();
}
logger.info("处理耗时任务1......结束");
return new AsyncResult<>("任务1 ok");
}
@Async("taskPool01Executor")
public Future<String> execute2() {
logger.info("处理耗时任务2......开始");
try {
TimeUnit.SECONDS.sleep(3);
} catch (InterruptedException e) {
e.printStackTrace();
}
logger.info("处理耗时任务2......结束");
return new AsyncResult<>("任务2 ok");
}
@Async("taskPool02Executor")
public Future<String> execute3() {
logger.info("处理耗时任务3......开始");
try {
TimeUnit.SECONDS.sleep(3);
} catch (InterruptedException e) {
e.printStackTrace();
}
logger.info("处理耗时任务3......结束");
return new AsyncResult<>("任务3 ok");
}
}
@Async(“线程池名称”),指定value使用自己定义的线程池:
执行结果利用了线程池。
注意事项(一定注意)
在使用@Async注解时,很多小伙伴都会发现异步使用失败。主要原因是异步方法的定义出了问题。
1、异步方法不能使用static修饰
2、异步类没有使用@Component注解(或其他注解)导致spring无法扫描到异步类
3、异步方法和调用异步方法的方法不能在同一个类
4、类中需要使用@Autowired或@Resource等注解自动注入,不能自己手动new对象
5、如果使用SpringBoot框架必须在启动类中增加@EnableAsync注解
来源:https://www.51cto.com/article/718351.html
猜你喜欢
- 前言在上一篇文章中讲完了SpringMVC的大部分知识,此篇文章中主要讲解 * 。上一篇文章🚩 * 的使用是非常普遍的。例如在 OA系统中通
- java Mybatis存进时间戳封装了一个实体类,里面有个字段 Integer createTime。要利用这个实体类将一个时间戳存进数据
- 近期,Apache SkyWalking 修复了一个隐藏了近4年的Bug - TTL timer 可能失效问题,这个 bug 在 SkyWa
- 前言MyBatis中也提供了注解式开发⽅式,采⽤注解可以减少Sql映射⽂件的配置。 当然,使⽤注解式开发的话,sql语句是写在java程序中
- 1、为什么使用缓存  我们知道内存的读取速度远大于硬盘的读取速度。当需要重复地获取相同数据时,一次一次地
- 假如使用绝对路径,没有任何问题,就是移植性不太好。假如使用相对路径,则要注意当前路径“.”是在哪儿?一般我们都会在配置文件中加入log文件的
- 功能描述1、创建扑克牌。包括四种花色(黑桃,红心,梅花,方块),十三种点数(2-10,J,Q,K),不考虑大小王。2、创建两个玩家。包括玩家
- 面试官:sychronized关键字有哪些特性?应聘者:可以用来修饰方法;可以用来修饰代码块;可以用来修饰静态方法;可以保证线程安全;支持锁
- 一、XSSFpackage com.yy.demo01;import java.io.FileInputStream;import java
- 前言:文件的上传和下载在日常开发中很是常见,那么这一功能是如何实现的呢,下面我给大家介绍一下实现条件:1、需要一个form标签,method
- 以下摘自胖哥分享的 2022开工福利教程。在学习Spring Security的时候你有没有下面这两个疑问:Spring Security的
- 一. 安装依赖包yum install -y wgetyum install -y gcc-c++yum install -y zlib-d
- 本文实例为大家分享了Java实现简单幸运抽奖的具体代码,供大家参考,具体内容如下代码模块:User类:package test1;publi
- 前言Java8 由Oracle在2014年发布,是继Java5之后最具革命性的版本。Java8吸收其他语言的精髓带来了函数式编程,lambd
- 1)页面跳转 直接返回字符串:此种方式会将返回的字符串与视图解析器的前后缀拼接后跳转。 返回带有前缀的字符串:转发:
- 最近在做代码优化时学习和研究了下JAVA多线程的使用,看了菜鸟们的见解后做了下总结。1、继承Thread类实现多线程继承Thread类的方法
- Java及数据库对日期进行格式化Java对日期进行格式化可使用java.text.SimpleDateFormat示例package com
- 在上一节中,我带大家学习了详解SpringBoot集成Redis来实现缓存技术方案,尤其是结合Spring Cache的注解的实现方案,接下
- List 是在开发中比较常用的集合,今天总结一下 Java 中初始化 List 的几种方式。1、常规方式List<String>
- 前言之前做的几个微信小程序项目,大部分客户都有要在微信小程序前端提现的需求。提现功能的实现,自然使用企业付款接口,不过这个功能开通比较麻烦,