【Springboot】springboot 多线程@EnableAsync和@Async

「爱情、让人受尽委屈。」 2022-09-04 02:59 254阅读 0赞

**本文目录**

一、背景描述

二、使用方法

第一步：配置线程池

第二步：开启异步调用

第三步：异步调用

三、代码测试

--------------------

# 一、背景描述 #

众所周知，**java** 的代码是同步顺序执行，当我们需要执行异步操作时我们通常会去创建一个新线程去执行，即使用多线程技术，比如显式的 **new Thread()**，或者线程池 **ThreadPoolExecutor**。

在 **Springboot** 中对其进行了简化处理，只需要配置一个类型为 **java.util.concurrent.TaskExecutor**或其子类的 **bean** ，并在配置类或直接在程序入口类上声明注解 **@EnableAsync**。

而在 **Spring 3.0** 之后提供了一个 **@Async** 注解，使用 **@Async** 注解进行优雅的异步调用，我们先看一下API对这个注解的定义：[Annotation Type Async][]

我们只需要简单的在启动类或者配置类上添加 **@EnableAsync** 注解，然后在需要执行的方法上添加 **@Async** 注解即可

# 二、使用方法 #

## 第一步：配置线程池 ##

以下代码，可以拿来即用：

package com.iot.daily.config.async;
 
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
 import org.springframework.core.task.TaskExecutor;
 import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
 
 import java.util.concurrent.ThreadPoolExecutor;
 
 /**
 * AsyncConfig 此类用于：配置线程池
 * @author：hujm
 * @date：2021年08月09日 16:12
 * @remark：
 */
 @Configuration
 public class AsyncConfig {
 
 @Bean
 public TaskExecutor taskExecutor() {
 ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
 // 设置核心线程数
 executor.setCorePoolSize(5);
 // 设置最大线程数
 executor.setMaxPoolSize(10);
 // 设置队列容量
 executor.setQueueCapacity(20);
 // 设置线程活跃时间（秒）
 executor.setKeepAliveSeconds(60);
 // 设置默认线程名称
 executor.setThreadNamePrefix("cron-other-statistics-");
 // 设置拒绝策略
 executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
 // 等待所有任务结束后再关闭线程池
 executor.setWaitForTasksToCompleteOnShutdown(true);
 return executor;
 }
 }

## 第二步：开启异步调用 ##

在启动类上添加 **@EnableAsync** 注解，或者 在第一步中的 配置类上 添加 **@EnableAsync** 注解也可以。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDI5OTAyNw_size_16_color_FFFFFF_t_70][]

## 第三步：异步调用 ##

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDI5OTAyNw_size_16_color_FFFFFF_t_70 1][]

# 三、代码测试 #

从以下程序的打印日志中可以看出线程池已经正常工作了。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDI5OTAyNw_size_16_color_FFFFFF_t_70 2][]

完结！

[Annotation Type Async]: https://docs.spring.io/spring/docs/current/javadoc-api/org/springframework/scheduling/annotation/Async.html
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDI5OTAyNw_size_16_color_FFFFFF_t_70]: /images/20220829/c147ad6fa9ae44f5bfcb350f5144b47c.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDI5OTAyNw_size_16_color_FFFFFF_t_70 1]: /images/20220829/6eabded9543f486fb9debcb4342894ef.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDI5OTAyNw_size_16_color_FFFFFF_t_70 2]: /images/20220829/1c55b63986f0470894f83d88fba1f5d7.png