快捷導(dǎo)航

一次java異步任務(wù)的實(shí)戰(zhàn)記錄

更新時(shí)間：2022年05月12日 12:33:13 作者：再見丶孫悟空

最近做項(xiàng)目的時(shí)候遇到了一個(gè)小問(wèn)題,從前臺(tái)提交到服務(wù)端A,A調(diào)用服務(wù)端B處理超時(shí),下面這篇文章主要給大家介紹了一次java異步任務(wù)的實(shí)戰(zhàn)記錄,需要的朋友可以參考下

前言

最近在開發(fā)中遇到一個(gè)埋點(diǎn)的需求，考慮到不能影響原有業(yè)務(wù)邏輯，于是準(zhǔn)備寫一個(gè)異步任務(wù)去異步執(zhí)行，但在 debug 的過(guò)程中卻發(fā)現(xiàn)了一個(gè)奇怪的問(wèn)題。

一、什么是異步任務(wù)

無(wú)論是生活中還是程序里，大體可以分為兩種：同步和異步。

同步：比如你去吃海底撈，你要先點(diǎn)鍋底，再點(diǎn)菜，然后服務(wù)員上鍋底，再上菜，最后你才能吃上菜，這一過(guò)程得按順序來(lái)。

異步任務(wù)：還是去吃海底撈，吃的人很多，你前面有很多人，你可能要排隊(duì)，等到排到你才能再進(jìn)入餐廳。但是如果中途你想去個(gè)廁所，怎么辦，回來(lái)還得重新排隊(duì)。于是就有了叫號(hào)，你先排隊(duì)取號(hào)，然后你可以去按個(gè)摩，看個(gè)電影，做個(gè) spa ，買杯奶茶 .... 。終于到你了，這時(shí)候會(huì) 通知你排到了，然后你就能進(jìn)去了。這個(gè)過(guò)程便是異步的。

二、SpringBoot + Async

一開始想著開一個(gè)線程池，把任務(wù)丟線程池里去完成。

后來(lái)想起來(lái) SpringBoot 有一個(gè)比較方便的異步框架 Async

代碼也很簡(jiǎn)單，只需要在需要異步執(zhí)行的方法上加個(gè) @Async ，SpringBoot 啟動(dòng)類上添加 @EnableAsync 即可

    @Async
    public void task() {
        // do something
    }

三、踩坑日記

代碼雖然少，但是坑可不會(huì)隨著代碼量的減少而減少。

為了方便起見，我本地搭了個(gè) demo，直接上代碼

@RestController
public class AsyncController {
    @Autowired
    private AsyncService asyncService;

    @GetMapping("/v1/say")
    public String sayV1() {
        asyncService.sayV1();
        return "success1";
    }

    @GetMapping("/v2/say")
    public String sayV2() {
        asyncService.sayV2();
        return "success2";
    }
}

@Service
public class AsyncService {
    public void sayV1() {
        try {
            Thread.sleep(3000L);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println("hello world");
    }

    @Async
    public void sayV2() {
        try {
            Thread.sleep(3000L);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println("hello world");
    }
}

很簡(jiǎn)單的 demo，提供兩個(gè)接口，/v1/say 和 /v2/say，一個(gè)同步執(zhí)行，一個(gè)異步執(zhí)行，通過(guò) sleep 3 秒來(lái)模擬耗時(shí)的任務(wù)

正常啟動(dòng)，沒(méi)有任何問(wèn)題，同步執(zhí)行的等 3 秒，主線程才會(huì)返回，異步執(zhí)行的立刻返回，等3 秒才會(huì)輸出 helloworld

但是，當(dāng)我加上斷點(diǎn)后，問(wèn)題產(chǎn)生了。

我先是在打印 hello world 那行加上個(gè)斷點(diǎn)，效果和原來(lái)的一樣，只是打印前被阻塞了，但并不影響主線程的返回。