不仅会用@Async，我把源码也梳理了一遍（上）

说起异步化，很多人会想起异步线程、消息队列等，消息队列不是文章的主题，今天我们来聊聊spring对异步化的支持@EnableAsync&@Async。

我会分为以下几个步骤去说明，首先说说用法，然后再从源码层分析@Async的底层原理，同学们准备好了吗？

@Async用法

想要开启异步化，我们就必须要用用到@EnableAsync注解，这又是我们之前给大家说个的@EnableXXX的模块，大家可以回顾一下：《导图梳理springboot手动、自动装配，让springboot不再难懂》，配置类中开启了@EnableAsync之后，@Async的注解就开始起作用了，我们先来做个简单的测试：

配置类

• com.example.demo.config.AsyncConfig

1. @EnableAsync

2. @Configuration

3. public class AsyncConfig {

4. }

一个页面控制器

• com.example.demo.controller.AsyncController

1. @Slf4j

2. @RestController

3. public class AsyncController {

4. @Autowired

5. UserService userService;

6. @GetMapping("/tt")

7. public Object tt() throws InterruptedException {

8. String username = userService.findUserNameById(1L);

9. log.info("AsyncController----------->" + Thread.currentThread().getName());

10. log.info("username---------------->" + username);

11. return username;

12. }

13. }

然后就是业务类

• com.example.demo.service.impl.UserServiceImpl

1. @Slf4j

2. @Service

3. public class UserServiceImpl implements UserService {

4. @Async

5. public String findUserNameById(Long id) {

6. log.info("UserServiceImpl----------->" + Thread.currentThread().getName());

7. return "关注公众号：java思维导图";

8. }

9. }

好了，最简单的用法已经完成了，我在UserServiceImpl#findUserNameById方法上添加了@Async注解，表示此方法是个异步方法。我们先来看看执行结果，然后再来说说上面的程序有什么问题。

控制台输出： 

可以看出，两个方法执行的线程是不一样的，明显UserServiceImpl的findUserNameById方法是另起了一个线程task-1执行。

这里我们注意到了一个问题，controller中我们获取不到了异步方法的返回值username了。所以想要获取@Async注解之后的异步方法就不能使用这种方式了，所以我们改下程序：

service中新添加个方法：

1. @Async

2. public Future<String> findLastNameById(Long id) {

3. log.info("UserServiceImpl----------->" + Thread.currentThread().getName());

4. return new AsyncResult<String>("关注公众号：java思维导图");

5. }

然后controller改成这样：

1. @GetMapping("/tt")

2. public Object tt() throws InterruptedException, ExecutionException {

3. String username = userService.findUserNameById(1L);

4. log.info("AsyncController----------->" + Thread.currentThread().getName());

5. log.info("username---------------->" + username);

6. Future<String> future = userService.findLastNameById(1L);

7. String lastname = future.get();

8. log.info("lastname---------------->" + lastname + Thread.currentThread().getName());

9. return username;

10. }

测试结果如下： 

 可以看到task-1获取不到结果，task-2获取到结果了，但是这里有个问题，为了获取异步的结果，线程http-nio-8080-exec-1一直在等待future.get()的返回结果，才继续往下走，这就有点影响主线程的性能了。

那如果异步方法出现了异常，我们怎么去捕捉呢，一般全局异常处理我们都是处理controller中的异常，但这个异步线程的异常能不能捕捉到都是个问题。其实，对于@Async的异常，是可以配置的。AsyncConfig中我们可以继承一个AsyncConfigurer，然后重写两个方法：

• com.example.demo.config.AsyncConfig

1. @EnableAsync

2. @Configuration

3. public class AsyncConfig implements AsyncConfigurer {

4. @Override

5. public Executor getAsyncExecutor() {

6. //线程池

7. ThreadPoolTaskExecutor taskExecutor = new ThreadPoolTaskExecutor();

8. taskExecutor.setCorePoolSize(5);

9. taskExecutor.setMaxPoolSize(10);

10. taskExecutor.setQueueCapacity(25);

11. taskExecutor.initialize();

12. return taskExecutor;

13. }

14. @Override

15. public AsyncUncaughtExceptionHandler getAsyncUncaughtExceptionHandler() {

16. return new SimpleAsyncUncaughtExceptionHandler();

17. }

18. }

一个定义线程池，一个定义异常处理器，线程池我们就不说了，这个默认的SimpleAsyncUncaughtExceptionHandler没啥东西：

1. public class SimpleAsyncUncaughtExceptionHandler implements AsyncUncaughtExceptionHandler {

2. private static final Log logger = LogFactory.getLog(SimpleAsyncUncaughtExceptionHandler.class);

3. @Override

4. public void handleUncaughtException(Throwable ex, Method method, Object... params) {

5. if (logger.isErrorEnabled()) {

6. logger.error("Unexpected exception occurred invoking async method: " + method, ex);

7. }

8. }

9. }

所以如果我们想自己处理这个出现异常之后的逻辑，还得重写AsyncUncaughtExceptionHandler 的handleUncaughtException接口，里面有method、params等参数，可以进行重试、或者其他处理等。

异步化原理

好吧，下一篇再写了，今天先到这里，下午还有点事~

待续~

结束语

坚持原创的第三篇（20190920），打卡打卡。希望你们会喜欢。

我是吕一明，欢迎关注我的公众号：java思维导图

做个小调查：

留言区留言：你们公司是用什么方式实现异步处理业务的？

- 精选文章 -

（java思维导图）

长按关注，每天java一下，成就架构师

我就知道你在看！