package top.ytheng.demo.task;import java.util.concurrent.Future;import org.springframework.scheduling.annotation.Async;
import org.springframework.scheduling.annotation.AsyncResult;
import org.springframework.stereotype.Component;//异步任务业务类
@Component
//标记此类是异步类，也可在方法中标记
//不加，则类里面的方法为同步执行
@Async
public class AsyncTask {public void task1() throws InterruptedException {long begin = System.currentTimeMillis();Thread.sleep(1000);long end = System.currentTimeMillis();System.out.println("任务1耗时：" + (end - begin));}public void task2() throws InterruptedException {long begin = System.currentTimeMillis();Thread.sleep(2000);long end = System.currentTimeMillis();System.out.println("任务2耗时：" + (end - begin));}public void task3() throws InterruptedException {long begin = System.currentTimeMillis();Thread.sleep(3000);long end = System.currentTimeMillis();System.out.println("任务3耗时：" + (end - begin));}//测试拿到返回结果public Future<String> task4() throws InterruptedException {long begin = System.currentTimeMillis();Thread.sleep(1000);long end = System.currentTimeMillis();System.out.println("任务4耗时：" + (end - begin));return new AsyncResult<String>("任务4");}public Future<String> task5() throws InterruptedException {long begin = System.currentTimeMillis();Thread.sleep(2000);long end = System.currentTimeMillis();System.out.println("任务5耗时：" + (end - begin));return new AsyncResult<String>("任务5");}public Future<String> task6() throws InterruptedException {long begin = System.currentTimeMillis();Thread.sleep(3000);long end = System.currentTimeMillis();System.out.println("任务6耗时：" + (end - begin));return new AsyncResult<String>("任务6");}
}

package top.ytheng.demo.controller;import java.util.concurrent.ExecutionException;
import java.util.concurrent.Future;import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;import top.ytheng.demo.task.AsyncTask;@RestController
@RequestMapping("api/v1/async")
public class TaskController {@Autowiredprivate AsyncTask asyncTask;@GetMapping("/test")public Object test() throws InterruptedException, ExecutionException {long begin = System.currentTimeMillis();//asyncTask.task1();//asyncTask.task2();//asyncTask.task3();Future<String> result1 = asyncTask.task4();Future<String> result2 = asyncTask.task5();Future<String> result3 = asyncTask.task6();System.out.println("返回结果:" + result1.get() + "," + result2.get() + "," + result3.get());for(;;) {if(result1.isDone() && result2.isDone() && result3.isDone()) {break;}}long end = System.currentTimeMillis();long total = end - begin;System.out.println("总耗时：" + total);return "总耗时:" + total;}
}

package top.ytheng.demo;import org.mybatis.spring.annotation.MapperScan;
import org.springframework.scheduling.annotation.EnableAsync;
import org.springframework.scheduling.annotation.EnableScheduling;import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.boot.web.servlet.ServletComponentScan;@SpringBootApplication //等于下面3个
//@SpringBootConfiguration
//@EnableAutoConfiguration
//@ComponentScan
//拦截器用到
@ServletComponentScan
//MyBatis用到
@MapperScan("top.ytheng.demo.mapper")
//定时使用(开启定时任务)
@EnableScheduling
//开启异步任务
@EnableAsync
public class DemoApplication {public static void main(String[] args) {SpringApplication.run(DemoApplication.class, args);}
}

http://localhost:8080/api/v1/async/test