- iOS/Objective-C 元类和类别
- objective-c - -1001 错误,当 NSURLSession 通过 httpproxy 和/etc/hosts
- java - 使用网络类获取 url 地址
- ios - 推送通知中不播放声音
为什么是CompletableFuture.allOf
声明为 CompletableFuture<Void>
而不是返回结果集合或其他东西?我认为制作 CompletableFuture.anyOf
是个好主意返回 CompletableFuture<Object>
,但我看到这两种方法相互关联,所以我对它们返回的内容感到困惑。
最佳答案
anyOf
必须以某种方式告诉您完成触发 anyOf
的特定 CompletableFuture
的结果是什么。在 allOf
的情况下,这不是必需的,因为您知道哪些 futures 已完成 - 所有这些。
allOf
(就像 anyOf
)不要求所有 future 都具有相同的类型。因此,如果它要返回集合的 future ,则它必须是 Object
的集合,这可能不是您想要的。
如果您真的想让 allOf
返回集合的 future ,那么编写您自己的就相当简单了:
public static CompletableFuture<List<Object>> myAllOf(CompletableFuture<?>... futures) {
return CompletableFuture.allOf(futures)
.thenApply(x -> Arrays.stream(futures)
.map(f -> (Object) f.join())
.collect(toList())
);
}
如果您有此问题的类型安全版本并且需要将特定类型的 future 集合转换为相同类型的 future 集合,请参阅此问题的几个示例:List<Future> to Future<List> sequence
关于java - 为什么 CompletableFuture.allOf 声明为 CompletableFuture<Void>?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/34083603/
我正试图通过使用 allOf 来弄清楚这个 swagger API 继承问题。这是我的 swagger yaml 文件。 swagger: '2.0' info: title: Test API
我正试图通过使用 allOf 来弄清楚这个 swagger API 继承问题。这是我的 swagger yaml 文件。 swagger: '2.0' info: title: Test API
我有这种情况,其中有 10 个或更多任务被分为许多组。在这些组内,一切都应该同时运行,但是因为每个组都需要前一组的结果(第一组除外),我需要以有序的方式运行它们(组内的任务不需要按顺序运行). 任务本
我有以下一段java代码: CompletableFuture future1 = CompletableFuture.supplyAsync(() -> { try {
一个非常简单的代码片段如下: String[] list = {"a", "b", "c"}; List> completableFutureList = new ArrayList<>(); for
请耐心等待,我通常不使用 spring,也没有使用过较新版本的 java(我说较新,我指的是 1.4 版之后的任何版本) 无论如何,我遇到一个问题,我必须进行休息调用才能使用多个并行请求进行搜索。我在
我有一个按如下方式创建的客户匹配器: private static class FromResidualAllocationMatcher extends BaseMatcher {....} 在我的
如果我有 CompletableFuture future1 = service.request(param1); CompletableFuture future2 = service.reques
此匹配器检查一组匹配器,如果它们都成功则成功。 签名如下: public static Matcher allOf(Iterable> matchers) 为什么这需要一个可迭代的 Matcher
假设我们有两个执行器,1 和 2。 我们可以配置在做的时候使用哪个executor CompletableFuture cf1 = CompletableFuture.supplyAsync(()->
具有以下暂存代码: public static void main(String[] args) throws ExecutionException, InterruptedException {
有两种方法可以强制执行 CompletableFuture 在给定的时间后超时: orTimeout(long timeout, TimeUnit unit) get(long timeout, Ti
我正在寻找一个 ScalaTest 匹配器来检查列表是否包含所有所需的元素(在另一个列表中给出),但也可能是其他元素。 contain allOf 要求获取两个固定元素,由于某种原因,其余元素作为可变
我有一个异步构建多个 DTO 的方法。它在一般用途中运行良好,因此我尝试为其编写一些单元测试。该方法如下所示: public List clientLeaderboard(@RequestBo
我正在学习 Java 1.8 中的 CompletableFuture,但在尝试理解 allOf 时遇到了困难。主线程似乎不会等待任何 CompletableFuture 完成。 参见https://
来自 javadoc, AllOf() If any of the given CompletableFutures complete exceptionally, then the returned
我正在尝试测试使用 CompletableFuture.allOf 的方法。 我模拟 future,以便它们在加入时返回所需的值。 由于某种我无法理解的原因。结果的 join() 需要永远。 任何帮助
我有一个类,它使用 CompletableFutures 向两个依赖服务发出并发请求。 我的代码如下所示: @Builder @Slf4j public class TestClass { @
这个问题已经有答案了: How to implement CompletableFuture.allOf() that completes exceptionally once any of the
我正在学习如何使用 Espresso 进行 UI 测试,我想验证 Intent 的状态。我写的是这样的: intended(allOf( hasAction(equalTo(Intent.AC
我是一名优秀的程序员,十分优秀!