我们在执行一个请求时，如果需要获取很多数据，而正常流程都是一行行代码执行，如果需要获取好几张表的数据时，同时又有很多个请求获取，那么响应时间就会很慢，所以我们需要用到异步线程的方式来编排代码，及通过多个线程同时并行获取数据，待数据都获取到了，直接返回即可。

1. 线程池配置

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

import java.util.concurrent.Executors;
import java.util.concurrent.LinkedBlockingDeque;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;

/**
 * 线程池配置
 * */
@Configuration
public class MyThreadConfig {

    @Bean
    public ThreadPoolExecutor threadPoolExecutor() {
        /**
         * int corePoolSize 核心线程池
         * int maximumPoolSize 最大线程池
         * long keepAliveTime 闲置多长时间关闭
         * TimeUnit unit 单位
         * BlockingQueue<Runnable> workQueue 阻塞队列,设置最多存储10万个异步任务
         * ThreadFactory threadFactory 线程工厂，使用默认的工厂
         * RejectedExecutionHandler handler 异常处理机制，抛出
         * */
        return new ThreadPoolExecutor(20,
                200,
                10,
                TimeUnit.SECONDS,
                new LinkedBlockingDeque<>(100000),
                Executors.defaultThreadFactory(), new ThreadPoolExecutor.AbortPolicy());
    }
}

2. 方法中异步编排实例

// 注入线程池
    @Autowired
    private ThreadPoolExecutor executor;

public UserInfoVo getUserInfo() throws ExecutionException, InterruptedException {
        /*
         * 如果一个人需要很多信息的话，可以通过异步编排并发获取所需信息，然后返回，
         * 而不需要一个个的排队获取信息
         * */
        UserInfoVo userInfoVo = new UserInfoVo();
        // 1. 获取用户信息
        // supplyAsync可以返回数据的异步方法
        CompletableFuture<UserInfo> infoFuture = CompletableFuture.supplyAsync(() -> {
            UserInfo userInfo = new UserInfo();
            userInfoVo.setUserInfo(userInfo);
            return userInfo;
        }, executor);

        // 2. 获取用户会员信息
        // thenAcceptAsync代表需要1执行后的数据才能获取另外一个我们需要的数据
        CompletableFuture<Void> vipInfoFuture = infoFuture.thenAcceptAsync((res) -> {
            String userId = res.getUserId();
            UserVipInfo vipInfo = new UserVipInfo();
            userInfoVo.setUserVipInfo(vipInfo);
        }, executor);

        // 3. 获取用户购物车信息
        // 这里获取购物车信息可以和会员信息同时获取，也就是在两个线程中同时执行，缩短时间
        CompletableFuture<Void> userCartFuture =  infoFuture.thenAcceptAsync((res) -> {
            String userId = res.getUserId();
            UserCart userCart = new UserCart();
            userInfoVo.setUserCart(userCart);
        }, executor);

        // 4. 获取会员等级信息，不需要和上面产生关联，可以放到另一个线程里执行，且不需要返回值
        CompletableFuture<Void> vipGradeFuture = CompletableFuture.runAsync(() -> {
            VipGrade vipGrade = new VipGrade();
            userInfoVo.setVipGrade(vipGrade);
        }, executor);

        // 5. 等待所有任务都完成，这里的异常抛出去，给系统自己处理
        CompletableFuture.allOf(vipInfoFuture,userCartFuture,vipGradeFuture).get();

        return userInfoVo;
    }