Srping注解之@Async：SpringBoot 实现异步调用-阿里云开发者社区

Srping注解之@Async：SpringBoot 实现异步调用

2023-08-10 78

版权

本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。

简介： Srping注解之@Async：SpringBoot 实现异步调用

1：前言

在日常开发过程中，会遇到一些需求是和主业务逻辑低耦合的，不要求和主业务逻辑同步进行，比如记录日志信息、发送消息通知电子邮件、生成PDF合同和导出报表等需求，而且，这些需求往往处理起来比较耗时。这个时候就需要开启新线程处理这些耗时多的业务，为主业务逻辑以最快速度执行完毕保驾护航。

2：如何创建线程池

在Spring Boot项目中通过注解开启异步线程，仅仅需要做两件事情：

① 在启动类添加注解@EnableAsync，开启异步调用。

②在方法上添加注解@Async("yourThreadPool")，其中，yourThreadPool为自定义线程池，可以使用系统默认线程池。

3：自定义线程池

新建Async.java配置类：

package com.xxxx.demoend.common;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.annotation.EnableAsync;
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
import java.util.concurrent.Executor;
import java.util.concurrent.ThreadPoolExecutor;
/**
 * @Author 
 * @Date Created in  2023/5/17 9:24
 * @DESCRIPTION:
 * @Version V1.0
 */
@EnableAsync//由于这个配置类中添加了@EnableAsync注解，故在项目启动类中就不必再次添加了。
@Configuration
public class Async {
   @Bean("east7TaskExecutor")
   public Executor taskExecutor() {
      ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
      //corePoolSize：线程池创建时候初始化的线程数；
      executor.setCorePoolSize(10);
      //maxPoolSize：线程池最大的线程数，只有在缓冲队列满了之后才会申请超过核心线程数的线程;
      executor.setMaxPoolSize(20);
      //queueCapacity：用来设置缓冲队列的容量，Set the capacity for the ThreadPoolExecutor's BlockingQueue.
      executor.setQueueCapacity(200);
      //keepAliveSeconds：允许线程的空闲时间60秒，当超过了核心线程数外的线程在空闲时间到达之后会被销毁；
      executor.setKeepAliveSeconds(60);
      //threadNamePrefix：线程池名的前缀，用于快速定位当前任务所在的线程池；
      executor.setThreadNamePrefix("east7Task-");
      //rejectedExecutionHandler：线程池对拒绝任务的处理策略，这里采用了CallerRunsPolicy;
      executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
      //waitForTasksToCompleteOnShutdown：默认值为false，这里赋值true，
      // 用来设置线程池关闭的时候等待所有任务都完成再继续销毁其他的Bean，
      // 这样这些异步任务的销毁就会先于其它对象（如数据库连接池对象）销毁；
      executor.setWaitForTasksToCompleteOnShutdown(true);
      //awaitTerminationSeconds：设置线程池中任务的等待时间，
      // 如果超过这个时间还没有销毁就强制销毁，以确保应用最后能够被关闭，而不被阻塞。
      executor.setAwaitTerminationSeconds(60);
      return executor;
   }
}

TestController.java

@RestController
@RequestMapping("test")
@Slf4j
@CrossOrigin
public class Test {
    @Resource
    private UserService userService;
    @GetMapping("/testSync")
    public void testSync() {
        userService.hello();
        String date = LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"));
        log.info("testSync 方法继续执行，当前时间：{}", date);
        log.error("执行结束");
    }
}
///
   @Async("east7TaskExecutor")
   public void hello() {
      try {
         log.info("同学们，课间休息时间到了");
         Thread.sleep(3000);
         String date = LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"));
         log.warn("休息结束，继续上课，当前时间：{}", date);
      } catch (InterruptedException e) {
         log.error("执行失败", e);
      }
   }