Future详解( 七 ) _生活百科

3）结果消费
1.介绍：
【1】与结果处理和结果转换系列函数返回一个新的 CompletableFuture 不同，结果消费系列函数只对结果执行Action，而不返回新的计算值。
【2】根据对结果的处理方式，结果消费函数又分为：
thenAccept系列：对单个结果进行消费thenAcceptBoth系列：对两个结果进行消费thenRun系列：不关心结果，只对结果执行Action2.方法列举：
【1】thenAccept
1.说明
//通过观察该系列函数的参数类型可知，它们是函数式接口Consumer，这个接口只有输入，没有返回值。public CompletionStage<Void> thenAccept(Consumer<? super T> action);public CompletionStage<Void> thenAcceptAsync(Consumer<? super T> action);2.示例
CompletableFuture<Void> future = CompletableFuture.supplyAsync(() -> {int number = new Random().nextInt(10);System.out.println("第一阶段：" + number);return number;}).thenAccept(number ->System.out.println("第二阶段：" + number * 5));【2】thenAcceptBoth
1.说明
//thenAcceptBoth 函数的作用是，当两个 CompletionStage 都正常完成计算的时候，就会执行提供的action消费两个异步的结果。public <U> CompletionStage<Void> thenAcceptBoth(CompletionStage<? extends U> other,BiConsumer<? super T, ? super U> action);public <U> CompletionStage<Void> thenAcceptBothAsync(CompletionStage<? extends U> other,BiConsumer<? super T, ? super U> action);2.示例
CompletableFuture<Integer> futrue1 = CompletableFuture.supplyAsync(new Supplier<Integer>() {@Overridepublic Integer get() {int number = new Random().nextInt(3) + 1;try {TimeUnit.SECONDS.sleep(number);} catch (InterruptedException e) {e.printStackTrace();}System.out.println("第一阶段：" + number);return number;}});CompletableFuture<Integer> future2 = CompletableFuture.supplyAsync(new Supplier<Integer>() {@Overridepublic Integer get() {int number = new Random().nextInt(3) + 1;try {TimeUnit.SECONDS.sleep(number);} catch (InterruptedException e) {e.printStackTrace();}System.out.println("第二阶段：" + number);return number;}});futrue1.thenAcceptBoth(future2, new BiConsumer<Integer, Integer>() {@Overridepublic void accept(Integer x, Integer y) {System.out.println("最终结果：" + (x + y));}});【3】thenRun
1.说明
//thenRun 也是对线程任务结果的一种消费函数，与thenAccept不同的是，thenRun 会在上一阶段 CompletableFuture 计算完成的时候执行一个Runnable，Runnable并不使用该 CompletableFuture 计算的结果。public CompletionStage<Void> thenRun(Runnable action);public CompletionStage<Void> thenRunAsync(Runnable action);2.示例
CompletableFuture<Void> future = CompletableFuture.supplyAsync(() -> {int number = new Random().nextInt(10);System.out.println("第一阶段：" + number);return number;}).thenRun(() ->System.out.println("thenRun 执行"));4）结果组合
1.方法列举：
【1】thenCombine
1.说明
//thenCombine 方法，合并两个线程任务的结果，并进一步处理。public <U,V> CompletionStage<V> thenCombine(CompletionStage<? extends U> other,BiFunction<? super T,? super U,? extends V> fn);public <U,V> CompletionStage<V> thenCombineAsync(CompletionStage<? extends U> other,BiFunction<? super T,? super U,? extends V> fn);2.示例
CompletableFuture<Integer> future1 = CompletableFuture.supplyAsync(new Supplier<Integer>() {@Overridepublic Integer get() {int number = new Random().nextInt(10);System.out.println("第一阶段：" + number);return number;}});CompletableFuture<Integer> future2 = CompletableFuture.supplyAsync(new Supplier<Integer>() {@Overridepublic Integer get() {int number = new Random().nextInt(10);System.out.println("第二阶段：" + number);return number;}});CompletableFuture<Integer> result = future1.thenCombine(future2, new BiFunction<Integer, Integer, Integer>() {@Overridepublic Integer apply(Integer x, Integer y) {return x + y;}});

Future详解( 七 )

经验总结扩展阅读

鲈鱼蒸多久就可以熟了鲈鱼蒸多长时间可以熟

菠萝蜜的功效及禁忌

白墙上的胶带留下印怎么去除

福泉市的特色景点有哪些?

炒花蛤怎么做

一月份适合去哪里旅游旅游景点告诉你

财运线杂乱的手相好不好

什么东西好吃健康不胖

抑郁症患者抑郁症：若想走向康复与强大，你必须学会与自己的灵魂对话

出汗对痘印有改善吗对人体有哪些好处

水培铜钱草分盆分株的方法

温州|行拘＋退学处理！温州高校深夜通报两起男生骚扰女性事件处理进展

moss时尚圈过年了！来“蹦迪”的明星们用了什么？

2023年1月9日安装门户好吗 2023年1月9日是安装门户的黄道吉日吗

2022年农历腊月初七开学典礼吉日 2022年12月29日适合开学典礼吗

擦眼镜怎么擦才正确

vivoT1和荣耀50哪个好_vivoT1和荣耀50参数对比

宝宝咳嗽吃什么好得快

许三观卖血记|活着是生命的力量，活得好是人生的态度

罗兰会算命吗_啥八字的女人易被抛弃