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 {
// 同上內容，省略
}
}@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秒後再判斷。
- 跳出迴圈之後，根據結束時間 - 開始時間，計算出三個任務併發執行的總耗時。