使用@Async實現(xiàn)異步調(diào)用
什么是”異步調(diào)用”與”同步調(diào)用”
“同步調(diào)用”就是程序按照一定的順序依次執(zhí)行,,每一行程序代碼必須等上一行代碼執(zhí)行完畢才能執(zhí)行;”異步調(diào)用”則是只要上一行代碼執(zhí)行,無需等待結(jié)果的返回就開始執(zhí)行本身任務(wù)。
通常情況下,”同步調(diào)用”執(zhí)行程序所花費的時間比較多,執(zhí)行效率比較差。所以,在代碼本身不存在依賴關(guān)系的話,我們可以考慮通過”異步調(diào)用”的方式來并發(fā)執(zhí)行。
“異步調(diào)用”
在 spring boot 框架中,只要提過@Async注解就能獎普通的同步任務(wù)改為異步調(diào)用任務(wù)。
注意: @Async所修飾的函數(shù)不要定義為static類型,這樣異步調(diào)用不會生效
1. 開啟@Async注解
在Spring Boot主類添加@EnableAsync注解
2. 定義異步任務(wù)
定義Task類,創(chuàng)建三個處理函數(shù)分別模擬三個執(zhí)行任務(wù)的操作,操作消耗時間隨機取(10秒內(nèi))。
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
|
@Component public class Task { //定義一個隨機對象. public static Random random = new Random(); @Async //加入"異步調(diào)用"注解 public void doTaskOne() throws InterruptedException { System.out.println( "開始執(zhí)行任務(wù)一" ); long start = System.currentTimeMillis(); Thread.sleep(random.nextInt( 10000 )); long end = System.currentTimeMillis(); System.out.println( "完成任務(wù)一,耗時:" + (end - start) + "毫秒" ); } @Async public void doTaskTwo() throws InterruptedException { System.out.println( "開始執(zhí)行任務(wù)二" ); long start = System.currentTimeMillis(); Thread.sleep(random.nextInt( 10000 )); long end = System.currentTimeMillis(); System.out.println( "完成任務(wù)二,耗時:" + (end - start) + "毫秒" ); } @Async public void doTaaskThree() throws InterruptedException { System.out.println( "開始執(zhí)行任務(wù)三" ); long start = System.currentTimeMillis(); Thread.sleep(random.nextInt( 10000 )); long end = System.currentTimeMillis(); System.out.println( "完成任務(wù)三,耗時:" + (end - start) + "毫秒" ); } } |
3. 創(chuàng)建Controller進行測試
注意@Autowired注入類,因為這個類已經(jīng)被 Spring 管理了。如果使用 new 來獲得線程類將不會執(zhí)行異步效果,這里涉及到在 Spring 中使用多線程。
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
|
@Controller public class TaskController { @Autowired private Task TASK; @ResponseBody @RequestMapping ( "/task" ) public String task() throws Exception { System.out.println( "開始執(zhí)行Controller任務(wù)" ); long start = System.currentTimeMillis(); TASK.doTaskOne(); TASK.doTaskTwo(); TASK.doTaaskThree(); long end = System.currentTimeMillis(); System.out.println( "完成Controller任務(wù),耗時:" + (end - start) + "毫秒" ); return "success" ; } } |
4. 多次調(diào)用
訪問 http://localhost:8080/task 截圖:
項目參考地址: https://github.com/FunriLy/springboot-study/tree/master/%E6%A1%88%E4%BE%8B7
以上就是本文的全部內(nèi)容,希望對大家的學(xué)習(xí)有所幫助,也希望大家多多支持服務(wù)器之家。
原文鏈接:http://blog.csdn.net/u011244202/article/details/54864528