使用@Async實(shí)現(xiàn)異步調(diào)用

什么是”異步調(diào)用”與”同步調(diào)用”

“同步調(diào)用”就是程序按照一定的順序依次執(zhí)行，，每一行程序代碼必須等上一行代碼執(zhí)行完畢才能執(zhí)行；”異步調(diào)用”則是只要上一行代碼執(zhí)行，無需等待結(jié)果的返回就開始執(zhí)行本身任務(wù)。

通常情況下，”同步調(diào)用”執(zhí)行程序所花費(fèi)的時間比較多，執(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ù)的操作，操作消耗時間隨機(jī)取(10秒內(nèi))。

@Component

public class Task {

//定義一個隨機(jī)對象.

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進(jìn)行測試

注意@Autowired注入類，因?yàn)檫@個類已經(jīng)被 Spring 管理了。如果使用 new 來獲得線程類將不會執(zhí)行異步效果，這里涉及到在 Spring 中使用多線程。

@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 截圖:

項(xiàng)目參考地址: https://github.com/FunriLy/springboot-study/tree/master/%E6%A1%88%E4%BE%8B7

以上就是本文的全部內(nèi)容，希望對大家的學(xué)習(xí)有所幫助，也希望大家多多支持聚米學(xué)院。

總結(jié)

以上是生活随笔為你收集整理的springboot 异步mysql_spring boot 使用@Async实现异步调用方法的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。