日本黄色一级经典视频|伊人久久精品视频|亚洲黄色色周成人视频九九九|av免费网址黄色小短片|黄色Av无码亚洲成年人|亚洲1区2区3区无码|真人黄片免费观看|无码一级小说欧美日免费三级|日韩中文字幕91在线看|精品久久久无码中文字幕边打电话

當前位置:首頁 > 單片機 > 架構師社區(qū)
[導讀]異步調用幾乎是處理高并發(fā)Web應用性能問題的萬金油,那么什么是“異步調用”?“異步調用”對應的是“同步調用”,同步調用指程序按照定義順序依次執(zhí)行,每一行程序都必須等待上一行程序執(zhí)行完成之后才能執(zhí)行;異步調用指程序在順序執(zhí)行時,不等待異步調用的語句返回結果就執(zhí)行后面的程序。同步調用...

異步調用幾乎是處理高并發(fā)Web應用性能問題的萬金油,那么什么是“異步調用”?

“異步調用”對應的是“同步調用”,同步調用指程序按照定義順序依次執(zhí)行,每一行程序都必須等待上一行程序執(zhí)行完成之后才能執(zhí)行;異步調用指程序在順序執(zhí)行時,不等待異步調用的語句返回結果就執(zhí)行后面的程序。

同步調用

下面通過一個簡單示例來直觀的理解什么是同步調用:

定義Task類,創(chuàng)建三個處理函數分別模擬三個執(zhí)行任務的操作,操作消耗時間隨機?。?0秒內)

@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對象,并在測試用例中執(zhí)行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();
????}
?
}
執(zhí)行單元測試,可以看到類似如下輸出:

開始做任務一
完成任務一,耗時:4256毫秒
開始做任務二
完成任務二,耗時:4957毫秒
開始做任務三
完成任務三,耗時:7173毫秒
任務一、任務二、任務三順序的執(zhí)行完了,換言之doTaskOne、doTaskTwo、doTaskThree三個函數順序的執(zhí)行完成。

異步調用

上述的同步調用雖然順利的執(zhí)行完了三個任務,但是可以看到執(zhí)行時間比較長,若這三個任務本身之間不存在依賴關系,可以并發(fā)執(zhí)行的話,同步調用在執(zhí)行效率方面就比較差,可以考慮通過異步調用的方式來并發(fā)執(zhí)行。推薦:Java進階視頻資源

在Spring Boot中,我們只需要通過使用@Async注解就能簡單的將原來的同步函數變?yōu)楫惒胶瘮担琓ask類改在為如下模式:

@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);
????}
?
}
此時可以反復執(zhí)行單元測試,您可能會遇到各種不同的結果,比如:

  • 沒有任何任務相關的輸出
  • 有部分任務相關的輸出
  • 亂序的任務相關的輸出
原因是目前doTaskOne、doTaskTwo、doTaskThree三個函數的時候已經是異步執(zhí)行了。主程序在異步調用之后,主程序并不會理會這三個函數是否執(zhí)行完成了,由于沒有其他需要執(zhí)行的內容,所以程序就自動結束了,導致了不完整或是沒有輸出任務相關內容的情況。

注:@Async所修飾的函數不要定義為static類型,這樣異步調用不會生效

異步回調

為了讓doTaskOne、doTaskTwo、doTaskThree能正常結束,假設我們需要統(tǒng)計一下三個任務并發(fā)執(zhí)行共耗時多少,這就需要等到上述三個函數都完成調動之后記錄時間,并計算結果。

那么我們如何判斷上述三個異步調用是否已經執(zhí)行完成呢?我們需要使用Future來返回異步調用的結果,就像如下方式改造doTaskOne函數:

@Async
public?Future?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?task1?=?task.doTaskOne();
????Future?task2?=?task.doTaskTwo();
????Future?task3?=?task.doTaskThree();
?
????while(true)?{
????????if(task1.isDone()?
本站聲明: 本文章由作者或相關機構授權發(fā)布,目的在于傳遞更多信息,并不代表本站贊同其觀點,本站亦不保證或承諾內容真實性等。需要轉載請聯系該專欄作者,如若文章內容侵犯您的權益,請及時聯系本站刪除。
關閉