Spring @Async和@EnableAsync详细理解

短命女 2022-10-12 01:36 407阅读 0赞

### 一、同步与异步 ###

同步：就是调用某个东西是，调用方得等待这个调用返回结果才能继续往后执行。

异步：在调用发出后调用者可用继续执行后续操作，被调用者通过状体来通知调用者，或者通过回掉函数来处理这个调用。

**示例：**

前提导入spring web相关依赖包

1.定义Service层

定义Service层，一个普通的方法，一个由@Async注释的方法

CommonService.class

@Service

public class CommonService \{

public  void serviceTest() \{

Arrays.stream(new int\[\]\{1,2,3,4,5,6,7,8,9,10\}).forEach( t -> \{

try \{

Thread.sleep(500);

\} catch (InterruptedException e) \{

e.printStackTrace();

System.out.println("获取number为：" + t);

\});

AsyncService.class

@Service

@EnableAsync

public class AsyncService \{

@Async

public  void serviceTest() \{

Arrays.stream(new int\[\]\{10,9,8,7,6,5,4,3,2,1\}).forEach(t -> \{

try \{

Thread.sleep(500);

\} catch (InterruptedException e) \{

e.printStackTrace();

System.out.println("获取number为：" + t);

\});

2.定义controller层

通用Controller

@RestController

public class CommonController \{

@Autowired

private CommonService commonService;

@GetMapping("/sync")

public String sync() \{

System.out.println("获取主线程名称："+ Thread.currentThread().getName());

commonService.serviceTest();

System.out.println("执行成功，返回结果");

return "sync";

访问该http接口，结果如下：

获取主线程名称：http-nio-9101-exec-2

获取number为：1

获取number为：2

获取number为：3

获取number为：4

获取number为：5

获取number为：6

获取number为：7

获取number为：8

获取number为：9

获取number为：10

执行成功，返回结果

浏览器会等待大约5s才会返回结果

异步执行的Controller

@RestController

public class AsyncController \{

@Autowired

private AsyncService asyncService;

@Autowired

private CommonService commonService;

@GetMapping("/threadPool")

public String threadPool()\{

System.out.println("获取主线程名称："+ Thread.currentThread().getName());

ThreadPoolExecutor executor = new ThreadPoolExecutor(1, 5, 5000, TimeUnit.MILLISECONDS, new LinkedBlockingDeque<>());

executor.execute(() -> commonService.serviceTest());

System.out.println("执行成功，返回结果");

return "thread pool";

@GetMapping("/async")

public String async()\{

System.out.println("获取主线程名称："+ Thread.currentThread().getName());

asyncService.serviceTest();

System.out.println("执行成功，返回结果");

return "async";

访问以上两个接口返回结果如下：

获取主线程名称：http-nio-9101-exec-4

执行成功，返回结果

获取number为：1

获取number为：2

获取number为：3

获取number为：4

获取number为：5

获取number为：6

获取number为：7

获取number为：8

获取number为：9

获取number为：10

浏览器立刻返回结果

使用@Async非常简单方便的开启了异步执行的功能

@Async和@EnableAsync详细理解

**@Async**注释bean 的方法将使其在单独的线程中执行

**@EnableAsync**  注释Java 配置启用异步处理

使用@Async的两个限制条件

1. 它只能使用在公用的方法(被public修饰的)

2. 从同一个类中调用异步方法将不起作用。

原因是：该方法需要是公开的， 以便它可以被代理。并且自调用不起作用，因为它绕过代理并直接调用底层方法。

@Async未指定执行的线程池，默认情况下，Spring 使用SimpleAsyncTaskExecutor来实际异步运行这些方法。但是有两个可以覆盖默认执行的线程池

方法1：在方法级别覆盖Executor

直接在方法注释@Async指定执行的线程池threadPoolTaskExecutor

@Async("threadPoolTaskExecutor")

public void asyncMethodWithConfiguredExecutor() \{

System.out.println("Execute method with configured executor - "

+ Thread.currentThread().getName());

方法2： 在应用级别覆盖Executor

需要实现AsyncConfigurer接口，并返回异步执行的线程池

@Configuration

@EnableAsync

public class SpringAsyncConfig implements AsyncConfigurer \{

@Override

public Executor getAsyncExecutor() \{

return new ThreadPoolTaskExecutor();

Spring @Async和@EnableAsync详细理解

发表评论取消回复

还没有评论，来说两句吧...

相关阅读

相关 Spring异步注解@Async,@EnableAsync底层源码分析

相关异步处理请求@EnableAsync与@Async

相关 @EnableAsync@Async多线程异步执行

相关 spring boot- @EnableAsync和@Async（Spring boot 注解@Async不生效无效不起作用）

相关 Spring Boot 微服务异步调用 @EnableAsync @Async

相关初识@EnableAsync @Async

相关 Spring @Async和@EnableAsync详细理解

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

相关 Springboot使用@EnableAsync @Async实现异步调用——SpringBoot学习

相关 SpringBoot EnableAsync无效 Async注解不异步