server层代码需要查询四个sql语句，但全都由主线程执行。

CompletableFuture可以分出多个子线程执行

CompletableFuture（并行处理多个异步任务）

1.通过CompletableFuture.supplyAsync()方法创建了三个CompletableFuture实例，分别代表异步任务a、b和c。每个CompletableFuture都使用了一个Lambda表达式来定义具体的任务逻辑，并返回一个结果。

2.通过CompletableFuture.allOf()方法将这三个CompletableFuture实例组合在一起，表示在所有任务完成后进行下一步操作。allOf()方法接收可变参数，可以传入任意数量的CompletableFuture实例。

3.在调用allOf()方法后，可以使用join()方法等待所有任务完成。join()方法会阻塞当前线程，直到所有任务都完成。

4.通过调用CompletableFuture的get()方法获取各个任务的结果。get()方法也是一个阻塞调用，它会等待对应的CompletableFuture完成并返回结果。

（a、b和c分别表示任务aFuture、bFuture和cFuture的结果。）

注意：如果某个CompletableFuture发生异常，get()方法会抛出ExecutionException异常。你可以使用try-catch块来处理异常情况。另外，如果某个CompletableFuture还没有完成，get()方法也会阻塞等待其完成。可以使用isDone()方法来判断CompletableFuture是否已完成。

var aFuture = CompletableFuture.supplyAsync(()->{//.....return xxx;});var bFuture = CompletableFuture.supplyAsync(()->{//.....return xxx;});var cFuture = CompletableFuture.supplyAsync(()->{//.....return xxx;});//并行处理CompletableFuture//allOf等待的参数.allOf(aFuture,bFuture,cFuture)//join等待子线程执行.join();//取值var a= aFuture.get();var b= bFuture.get();var c= cFuture.get();

原代码：

/*** 获取首页基本数据* @param beginCreateTime* @param endCreateTime* @return*/@Overridepublic IndexBaseInfoVO getBaseInfo(String beginCreateTime, String endCreateTime) {//1）构建一个空的结果集对象IndexBaseInfoVO result = new IndexBaseInfoVO();//2 封装结果集属性// 2.1 由于查询需要用到用户名 调用工具类获取用户名String username = SecurityUtils.getUsername();try {//3 封装结果集对象result.setCluesNum(reportMpper.getCluesNum(beginCreateTime, endCreateTime, username));result.setBusinessNum(reportMpper.getBusinessNum(beginCreateTime, endCreateTime, username));result.setContractNum(reportMpper.getContractNum(beginCreateTime, endCreateTime, username));result.setSalesAmount(reportMpper.getSalesAmount(beginCreateTime, endCreateTime, username));}catch (Exception e) {e.printStackTrace();return null;}//4 返回结果集对象return result;}

修改后的代码：

/*** 获取首页基本数据* @param beginCreateTime* @param endCreateTime* @return*/
@Override
public IndexBaseInfoVO getBaseInfo(String beginCreateTime, String endCreateTime) {//1）构建一个空的结果集对象IndexBaseInfoVO result = new IndexBaseInfoVO();//2 封装结果集属性// 2.1 由于查询需要用到用户名 调用工具类获取用户名String username = SecurityUtils.getUsername();try {CompletableFuture<Integer> clueNums = CompletableFuture.supplyAsync(()->{// 2.2 开始查询第一个属性 线索数量return reportMpper.getCluesNum(beginCreateTime, endCreateTime, username);});CompletableFuture<Integer> bussinessNum = CompletableFuture.supplyAsync(()->{// 2.3 开始查询第一个属性 商机数量return reportMpper.getBusinessNum(beginCreateTime, endCreateTime, username);});CompletableFuture<Integer> contractNum = CompletableFuture.supplyAsync(()->{// 2.4 开始查询第一个属性 合同数量return reportMpper.getContractNum(beginCreateTime, endCreateTime, username);});CompletableFuture<Double> saleAmount = CompletableFuture.supplyAsync(()->{// 2.5 开始查询第一个属性 销售金额数量return reportMpper.getSalesAmount(beginCreateTime, endCreateTime, username);});//3 join等待所有线程全部执行完成CompletableFuture.allOf(clueNums,bussinessNum,contractNum,saleAmount).join();//4 封装结果集对象result.setCluesNum(clueNums.get());result.setBusinessNum(bussinessNum.get());result.setContractNum(contractNum.get());result.setSalesAmount(saleAmount.get());}catch (Exception e) {e.printStackTrace();return null;}//5 返回结果集对象return result;
}