Spring里的Async注解實現異(yi)步操作
異步執行一般用來發送一些消息數據,數據一致(zhi)性不要求太(tai)高的(de)場景,對于spring來說,它把這個異步進行了封裝,使用一個注解就(jiu)可以實現。
用法
- 程序啟動時開啟
@EnableAsync注解 - 建立新的類型,建立
異步方法,為方法添加@Async注解 - 在業務代碼中,
@Autowired注入你的類型,使用它即可
我們(men)(men)可以關注(zhu)到在(zai)配(pei)置task的(de)(de)(de)時(shi)候,是有參數(shu)讓我們(men)(men)配(pei)置線程(cheng)池的(de)(de)(de)數(shu)量(liang)的(de)(de)(de)。因為這種實現(xian)方(fang)法(fa)(fa),所以在(zai)同一(yi)個類中的(de)(de)(de)方(fang)法(fa)(fa)調用,添加@async注(zhu)解是失(shi)效的(de)(de)(de)!,原因是當你在(zai)同一(yi)個類中的(de)(de)(de)時(shi)候,方(fang)法(fa)(fa)調用是在(zai)類體內執(zhi)行的(de)(de)(de),spring無法(fa)(fa)截獲這個方(fang)法(fa)(fa)調用.
Async幾種方式
- 沒有返回值的,不會阻塞主線程,相當于開啟新線程在后臺執行這個任務
@Async
public String sayHello2() throws InterruptedException {
Thread.sleep(2 * 1000);//網絡連接中 。。。消息發送中。。。
return "我愛你啊!";// 調用方調用后會立即返回,所以返回null
}
- 帶有返回值的,返回類型必須為Future<>,它會開啟新的線程執行任務,并阻塞主線程,執行完成后把結果返回給主線程
@Async
public Future<String> asyncFunc() throws InterruptedException {
int thinking = 2;
Thread.sleep(thinking * 1000);
System.out.println("async!");
return new AsyncResult<String>("發送消息用了" + thinking + "秒");
}
調用方法
@GetMapping("/lind-demo/asyncFunc")
public void async() throws Exception {
Future<String> future = null;
future = asyncService.asyncFunc();
System.out.println(future.get());
System.out.println("主線程被阻塞執行完成");
}
執行結果
async!
發送消息用了2秒
主線程執行完成