最近在做訂單模塊，用戶購買服務類產品之后，需要進行預約，預約成功之后分別給商家和用戶發送提醒短信。考慮發短信耗時的情況所以我想用異步的方法去執行，於是就在網上看見了Spring的@Async了。
但是遇到了許多問題，使得@Async無效，也一直沒有找到很好的文章去詳細的說明@Async的正確及錯誤的使用方法及需要注意的地方，這里簡單整理了一下遇見的問題，Sring是以配置文件的形式來開啟@Async，而SpringBoot則是以注解的方式開啟。
我們可以使用springBoot默認的線程池，不過一般我們會自定義線程池（因為比較靈活），配置方式有：
- 使用 xml 文件配置的方式
- 使用Java代碼結合@Configuration進行配置（推薦使用）
下面分別實現兩種配置方式
第一步、配置@Async
一、springBoot啟動類的配置：
在Spring Boot的主程序中配置@EnableAsync，如下所示：
二、Spring XML的配置方式：
1.applicationContext.xml同目錄下創建文件threadPool.xml文件：
2.然后在applicationContext.xml中引入threadPool.xml：<import resource="threadPool.xml" />
第二步：創建兩個異步方法的類，如下所示:
第一個類（這里模擬取消訂單后發短信，有兩個發送短信的方法）：
第二個類。調用發短信的方法 （異步方法不能與被調用的異步方法在同一個類中，否則無效）：
經過測試得到如下結果：
1.沒有使用@Async
2.使用了@Async
可以看出，沒有使用@Async方式實現的發送短信是同步執行的，意思就是說第一條發送之后再發送第二條，第二條發送成功之后再給用戶提示，這樣顯然會影響用戶體驗，再看使用了@Async實現的，在執行第一個發送短信方法之后馬上開啟另一個線程執行第二個方法，顯然這樣我們的處理速度回快很多。
使用Java代碼結合@Configuration注解的配置方式（推薦使用）
1. 新建一個配置類
package com.boot.common.conf;
import java.util.concurrent.ThreadPoolExecutor;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.annotation.EnableAsync;
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
/**
* 線程池配置
*@authorzhh
*
*/
@Configuration
@EnableAsync
public classThreadPoolTaskConfig{
/**
* 默認情況下，在創建了線程池后，線程池中的線程數為0，當有任務來之后，就會創建一個線程去執行任務，
* 當線程池中的線程數目達到corePoolSize后，就會把到達的任務放到緩存隊列當中；
* 當隊列滿了，就繼續創建線程，當線程數量大於等於maxPoolSize后，開始使用拒絕策略拒絕
*/
/** 核心線程數（默認線程數） */
private static final int corePoolSize = 20;
/** 最大線程數 */
private static final int maxPoolSize = 100;
/** 允許線程空閑時間（單位：默認為秒） */
private static final int keepAliveTime = 10;
/** 緩沖隊列大小 */
private static final int queueCapacity = 200;
/** 線程池名前綴 */
private static final String threadNamePrefix = "Async-Service-";
@Bean("taskExecutor") // bean的名稱，默認為首字母小寫的方法名
publicThreadPoolTaskExecutortaskExecutor(){
ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
executor.setCorePoolSize(corePoolSize);
executor.setMaxPoolSize(maxPoolSize);
executor.setQueueCapacity(queueCapacity);
executor.setKeepAliveSeconds(keepAliveTime);
executor.setThreadNamePrefix(threadNamePrefix);
// 線程池對拒絕任務的處理策略
// CallerRunsPolicy：由調用線程（提交任務的線程）處理該任務
executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
// 初始化
executor.initialize();
return executor;
}
}
2.創建兩個異步方法的類（和之前的類類似僅僅是方法上注解不一樣），如下所示:
第一個類（這里模擬取消訂單后發短信，有兩個發送短信的方法）：
代碼中的 @Async("taskExecutor") 對應我們自定義線程池中的 @Bean("taskExecutor") ，表示使用我們自定義的線程池。
第二個類。調用發短信的方法 （異步方法不能與被調用的異步方法在同一個類中，否則無效）：
運行截圖：
注意看，截圖中的 [nio-8090-exec-1] 是Tomcat的線程名稱
[Async-Service-1]、[Async-Service-2]表示線程1和線程2 ，是我們自定義的線程池里面的線程名稱，我們在配置類里面定義的線程池前綴：
private static final String threadNamePrefix = "Async-Service-"; // 線程池名前綴，說明我們自定義的線程池被使用了。
注意事項
如下方式會使@Async失效
- 異步方法使用static修飾
- 異步類沒有使用@Component注解（或其他注解）導致spring無法掃描到異步類
- 異步方法不能與被調用的異步方法在同一個類中
- 類中需要使用@Autowired或@Resource等注解自動注入，不能自己手動new對象
- 如果使用SpringBoot框架必須在啟動類中增加@EnableAsync注解