SpringBoot如何实现并发任务并返回结果

@Service
public class AsyncTest {
        @Async
        public Future<Boolean> doReturn1(){
            try {
                // 这个方法需要调用500毫秒
                Thread.sleep(500);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            for (int i = 0; i < 10; i++) {
                System.out.println("一号线程:"+i);
            }
            // 消息汇总
            return new AsyncResult<>(true);
        }
        @Async
        public Future<Boolean> doReturn2(){
            try {
                // 这个方法需要调用500毫秒
                Thread.sleep(500);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            for (int i = 0; i < 10; i++) {
                System.out.println("二号线程:"+i);
            }
            // 消息汇总
            return new AsyncResult<>(true);
        }
        @Async
        public Future<Boolean> doReturn3(){
            try {
                // 这个方法需要调用500毫秒
                Thread.sleep(500);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            for (int i = 0; i < 10; i++) {
                System.out.println("三号线程:"+i);
            }
            // 消息汇总
            return new AsyncResult<>(true);
        }
        @Async
        public Future<Boolean> doReturn4(){
            try {
                // 这个方法需要调用500毫秒
                Thread.sleep(500);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            for (int i = 0; i < 10; i++) {
                System.out.println("四号线程:"+i);
            }
            // 消息汇总
            return new AsyncResult<>(true);
        }
}

@RequestMapping("/async")
    public String async(){
        List<Future<Boolean>> futures = new ArrayList<>();
        Future<Boolean> flag1 = asyncTest.doReturn1();
        Future<Boolean> flag2 = asyncTest.doReturn2();
        Future<Boolean> flag3 = asyncTest.doReturn3();
        Future<Boolean> flag4 = asyncTest.doReturn4();
        futures.add(flag1);
        futures.add(flag2);
        futures.add(flag3);
        futures.add(flag4);
        List<Boolean> response = new ArrayList<>();
        for (Future future : futures) {
            Boolean flag = null;
            try {
                flag = (Boolean) future.get();
            } catch (InterruptedException e) {
                e.printStackTrace();
            } catch (ExecutionException e) {
                e.printStackTrace();
            }
            response.add(flag);
        }
        System.out.println(response);
        return response.toString();
    }

# application.yml
spring:
  task:
    execution:
      pool:
        max-threads: 10
        core-threads: 5

@Configuration
@EnableAsync
public class AppConfig {
    @Bean
    public Executor taskExecutor() {
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        executor.setCorePoolSize(5);
        executor.setMaxPoolSize(10);
        executor.setQueueCapacity(25);
        return executor;
    }
}

@Configuration
public class WebMvcConfig extends WebMvcConfigurerAdapter {
    @Override
    public void configureAsyncSupport(final AsyncSupportConfigurer configurer) {
        configurer.setTaskExecutor(asyncTaskExecutor());
    }
    @Bean
    public AsyncTaskExecutor asyncTaskExecutor() {
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        executor.setCorePoolSize(5);
        executor.setMaxPoolSize(50);
        executor.setQueueCapacity(100);
        executor.setThreadNamePrefix("MySpringAsyncThread-");
        executor.initialize();
        return executor;
    }
}

server:
    tomcat:
        max-connections:2000
        max-threads:200
        min-spare-threads:10
        accept-count:100

  # undertow 配置
  undertow:
    # HTTP post内容的最大大小。当值为-1时，默认值为大小是无限的
    max-http-post-size: -1
    # 以下的配置会影响buffer,这些buffer会用于服务器连接的IO操作,有点类似netty的池化内存管理
    # 每块buffer的空间大小,越小的空间被利用越充分
    buffer-size: 512
    # 是否分配的直接内存
    direct-buffers: true
    threads:
      # 设置IO线程数, 它主要执行非阻塞的任务,它们会负责多个连接, 默认设置每个CPU核心一个线程
      io: 8
      # 阻塞任务线程池, 当执行类似servlet请求阻塞操作, undertow会从这个线程池中取得线程,它的值设置取决于系统的负载
      worker: 256