可比较未来链接结果

java java-8 completable-future

2022-09-04 20:38:20

我正在尝试将方法的调用/结果链接到下一个调用。我得到编译时错误方法E，因为如果我无法从上一个调用中获取objB的引用。

如何将上一个调用的结果传递给下一个链？我是否完全误解了这个过程？

Object objC = CompletableFuture.supplyAsync(() -> service.methodA(obj, width, height))
    .thenApply(objA -> {
    try {
        return service.methodB(objA);
    } catch (Exception e) {
        throw new CompletionException(e);
    }
})
   .thenApply(objA -> service.methodC(objA))
   .thenApply(objA -> {
   try {
       return service.methodD(objA); // this returns new objB how do I get it and pass to next chaining call 
       } catch (Exception e) {
           throw new CompletionException(e);
       }
    })
    .thenApply((objA, objB) -> {
       return service.methodE(objA, objB); // compilation error 
  })
 .get();

答案 1

您可以将中间存储在变量中，然后使用：CompletableFuturethenCombine

CompletableFuture<ClassA> futureA = CompletableFuture.supplyAsync(...)
    .thenApply(...)
    .thenApply(...);

CompletableFuture<ClassB> futureB = futureA.thenApply(...);

CompletableFuture<ClassC> futureC = futureA.thenCombine(futureB, service::methodE);

objC = futureC.join();

答案 2

您应该使用 thenCompose，这是一个异步映射，而不是 thenApply，它是同步的。下面是一个链接两个未来返回函数的示例：

public CompletableFuture<String> getStringAsync() {
    return this.getIntegerAsync().thenCompose(intValue -> {
        return this.getStringAsync(intValue);
    });
}

public CompletableFuture<Integer> getIntegerAsync() {
    return CompletableFuture.completedFuture(Integer.valueOf(1));
}

public CompletableFuture<String> getStringAsync(Integer intValue) {
    return CompletableFuture.completedFuture(String.valueOf(intValue));
}

有了那么Apply，你就不会再回来了。有了那么Compose，你做到了。