springboot 的異步任務 ：無傳回值 和有傳回值

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

注：這裡的異步方法，隻能在本類之外調用，在本類調用是無效的。

無傳回值的異步任務

service實作部分：

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

controller調用部分：

@RestController
@EnableAsync//調用異步任務的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("任務執行成功,耗時{%s}", System.currentTimeMillis() - start);
    }
           

輸出：

任務執行成功，耗時{4}
           

可見testAsyncNoRetrun()方法中 調用doNoReturn(),沒等doNoReturn（）執行完即傳回。

有傳回值的異步任務

有傳回值的異步任務方法需要用Futrue變量把傳回值封裝起來。

service實作部分：

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

讀取的時候要批量讀取不能單獨讀取。

controller調用部分：

@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("消耗時間", String.format("任務執行成功,耗時{%s}毫秒", System.currentTimeMillis() - start));
        return map;
}
           

在浏覽器輸入位址:http://localhost:8080/hi

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

{"data":["這個是第{0}個異步調用的證書","這個是第{1}個異步調用的證書","這個是第{2}個異步調用的證書","這個是第{3}個異步調用的證書","這個是第{4}個異步調用的證書","這個是第{5}個異步調用的證書","這個是第{6}個異步調用的證書","這個是第{7}個異步調用的證書","這個是第{8}個異步調用的證書","這個是第{9}個異步調用的證書"],"消耗時間":"任務執行成功,耗時{508}毫秒"}