一文搞懂SpringBoot如何利用@Async实现异步调用
作者：老顾聊技术 发布时间：2022-02-06 12:39:27
标签：SpringBoot,@Async,异步
前言
异步调用几乎是处理高并发，解决性能问题常用的手段，如何开启异步调用？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
0
投稿猜你喜欢
前言在【Android】线程间通信 - Handler之使用篇主要讲了 Handler 的创建，发送消息，处理消息 三个步骤。那么接下来，我- 目录前言线程基础1、创建线程2、暂停线程3、线程等待4、线程终止C#中的lock关键字总结前言最近由于工作的需要，一直在使用C#的多线程进行
- 本文实例为大家分享了Java实现登录和注册的具体代码，供大家参考，具体内容如下登录和注册案例的分析：我们在完成一个需求时，需要面向对象，我们
- Spring Cloud是一系列框架的有序集合。它利用Spring Boot的开发便利性巧妙地简化了分布式系统基础设施的开发，如服务发现注册
- 本文实例为大家分享了Android实现记事本功能的具体代码，供大家参考，具体内容如下MainActivity.java代码:package
- Springboot导入本地jar后 打包依赖无法加入1.本地jar包2.pom文件添加自定义jar包导入<!--自定义jar--&g
- 可能开发安卓的人大多数都用过很多下拉刷新的开源组件，但是今天用了官方v4支持包的SwipeRefreshLayout觉得效果也蛮不错的，特拿
- 首先，来看一下，快速排序的实现的动态图：快速排序介绍：快速排序，根据教科书说法来看，是冒泡排序的一种改进。快速排序，由一个待排序的数组（ar
- 本文介绍了什么是压缩纹理，以及加载压缩纹理的核心步骤。并在 Android OpenGLES 平台上实现了压缩纹理的显示。一、压缩纹理概念传
- 我们先假设一个场景想象一下，当一个项目出现bug的时候，恰巧这个时候需要你去修改，而当你打开项目之后，眼前的代码让你有一种特别严重的陌生感，
- 引言根据 C# 语言规范，不可能从一个方法返回多个值。使用 C# 提供的一些其他功能，我们可以将多个值返回给调用者方法。本文概述了一些可用的
- 一、Service简介Service是Android程序中四大基础组件之一，它和Activity一样都是Context的子类，只不过它没有U
- 在上篇文章给大家介绍了WebService教程详解(一)使用工具的原因：1、 使用工具可以更好的了解WebService请求的过程 2、 使
- 用一道选择题作为本文的开始吧！ ArrayList list = new ArrayList(20);中的list扩充几次 A.0 B.1
- 通过脚本命令行批量修改 Jenkins 任务最近，笔者所在团队的 Jenkins 所在的服务器经常报硬盘空间不足。经查发现很多任务没有设置“
- 夏天到了、小雪来给大家降降温话不多说、直接进入主题主要功能模块设计：登录注册、首页信息浏览、选课分类查看、选课详情查看、评论交流、收藏、浏览
- 本文实例为大家分享了两种java实现FTP文件上传下载的方式，供大家参考，具体内容如下第一种方式：package com.cloudpowe
- 什么是Handler？Handler可以发送和处理消息对象或Runnable对象，这些消息对象和Runnable对象与一个线程相关联。每个H
- 这篇文章主要介绍了Java判断用户名和密码过程详解,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可
- 本文实例为大家分享了Android实现图片加载进度提示的具体代码，供大家参考，具体内容如下先上图：实现原理：第一个控件的实现原理是重写Ima
