當(dāng)我們?cè)谡{(diào)用某些耗時(shí)的方法,比如發(fā)起第三方調(diào)用時(shí)而不關(guān)心他的返回值闹击,可以采用@Async來(lái)實(shí)現(xiàn)異步調(diào)用。極大的提升程序的響應(yīng)速度。
在以往的編程方法中我們一般都是開(kāi)啟另一個(gè)線程去處理類似的場(chǎng)景国葬,而在Spring 3.x之后則可以使用@Async。
@Target({ElementType.METHOD, ElementType.TYPE})
@Retention(RetentionPolicy.RUNTIME)
@Documented
public @interface Async {
String value() default "";
}
可以看到@Async可以修飾在方法和類上芹壕。當(dāng)修飾方法時(shí)汇四,該方法則成為異步方法,這些方法在執(zhí)行的時(shí)候?qū)?huì)被獨(dú)立的線程去執(zhí)行踢涌。
在Spring和Spring Boot中啟用@Async
在啟動(dòng)類上添加注解:@EnableAsync
在相應(yīng)的方法上添加注解:@Async
需要處理返回值
如果在使用了@Async的方法時(shí)還需要處理它的返回值通孽,那么需要用到Future
類。
@Async
public Future<String> asyncMethodWithReturnType() {
System.out.println("Execute method asynchronously - "
+ Thread.currentThread().getName());
try {
Thread.sleep(5000);
return new AsyncResult<String>("hello world !!!!");
} catch (InterruptedException e) {
//
}
return null;
}
以上是異步方法睁壁,調(diào)用該方法時(shí)應(yīng)該以如下方式調(diào)用:
public void testAsyncAnnotationForMethodsWithReturnType()
throws InterruptedException, ExecutionException {
System.out.println("Invoking an asynchronous method. "
+ Thread.currentThread().getName());
Future<String> future = asyncAnnotationExample.asyncMethodWithReturnType();
while (true) { ///這里使用了循環(huán)判斷背苦,等待獲取結(jié)果信息
if (future.isDone()) { //判斷是否執(zhí)行完畢
System.out.println("Result from asynchronous process - " + future.get());
break;
}
System.out.println("Continue doing something else. ");
Thread.sleep(1000);
}
}
通過(guò)while true
來(lái)循環(huán)判斷異步方法是否正常返回,但是這樣的代碼在正常情況下完全沒(méi)有必要性潘明,不如直接寫成同步調(diào)用行剂。
異常處理
在異步方法中,如果出現(xiàn)了異常钳降,對(duì)于調(diào)用者而言是無(wú)法感知的厚宰。如果確實(shí)需要處理異常,則需要自定義實(shí)現(xiàn)AsyncTaskExecutor遂填。
事務(wù)處理
如果想要在異步方法中實(shí)現(xiàn)事務(wù)铲觉,則需要把需要事務(wù)管理的方法放到異步方法內(nèi)部,在內(nèi)部被調(diào)用的方法上添加@Transactional城菊。
例如:方法A备燃,使用了@Async/@Transactional來(lái)修飾,但是無(wú)法達(dá)到事務(wù)控制的目的凌唬。
方法B并齐,使用了@Async修飾,B中調(diào)用了C客税、D况褪,C/D分別使用@Transactional來(lái)修飾,可以達(dá)到事務(wù)控制的目的更耻。
我的博客即將同步至騰訊云+社區(qū)测垛,邀請(qǐng)大家一同入駐:https://cloud.tencent.com/developer/support-plan?invite_code=2djokz1ijr38