栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 面试经验 > 面试问答

CompletableFuture allof(..)。join()与CompletableFuture.join()

面试问答 更新时间: 发布时间: IT归档 最新发布 模块sitemap 名妆网 法律咨询 聚返吧 英语巴士网 伯小乐 网商动力

CompletableFuture allof(..)。join()与CompletableFuture.join()

首先,

.getNow()
它不起作用,因为对于将来尚未完成的情况,此方法需要一个后备值作为参数。由于您假设将来会在这里完成,因此您也应该使用
join()

然后,线程耗尽没有任何区别,因为在任何一种情况下,您都在等待所有作业的完成之后再继续操作,从而有可能阻塞当前线程。

避免这种情况的唯一方法是,重构代码以使其不期望同步结果,而是安排在完成所有作业后执行后续处理动作。然后,使用

allOf
变得很重要:

final List<CompletableFuture<List<Test>>> completableFutures = resolvers.stream()    .map(resolver -> supplyAsync(() -> task.doWork()))    .collect(toList());CompletableFuture.allOf(completableFutures.toArray(new CompletableFuture<?>[0]))    .thenAccept(justVoid -> {        // here, all jobs have been completed        final List<Test> tests = completableFutures.stream() .flatMap(completableFuture -> completableFuture.join().stream()) .collect(toList());        // process the result here    });

顺便说一句,关于

toArray
收藏的方法,我建议阅读《远古智慧的数组》 …



转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/451484.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号