Spring Boot入门系列（九）如何实现异步执行任务，极简版！

架构师精进

发布于 2020-04-27 19:48:49

9320

发布于 2020-04-27 19:48:49

今天主要讲解Spring Boot中的另外一个任务：异步任务。所谓异步任务，其实就是异步执行程序，有些时候遇到一些耗时的的任务，如果一直卡等待，肯定会影响其他程序的执行，所以就让这些程序需要以异步的方式去执行。那么下面就来介绍Spring Boot 如何实现异步任务。

一、使用注解@EnableAsync 开启异步调用方法

在application启动类中，加上@EnableAsync注解，Spring Boot 会自动扫描异步任务。

package com.weiz;
import org.springframework.boot.SpringApplication;import org.springframework.boot.autoconfigure.SpringBootApplication;import org.springframework.context.annotation.ComponentScan;import org.springframework.scheduling.annotation.EnableAsync;import org.springframework.scheduling.annotation.EnableScheduling;import tk.mybatis.spring.annotation.MapperScan;
@SpringBootApplication//扫描 mybatis mapper 包路径@MapperScan(basePackages = "com.weiz.mapper")//扫描 所有需要的包, 包含一些自用的工具类包 所在的路径@ComponentScan(basePackages = {"com.weiz","org.n3r.idworker"})//开启定时任务@EnableScheduling//开启异步调用方法@EnableAsyncpublic class SpringBootStarterApplication {
    public static void main(String[] args) {        SpringApplication.run(SpringBootStarterApplication.class, args);    }
}

二、创建异步执行类，定义@Component及@Async组件

创建com.weiz.tasks包，在tasks包里增加AsyncTask 异步任务类，加上@Component 注解，然后在需要异步执行的方法前面加上@Async注解，这样Spring Boot容器扫描到相关异步方法之后，调用时就会将这些方法异步执行。

package com.weiz.tasks;
import java.util.concurrent.Future;
import org.springframework.scheduling.annotation.Async;import org.springframework.scheduling.annotation.AsyncResult;import org.springframework.stereotype.Component;
@Componentpublic class AsyncTask {        @Async    public Future<Boolean> doTask11() throws Exception {        long start = System.currentTimeMillis();        Thread.sleep(1000);        long end = System.currentTimeMillis();        System.out.println("任务1耗时:" + (end - start) + "毫秒");        return new AsyncResult<>(true);    }        @Async    public Future<Boolean> doTask22() throws Exception {        long start = System.currentTimeMillis();        Thread.sleep(700);        long end = System.currentTimeMillis();        System.out.println("任务2耗时:" + (end - start) + "毫秒");        return new AsyncResult<>(true);    }        @Async    public Future<Boolean> doTask33() throws Exception {        long start = System.currentTimeMillis();        Thread.sleep(600);        long end = System.currentTimeMillis();        System.out.println("任务3耗时:" + (end - start) + "毫秒");        return new AsyncResult<>(true);     }}

说明：@Async 加上这个注解，就表示该方法是异步执行方法。

三、测试调用

创建一个DoTask调用类，我们看看这几个方法，是怎么执行的：

package com.weiz.tasks;
import java.util.concurrent.Future;
import org.springframework.beans.factory.annotation.Autowired;import org.springframework.web.bind.annotation.RequestMapping;import org.springframework.web.bind.annotation.RestController;
@RestController@RequestMapping("tasks")public class DoTask {
    @Autowired    private AsyncTask asyncTask;
    @RequestMapping("test1")    public String test1() throws Exception {
        long start = System.currentTimeMillis();
        Future<Boolean> a = asyncTask.doTask11();        Future<Boolean> b = asyncTask.doTask22();        Future<Boolean> c = asyncTask.doTask33();
        while (!a.isDone() || !b.isDone() || !c.isDone()) {            if (a.isDone() && b.isDone() && c.isDone()) {                break;            }        }
        long end = System.currentTimeMillis();
        String times = "任务全部完成，总耗时：" + (end - start) + "毫秒";        System.out.println(times);
        return times;    }}