Spring 提供的对 ThreadPoolExecutor 封装的线程池 ThreadPoolTaskExecutor ，直接使用注解启用 @EnableAsync @Async

要使用到线程池，我们还需要来创建Executors，在使用spring中，已经给我们做了很好的支持。只要 @EnableAsync 就可以使用多线程。使用 @Async 就可以定义一个线程任务。通过spring给我们提供的 ThreadPoolTaskExecutor 就可以使用线程池。
默认情况下，Spring将搜索相关的线程池定义：要么在上下文中搜索唯一的 AsyncServiceExecutorbean ，要么搜索名为 asyncServiceExecutor 的Executor bean。如果两者都无法解析，则将使用 SimpleAsyncTaskExecutor 来处理异步方法调用。

定义配置类

要使用 @Configuration 和 @EnableAsync 这两个注解，表示这是个配置类，并且是线程池的配置类
@EnableAsync 开始对异步任务的支持

  1. @Configuration
  2. @EnableAsync
  3. public class ExecutorConfig {
  4.     private static final Logger logger = LoggerFactory.getLogger(ExecutorConfig.class);
  6.     private static final int CORE_POOL_SIZE = 10;
  7.     private static final int MAX_POOL_SIZE = 100;
  8.     private static final int KEEP_ALIVE_TIME = 10;
  9.     private static final int QUEUE_CAPACITY = 200;
  10.     private static final String THREAD_NAME_PREFIX = "Async-Service-";
  12.     // bean的名称，默认为首字母小写的方法名
  13.     @Bean(name = "asyncServiceExecutor")
  14.     public ThreadPoolTaskExecutor asyncServiceExecutor(){
  15.         ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
  16.         // 核心线程数（默认线程数）
  17.         executor.setCorePoolSize(CORE_POOL_SIZE);
  18.         // 最大线程数
  19.         executor.setMaxPoolSize(MAX_POOL_SIZE);
  20.         // 允许线程空闲时间（单位：默认为秒）
  21.         executor.setQueueCapacity(QUEUE_CAPACITY);
  22.         // 缓冲队列数
  23.         executor.setKeepAliveSeconds(KEEP_ALIVE_TIME);
  24.         // 线程池名前缀
  25.         executor.setThreadNamePrefix(THREAD_NAME_PREFIX);
  27.         // 线程池对拒绝任务的处理策略
  28.         // rejection-policy：当pool已经达到max size的时候，如何处理新任务
  29.         // CALLER_RUNS：不在新线程中执行任务，而是有调用者所在的线程来执行
  30.         executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
  31.         // 初始化
  32.         executor.initialize();
  33.         return executor;
  34.     }
  36. }

创建业务层

创建一个 Service 接口，是异步线程的接口

  1. public interface AsyncService {
  2.     /** * 执行异步任务 * 可以根据需求，自己加参数拟定，我这里就做个测试演示 */
  3.     void service1() throws InterruptedException;
  4.     void service2() throws InterruptedException;
  5. }

实现类
将 Service 层的服务异步化，在service()方法上增加注解 @Async("asyncServiceExecutor") ， asyncServiceExecutor 方法是前面ExecutorConfig.java 中的方法名，表明service方法进入的线程池是 asyncServiceExecutor 方法创建的
@Async 注解来声明一个或多个异步任务，可以加在方法或者类上，加在类上表示这整个类都是使用这个自定义线程池进行操作

  1. @Service
  2. public class AsyncServiceImpl implements AsyncService {
  4.     private static final Logger logger = LoggerFactory.getLogger(AsyncServiceImpl.class);
  6.     // 发送提醒短信 1
  7.     @Async("asyncServiceExecutor")
  8.     @Override
  9.     public void service1() throws InterruptedException {
  10.         logger.info("--------start-service1------------");
  11.         Thread.sleep(5000); // 模拟耗时
  12.         logger.info("--------end-service1------------");
  13.     }
  15.     // 发送提醒短信 2
  16.     @Async("asyncServiceExecutor")
  17.     @Override
  18.     public void service2() throws InterruptedException {
  20.         logger.info("--------start-service2------------");
  21.         Thread.sleep(2000); // 模拟耗时
  22.         logger.info("--------end-service2------------");
  24.     }
  25. }

接下来就是在 Controller 里或者是哪里通过注解@Autowired注入这个 Service

  1. @RestController
  2. @RequestMapping("/async")
  3. public class AsyncController {
  5.     @Autowired
  6.     private AsyncService service;
  7.     @GetMapping("/test")
  8.     public void test() throws InterruptedException {
  9.         service.service1();
  10.         service.service2();
  11.         service.service2();
  12.         service.service2();
  13.     }
  14. }
  15. 15:43:27.665  INFO 2244 --- [Async-Service-3] AsyncServiceImpl   : --------start-service2------------
  16. 15:43:27.664  INFO 2244 --- [Async-Service-4] AsyncServiceImpl   : --------start-service1------------
  17. 15:43:27.665  INFO 2244 --- [Async-Service-1] AsyncServiceImpl   : --------start-service2------------
  18. 15:43:27.664  INFO 2244 --- [Async-Service-2] AsyncServiceImpl   : --------start-service2------------
  19. 15:43:29.666  INFO 2244 --- [Async-Service-1] AsyncServiceImpl   : --------end-service2------------
  20. 15:43:29.666  INFO 2244 --- [Async-Service-2] AsyncServiceImpl   : --------end-service2------------
  21. 15:43:29.666  INFO 2244 --- [Async-Service-3] AsyncServiceImpl   : --------end-service2------------
  22. 15:43:32.680  INFO 2244 --- [Async-Service-4] AsyncServiceImpl   : --------end-service1------------

@Async失效场景

  • 异步方法使用static修饰
  • 异步类没有使用@Component注解（或其他注解）导致spring无法扫描到异步类
  • 异步方法不能与异步方法在同一个类中
  • 类中需要使用@Autowired或@Resource等注解自动注入，不能自己手动new对象
  • 在Async 方法上标注@Transactional是没用的。 在Async 方法调用的方法上标注@Transactional 有效。
  • 调用被@Async标记的方法的调用者不能和被调用的方法在同一类中不然不会起作用
  • 使用@Async时要求是不能有返回值的不然会报错的 因为异步要求是不关心结果的