JDK8-11-CompletableFuture（6）- thenCombine方法使用

承接上文：https://blog.csdn.net/sql2008help/article/details/127348660

假设顾客进入餐馆的时间比较早，直到顾客点完餐后才开始煮饭，场景步骤如下（/ 表示同时进行）：
1.顾客进入餐厅
2.顾客开始点餐
3.厨师按照顾客所选菜品开始炒菜 / 4.服务员煮饭 / 5.顾客玩手机
6.顾客等饭菜做好后开始吃饭

用程序模拟如下：

使用两个异步任务 chefCF ，waiterCF 分别处理炒菜和煮饭这两个动作，使用 chefCF.get(), waiterCF.get() 等待任务执行完成

import java.util.concurrent.CompletableFuture;
import java.util.concurrent.ExecutionException;

public class SupplyAsyncTest04 {

    public static void main(String[] args) {
        PrintTool.printTimeAndThread("顾客进入餐厅。。。");
        PrintTool.printTimeAndThread("顾客开始点餐。。。");
        CompletableFuture<String> chefCF = CompletableFuture.supplyAsync(() -> {
            PrintTool.printTimeAndThread("厨师开始炒菜。。。");
            PrintTool.sleep(500);
            return "番茄炒蛋";
        });
        CompletableFuture<String> waiterCF = CompletableFuture.supplyAsync(() -> {
            PrintTool.printTimeAndThread("服务员开始煮饭。。。");
            PrintTool.sleep(1500);
            return "米饭";
        });
        PrintTool.printTimeAndThread("顾客玩手机中。。。");
        try {
            PrintTool.printTimeAndThread(String.format("顾客开始吃%s+%s", chefCF.get(), waiterCF.get()));
        } catch (InterruptedException e) {
            e.printStackTrace();
        } catch (ExecutionException e) {
            e.printStackTrace();
        }
    }
}

执行结果：

1665916611820	|	1	|	main	|	顾客进入餐厅。。。
1665916611821	|	1	|	main	|	顾客开始点餐。。。
1665916611947	|	1	|	main	|	顾客玩手机中。。。
1665916611948	|	15	|	ForkJoinPool.commonPool-worker-2	|	服务员开始煮饭。。。
1665916611948	|	14	|	ForkJoinPool.commonPool-worker-1	|	厨师开始炒菜。。。
1665916613484	|	1	|	main	|	顾客开始吃番茄炒蛋+米饭

thenCombine 方法

虽然上述程序可以异步完成厨师炒菜和服务员煮饭这两个动作，但是同样 CompletableFuture 为我们提供了这种场景的API，即 thenCombine

import java.util.concurrent.CompletableFuture;
import java.util.concurrent.ExecutionException;

public class SupplyAsyncTest05 {

    public static void main(String[] args) {
        PrintTool.printTimeAndThread("顾客进入餐厅。。。");
        PrintTool.printTimeAndThread("顾客开始点餐。。。");
        CompletableFuture<String> chefCF = CompletableFuture.supplyAsync(() -> {
            PrintTool.printTimeAndThread("厨师开始炒菜。。。");
            PrintTool.sleep(500);
            return "番茄炒蛋";
        }).thenCombine(CompletableFuture.supplyAsync(() -> {
            PrintTool.printTimeAndThread("服务员开始煮饭。。。");
            PrintTool.sleep(1500);
            return "米饭";
        }), (dish, rice) -> String.format("%s+%s", dish, rice));
        PrintTool.printTimeAndThread("顾客玩手机中。。。");
        try {
            PrintTool.printTimeAndThread(String.format("顾客开始吃%s", chefCF.get()));
        } catch (InterruptedException e) {
            e.printStackTrace();
        } catch (ExecutionException e) {
            e.printStackTrace();
        }
    }
}

执行结果：
如下所示，厨师炒菜和服务员煮饭时间戳都是 1665916480033 ，即表示同时进行

1665916479910	|	1	|	main	|	顾客进入餐厅。。。
1665916479911	|	1	|	main	|	顾客开始点餐。。。
1665916480033	|	14	|	ForkJoinPool.commonPool-worker-1	|	厨师开始炒菜。。。
1665916480033	|	15	|	ForkJoinPool.commonPool-worker-2	|	服务员开始煮饭。。。
1665916480034	|	1	|	main	|	顾客玩手机中。。。
1665916481583	|	1	|	main	|	顾客开始吃番茄炒蛋+米饭

分析

combine意思为组合，thenCombine表示将两个异步任务组合起来一起执行，thenCombine方法接收两个入参，第一个入参为 CompletionStage，本例为 CompletableFuture，第二个入参为 BiFunction，BiFunction 的两个入参分别为第一个任务和第二个任务的返回结果，出参即为 chefCF.get() 结果值

public <U,V> CompletableFuture<V> thenCombine(
        CompletionStage<? extends U> other,
    BiFunction<? super T,? super U,? extends V> fn) {
    return biApplyStage(null, other, fn);
}

@FunctionalInterface
public interface BiFunction<T, U, R> {

    /**
     * Applies this function to the given arguments.
     *
     * @param t the first function argument
     * @param u the second function argument
     * @return the function result
     */
    R apply(T t, U u);
}