springboot的異步任務(wù):無(wú)返回值和有返回值問(wèn)題

更新時(shí)間：2023年07月20日 09:33:49 作者：kailly235

這篇文章主要介紹了springboot的異步任務(wù):無(wú)返回值和有返回值問(wèn)題，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教

springboot異步任務(wù):無(wú)返回值和有返回值

在想要異步執(zhí)行的方法上加上@Async注解，在controller上加上@EnableAsync，即可。

注：這里的異步方法，只能在本類之外調(diào)用，在本類調(diào)用是無(wú)效的。

無(wú)返回值的異步任務(wù)

service實(shí)現(xiàn)部分：

@Service
public class AsyncService {
? ? @Async //想要異步執(zhí)行的方法上加@Async 注解
? ? public void doNoReturn(){
? ? ? ? try {
? ? ? ? ? ? // 這個(gè)方法執(zhí)行需要三秒
? ? ? ? ? ? Thread.sleep(3000);
? ? ? ? ? ? System.out.println("方法執(zhí)行結(jié)束" + new Date());
? ? ? ? } catch (InterruptedException e) {
? ? ? ? ? ? e.printStackTrace();
? ? }
}

controller調(diào)用部分：

@RestController
@EnableAsync//調(diào)用異步任務(wù)的controller上加@EnableAsync注解
public class AsyncController {
? ? @Autowired
? ? private AsyncService asyncService;
? ? @RequestMapping(value = "/hello",method = RequestMethod.GET)
? ? public String testAsyncNoRetrun(){
? ? ? ? long start = System.currentTimeMillis();
? ? ? ? ?asyncService.doNoReturn();
? ? ? ? ?return String.format("任務(wù)執(zhí)行成功,耗時(shí){%s}", System.currentTimeMillis() - start);
? ? }

輸出：

任務(wù)執(zhí)行成功，耗時(shí){4}

可見(jiàn)testAsyncNoRetrun()方法中調(diào)用doNoReturn(),沒(méi)等doNoReturn（）執(zhí)行完即返回。

有返回值的異步任務(wù)

有返回值的異步任務(wù)方法需要用Futrue變量把返回值封裝起來(lái)。

service實(shí)現(xiàn)部分：

@Async
?public Future<String> doReturn(int i){
? ? ? ? try {
? ? ? ? ? ? // 這個(gè)方法需要調(diào)用500毫秒
? ? ? ? ? ? Thread.sleep(500);
? ? ? ? } catch (InterruptedException e) {
? ? ? ? ? ? e.printStackTrace();
? ? ? ? }
? ? ? ? // 消息匯總
? ? ? ? return new AsyncResult<>(String.format("這個(gè)是第{%s}個(gè)異步調(diào)用的證書(shū)", i));
}

讀取的時(shí)候要批量讀取不能單獨(dú)讀取。

controller調(diào)用部分：

@GetMapping("/hi")
? ? public Map<String, Object> testAsyncReturn() throws ExecutionException, InterruptedException {
? ? ? ? long start = System.currentTimeMillis();
? ? ? ? Map<String, Object> map = new HashMap<>();
? ? ? ? List<Future<String>> futures = new ArrayList<>();
? ? ? ? for (int i = 0; i < 10; i++) {
? ? ? ? ? ? Future<String> future = asyncService.doReturn(i);
? ? ? ? ? ? futures.add(future);
? ? ? ? }
? ? ? ? List<String> response = new ArrayList<>();
? ? ? ? for (Future future : futures) {
? ? ? ? ? ? String string = (String) future.get();
? ? ? ? ? ? response.add(string);
? ? ? ? }
? ? ? ? map.put("data", response);
? ? ? ? map.put("消耗時(shí)間", String.format("任務(wù)執(zhí)行成功,耗時(shí){%s}毫秒", System.currentTimeMillis() - start));
? ? ? ? return map;
}

在瀏覽器輸入地址:http://localhost:8080/hi

結(jié)果如下: 耗時(shí)500多毫秒的意思代表,springboot自帶異步任務(wù)線程池是小于10的大小的

{"data":["這個(gè)是第{0}個(gè)異步調(diào)用的證書(shū)","這個(gè)是第{1}個(gè)異步調(diào)用的證書(shū)","這個(gè)是第{2}個(gè)異步調(diào)用的證書(shū)","這個(gè)是第{3}個(gè)異步調(diào)用的證書(shū)","這個(gè)是第{4}個(gè)異步調(diào)用的證書(shū)","這個(gè)是第{5}個(gè)異步調(diào)用的證書(shū)","這個(gè)是第{6}個(gè)異步調(diào)用的證書(shū)","這個(gè)是第{7}個(gè)異步調(diào)用的證書(shū)","這個(gè)是第{8}個(gè)異步調(diào)用的證書(shū)","這個(gè)是第{9}個(gè)異步調(diào)用的證書(shū)"],"消耗時(shí)間":"任務(wù)執(zhí)行成功,耗時(shí){508}毫秒"}

springboot的異步任務(wù)（帶返回值和不帶返回值的處理）

注意：在用異步任務(wù)之前先給啟動(dòng)類加@EnableAsync這個(gè)注解

新建異步任務(wù)包和在包里面建異步任務(wù)類

As.java異步類

package com.example.demo.async;
import org.springframework.scheduling.annotation.Async;
import org.springframework.scheduling.annotation.AsyncResult;
import org.springframework.stereotype.Component;
import java.util.concurrent.Future;
//注意：1、要把異步任務(wù)寫(xiě)進(jìn)一個(gè)類里面而不能直接寫(xiě)在controller中
//      2、如果需要拿到結(jié)果，則需要在調(diào)用處判斷全部的task.isDone()來(lái)確定異步任務(wù)的完成
@Component
//異步類注解，表明整個(gè)類的方法都是異步方法，如果把這個(gè)注解加在某一個(gè)方法上而不是某一個(gè)類則表明僅僅是這個(gè)方法才是異步方法
@Async
public class As {
    //下面是3個(gè)異步任務(wù)（不帶返回值的）
    public void task1() throws InterruptedException {
        long begin=System.currentTimeMillis();
        Thread.sleep(3000l);
        long end=System.currentTimeMillis();
        System.out.println("任務(wù)1耗時(shí)"+(end-begin));
    }
    public void task2() throws InterruptedException {
        long begin=System.currentTimeMillis();
        Thread.sleep(2000l);
        long end=System.currentTimeMillis();
        System.out.println("任務(wù)2耗時(shí)"+(end-begin));
    }
    public void task3() throws InterruptedException {
        long begin=System.currentTimeMillis();
        Thread.sleep(1000l);
        long end=System.currentTimeMillis();
        System.out.println("任務(wù)3耗時(shí)"+(end-begin));
    }
    //下面是3個(gè)異步任務(wù)（帶返回值的，可以在調(diào)用出取地返回值）
    public Future<String> task4() throws InterruptedException {
        long begin=System.currentTimeMillis();
        Thread.sleep(3000l);
        long end=System.currentTimeMillis();
        return new AsyncResult<String>("任務(wù)4耗時(shí)"+(end-begin));
    }
    public Future<String> task5() throws InterruptedException {
        long begin=System.currentTimeMillis();
        Thread.sleep(2000l);
        long end=System.currentTimeMillis();
        return new AsyncResult<String>("任務(wù)5耗時(shí)"+(end-begin));
    }
    public Future<String> task6() throws InterruptedException {
        long begin=System.currentTimeMillis();
        Thread.sleep(1000l);
        long end=System.currentTimeMillis();
        return new AsyncResult<String>("任務(wù)6耗時(shí)"+(end-begin));
    }
}

controller測(cè)試控制器

package com.example.demo.controller;
import com.example.demo.async.As;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.Future;
@RestController
public class He {
	//注入異步類
    @Autowired
    private As as;
    //測(cè)試異步任務(wù)沒(méi)帶返回值的，直接主線程瞬間就通過(guò)了
    @RequestMapping("/as")
    public Object as() throws InterruptedException {
        long begin=System.currentTimeMillis();
        as.task1();
        as.task2();
        as.task3();
        long end=System.currentTimeMillis();
        return "總耗時(shí)+"+(end-begin);
    }
    //測(cè)試異步任務(wù)帶返回值的,總耗時(shí)是最慢的那個(gè)任務(wù)的耗時(shí)
    @RequestMapping("/asHava")
    public Object ash() throws InterruptedException, ExecutionException {
        long begin=System.currentTimeMillis();
        Future<String> task4=as.task4();
        Future<String> task5=as.task5();
        Future<String> task6=as.task6();
        //先小堵塞主線程一會(huì)，用以拿到異步任務(wù)返回值
        while (!(task4.isDone()&&task5.isDone()&&task6.isDone())){
        }
        long end=System.currentTimeMillis();
        //取得異步任務(wù)的返回值并查看總耗時(shí)
        return "總耗時(shí)+"+(end-begin)+"   task4結(jié)果："+task4.get()+"  task5結(jié)果："+task5.get()+"  task6結(jié)果："+task6.get();
        //結(jié)果是3s左右，因?yàn)檫M(jìn)入接口，三個(gè)異步任務(wù)瞬間開(kāi)啟，再瞬間到while這兒堵起
        //由于三個(gè)異步任務(wù)幾乎是同時(shí)開(kāi)啟的，所以等最慢的那個(gè)異步任務(wù)完成以后，肯定所有的異步任務(wù)都完成了
        //所以while這時(shí)才都為true，那么放開(kāi)while，所以結(jié)果就是最慢的那個(gè)異步任務(wù)的時(shí)間
        //如果說(shuō)不用這種異步取值而用同步的話，那么時(shí)間就是1+2+3就是6s左右，而不是最慢的那個(gè)任務(wù)的時(shí)間
    }
}