Future详解( 六 ) _生活百科

【3】常用方法的使用与介绍
1）结果处理
1.介绍：
//当CompletableFuture的计算结果完成，或者抛出异常的时候，我们可以执行特定的 Action 。主要是下面的方法：public CompletableFuture<T> whenComplete(BiConsumer<? super T,? super Throwable> action)public CompletableFuture<T> whenCompleteAsync(BiConsumer<? super T,? super Throwable> action)public CompletableFuture<T> whenCompleteAsync(BiConsumer<? super T,? super Throwable> action, Executor executor)//Action的类型是BiConsumer<? super T,? super Throwable>，它可以处理正常的计算结果，或者异常情况。//方法不以Async结尾，意味着Action使用相同的线程执行，而Async可能会使用其它的线程去执行(如果使用相同的线程池，也可能会被同一个线程选中执行) 。//这几个方法都会返回CompletableFuture，当Action执行完毕后它的结果返回原始的CompletableFuture的计算结果或者返回异常2.示例：
CompletableFuture<String> future = CompletableFuture.supplyAsync(() -> {try {TimeUnit.SECONDS.sleep(1);} catch (InterruptedException e) {}if (new Random().nextInt(10) % 2 == 0) {int i = 12 / 0;}System.out.println("执行结束！");return "test";});//whenComplete一般搭配exceptionally一起使用，一个处理结果，一个处理异常future.whenComplete(new BiConsumer<String, Throwable>() {@Overridepublic void accept(String t, Throwable action) {System.out.println(t+" 执行完成！");}});future.exceptionally(new Function<Throwable, String>() {@Overridepublic String apply(Throwable t) {System.out.println("执行失败：" + t.getMessage());return "异常xxxx";}});2）结果转换
1.介绍：所谓结果转换，就是将上一段任务的执行结果作为下一阶段任务的入参参与重新计算，产生新的结果。
2.方法列举：
【1】thenApply
1.说明
//thenApply 接收一个函数作为参数，使用该函数处理上一个CompletableFuture 调用的结果，并返回一个具有处理结果的Future对象。public CompletableFuture thenApply(Function<? super T,? extends U> fn)public CompletableFuture thenApplyAsync(Function<? super T,? extends U> fn)2.示例
CompletableFuture<Integer> future = CompletableFuture.supplyAsync(() -> {int result = 100;System.out.println("一阶段：" + result);return result;}).thenApply(number -> {int result = number * 3;System.out.println("二阶段：" + result);return result;});【2】thenCompose
1.说明
//thenCompose 的参数为一个返回 CompletableFuture 实例的函数，该函数的参数是先前计算步骤的结果。public CompletableFuture thenCompose(Function<? super T, ? extends CompletionStage> fn);public CompletableFuture thenComposeAsync(Function<? super T, ? extends CompletionStage> fn) ;2.示例
CompletableFuture<Integer> future = CompletableFuture.supplyAsync(new Supplier<Integer>() {@Overridepublic Integer get() {int number = new Random().nextInt(30);System.out.println("第一阶段：" + number);return number;}}).thenCompose(new Function<Integer, CompletionStage<Integer>>() {@Overridepublic CompletionStage<Integer> apply(Integer param) {return CompletableFuture.supplyAsync(new Supplier<Integer>() {@Overridepublic Integer get() {int number = param * 2;System.out.println("第二阶段：" + number);return number;}});}});3.说明：
【1】thenApply 和 thenCompose的区别
1.thenApply 转换的是泛型中的类型，返回的是同一个CompletableFuture；
2.thenCompose 将内部的 CompletableFuture 调用展开来并使用上一个CompletableFutre 调用的结果在下一步的 CompletableFuture 调用中进行运算，是生成一个新的CompletableFuture 。
3.示例
CompletableFuture<String> future = CompletableFuture.supplyAsync(() -> "Hello");CompletableFuture<String> result1 = future.thenApply(param -> param + " World");CompletableFuture<String> result2 = future.thenCompose(param -> CompletableFuture.supplyAsync(() -> param + " World"));System.out.println(result1.get());

Future详解( 六 )

经验总结扩展阅读

8月，4大星座财运大涨，横财正财偏财齐聚满堂，富贵满堂

裸妆|看来看去，浓妆艳抹不算啥，还是裸妆最百搭，关键实用又简单

健康周谈|冬天是脑梗高发季，该如何度过？医生：做好4件事，或能安稳过冬

五行缺火100分女孩名字缺火的高分女孩名字

睡美人的睡眠秘籍

上颌窦真菌病65例诊治体会

芝兰是什么意思芝兰的解释

家具品牌选哪些牌子好十大环保品牌家具排行榜

2023年1月4日制作房梁黄道吉日 2023年农历腊月十三制作房梁吉日

籽字取名的寓意是什么?

宝莲灯前传和宝莲灯的关系是什么?

越南|中国男性和越南男性有啥区别？听听越南姑娘是怎么说的

立冬节气特点

有一句俗话：“早起的鸟儿有虫吃。|早睡早起的时间，早起的人更容易获取成功机会

2023年5月定亲黄道吉日 2023年5月哪天适合定亲

含笑的秋水是什么意思含笑的秋水应该是什么意思

发型只热衷于一款发型的发型师 | 爆笑视频

六学家什么梗？

床垫对睡眠有什么影响怎么挑选好床垫

玻璃种翡翠值多少钱