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;
    }

}