package com.test;
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.TimeUnit;
/**
* @author: leizheng
* @create: 2022/3/20 11:49 上午
* @description:
*/
public class CompletableFutureTest<T> {
/**
* 俩子任务返回结果后执行下一个子任务
*/
public void ConsolidationResultExec()throws Exception{
CompletableFuture<T> cf = CompletableFuture.supplyAsync(()-> t1())
.thenCombineAsync(CompletableFuture.supplyAsync(()-> t2()), (t1, t2)-> t3(t1, t2));
cf.get(10, TimeUnit.SECONDS);
}
public T t1(){
return null;
}
public T t2(){
return null;
}
public T t3(T t1, T t2){
return null;
}
}