Spring Boot學習(十二)之Spring Boot使用@Async實現非同步呼叫
阿新 • • 發佈:2019-02-03
什麼是“非同步呼叫”?“非同步呼叫”對應的是“同步呼叫”,同步呼叫指程式按照定義順序依次執行,每一行程式都必須等待上一行程式執行完成之後才能執行;非同步呼叫指程式在順序執行時,不等待非同步呼叫的語句返回結果就執行後面的程式。同步呼叫下面通過一個簡單示例來直觀的理解什麼是同步呼叫:
- 定義Task類,建立三個處理函式分別模擬三個執行任務的操作,操作消耗時間隨機取(10秒內)
@Component public class Task { public static Random random =new Random(); public void doTaskOne() throws Exception { System.out.println("開始做任務一"); long start = System.currentTimeMillis(); Thread.sleep(random.nextInt(10000)); long end = System.currentTimeMillis(); System.out.println("完成任務一,耗時:" + (end - start) + "毫秒"); } public void doTaskTwo() throws Exception { System.out.println("開始做任務二"); long start = System.currentTimeMillis(); Thread.sleep(random.nextInt(10000)); long end = System.currentTimeMillis(); System.out.println("完成任務二,耗時:" + (end - start) + "毫秒"); } public void doTaskThree() throws Exception { System.out.println("開始做任務三"); long start = System.currentTimeMillis(); Thread.sleep(random.nextInt(10000)); long end = System.currentTimeMillis(); System.out.println("完成任務三,耗時:" + (end - start) + "毫秒"); } }
- 在單元測試用例中,注入Task物件,並在測試用例中執行doTaskOne、doTaskTwo、doTaskThree三個函式。
@RunWith(SpringJUnit4ClassRunner.class) @SpringApplicationConfiguration(classes = Application.class) public class ApplicationTests { @Autowired private Task task; @Test public void test() throws Exception { task.doTaskOne(); task.doTaskTwo(); task.doTaskThree(); } }
- 執行單元測試,可以看到類似如下輸出:
@Component
public class Task {
@Async
public void doTaskOne() throws Exception {
// 同上內容,省略
}
@Async
public void doTaskTwo() throws Exception {
// 同上內容,省略
}
@Async
public void doTaskThree() throws Exception {
// 同上內容,省略
}
}
為了讓@Async註解能夠生效,還需要在Spring Boot的主程式中配置@EnableAsync,如下所示:@SpringBootApplication
@EnableAsync
public class Application {
public static void main(String[] args) {
SpringApplication.run(Application.class, args);
}
}
此時可以反覆執行單元測試,您可能會遇到各種不同的結果,比如:- 沒有任何任務相關的輸出
- 有部分任務相關的輸出
- 亂序的任務相關的輸出
@Async
public Future<String> doTaskOne() throws Exception {
System.out.println("開始做任務一");
long start = System.currentTimeMillis();
Thread.sleep(random.nextInt(10000));
long end = System.currentTimeMillis();
System.out.println("完成任務一,耗時:" + (end - start) + "毫秒");
return new AsyncResult<>("任務一完成");
}
按照如上方式改造一下其他兩個非同步函式之後,下面我們改造一下測試用例,讓測試在等待完成三個非同步呼叫之後來做一些其他事情。@Test
public void test() throws Exception {
long start = System.currentTimeMillis();
Future<String> task1 = task.doTaskOne();
Future<String> task2 = task.doTaskTwo();
Future<String> task3 = task.doTaskThree();
while(true) {
if(task1.isDone() && task2.isDone() && task3.isDone()) {
// 三個任務都呼叫完成,退出迴圈等待
break;
}
Thread.sleep(1000);
}
long end = System.currentTimeMillis();
System.out.println("任務全部完成,總耗時:" + (end - start) + "毫秒");
}
看看我們做了哪些改變:- 在測試用例一開始記錄開始時間
- 在呼叫三個非同步函式的時候,返回Future<String>型別的結果物件
- 在呼叫完三個非同步函式之後,開啟一個迴圈,根據返回的Future<String>物件來判斷三個非同步函式是否都結束了。若都結束,就結束迴圈;若沒有都結束,就等1秒後再判斷。
- 跳出迴圈之後,根據結束時間 - 開始時間,計算出三個任務併發執行的總耗時。