Springboot中的@EnableAsync和@Async的作用和用法

参考https://blog.csdn.net/qq_38796327/article/details/90599867

日常开发中，我们偶尔会遇到在业务层中我们需要同时执行多个数据操作任务，如果我们用往常的同步的方式，也就是单线程的方式来执行的话，可能会出现执行超时等异常造成请求结果失败，及时成功，前端也需要等待较长时间来获取响应结果，这样不但造成了用户体验差，而且会经常出现请求执行失败的问题。

我们来观察一下使用同步的方式实现的结果：

1.我们定义一个TestController,如下所示：

@RestController
public class TestController {
@Autowired
private TestService service;
/**
* 使用传统方式测试
*/
@GetMapping("/test")
public void test() {
System.out.println("获取主线程名称：" + Thread.currentThread().getName());
service.serviceTest();
System.out.println("执行成功，返回结果");
}
}

2. 我们定义TestService,如下所示：

@Service
public class TestAsyncService {
public void serviceTest() {
// 这里执行实际的业务逻辑，在这里我们就是用一个简单的遍历来模拟
Arrays.stream(new int[]{1,2,3,4,5,6,7,8,9,10}).forEach( t -> {
try {
Thread.sleep(100);
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println("获取number为:" + t) ;
});
}
}

我们执行请求http://localhost:8888/test，结果显示如下：

Springboot中的@EnableAsync和@Async的作用和用法

接下来我们采用我们所说的多线程方式来实现：

1.使用线程池的方式来实现

.（1）定义TestAsyncController中的test()方法，如下所示：

@RestController
public class TestAsyncController {
@Autowired
private TestAsyncService asyncService;
/**
* 使用传统方式测试
*/
@GetMapping("/test")
public void test() {
System.out.println("获取主线程名称：" + Thread.currentThread().getName());
/**
* 这里也可以采用以下方式使用，但是使用线程池的方式可以很便捷的对线程管理（提高程序的整体性能），
* 也可以减少每次执行该请求时都需要创建一个线程造成的性能消耗
* new Thread(() ->{
* run方法中的业务逻辑
* })
*/
/**
* 定义一个线程池
* 核心线程数（corePoolSize）:1
* 最大线程数（maximumPoolSize）: 1
* 保持连接时间（keepAliveTime）：50000
* 时间单位 (TimeUnit):TimeUnit.MILLISECONDS(毫秒)
* 阻塞队列 new LinkedBlockingQueue<Runnable>()
*/
ThreadPoolExecutor executor = new ThreadPoolExecutor(1,5,50000, TimeUnit.MILLISECONDS, new LinkedBlockingQueue<Runnable>());
// 执行业务逻辑方法serviceTest()
executor.execute(new Runnable() {
@Override
public void run() {
asyncService.serviceTest();
}
});
System.out.println("执行完成，向用户响应成功信息");
}
}

（2）.定义TestAsyncService和TestService中的test()相同，在这就不显示了；

（3）.查看运行结果：

Springboot中的@EnableAsync和@Async的作用和用法

我们发现在主线程中使用线程池中的线程来实现，程序的执行结果表明，主线程直接将结果进行了返回，然后才是线程池在执行业务逻辑，减少了请求响应时长。

2. 使用注解@EnableAsync和@Async来实现

（1）。虽然这样实现了我们想要的结果，但是，但是我们发现如果我们在多个请求中都需要这种异步请求，每次都写这么冗余的线程池配置会不会，这种问题当然会被我们强大的spring所观察到，所以spring为了提升开发人员的开发效率，使用@EnableAsync来开启异步的支持，使用@Async来对某个方法进行异步执行。TestAsyncController如下所示：

@RestController
public class TestAsyncController {
@Autowired
private TestAsyncService asyncService;
/**
* 使用@Async来实现
*/
@GetMapping("/test")
public void test() {
System.out.println("获取主线程名称：" + Thread.currentThread().getName());
// 异步调用
asyncService.serviceTest();
System.out.println("执行完成，向用户响应成功信息");
}

（2）TestAsyncService如下所示（多线程定时任务也就参考这样）：

@Service
@EnableAsync
public class TestAsyncService {
/**
* 采用异步执行
*/
@Async
public void serviceTest() {
// 这里执行实际的业务逻辑，在这里我们就是用一个简单的遍历来模拟
Arrays.stream(new int[]{1,2,3,4,5,6,7,8,9,10}).forEach( t -> {
try {
Thread.sleep(100);
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println("获取number为:" + t) ;
});
}

（3）执行结果如下：

Springboot中的@EnableAsync和@Async的作用和用法

结果与使用线程池的结果一致，但是简化了我们编写代码的逻辑，@Async注解帮我们实现了创建线程池的繁琐，提高了我们的开发效率。