仅当前一个期货引发异常时，才执行可完成期货的列表

Question

我有一个可完成期货的列表，我想从第一个期货开始，如果有任何完成例外，我想尝试列表中的下一个期货，依此类推，直到我耗尽了我所有的期货。如果任何一个期货成功了，我想就此止步，而不使用列表中的下一个期货。我如何做到这一点？到目前为止，我已经尝试过：

for (SampleFutures future : getSampleFutures()) {

    try {
          return future.someMethod();
      } catch (Exception e) {
          log.error("An exception occurred, Will try the next future.", e);
      }
}

但是当我测试这种方法时，我看到当未来完成失败时，会抛出异常，并且不会尝试下一组期货。

编辑：

这就是样本的样子

public class SampleFutureA implements SampleFutures {

    @Override
    public CompletableFuture<SomeOject> someMethod() {
        return CompletableFuture
                .supplyAsync(() -> someOtherMethod())
                .thenApply( ()->anotherMethod())
                .exceptionally(ex -> exceptionHandler(ex));
    }

Answer 1

对于这种问题，我建议使用EA Async，因为它提供了一种异步/等待机制，可以很容易地实现它：

应用程序启动时初始化异步：（您也可以预处理应用程序，请阅读文档了解详细信息）

Async.init();

然后按如下方式使用wait（）：

for (SampleFutures future : getSampleFutures()) {
    try {
        return completedFuture(await(future.someMethod()));
    } catch (Exception e) {
        log.error("An exception occurred, Will try the next future.", e);
    }
}
throw new RuntimeException("All futures failed!");

但是，如果您不能或不想使用它，可以使用递归异步方法实现相同的功能：

private CompletableFuture<SomeObject> processNext(Iterator<SampleFutures> iterator) {
    if (iterator.hasNext()) {
        return iterator.next().someMethod()
                .handle((r, e) -> {
                    if (e != null) {
                        log.error("An exception occurred, Will try the next future.", e);
                        return processNext(iterator);
                    } else {
                        return completedFuture(r);
                    }
                }).thenCompose(c -> c);
    }
    CompletableFuture<SomeObject> allFailed = new CompletableFuture<>();
    allFailed.completeExceptionally(new RuntimeException("All futures failed!"));
    return allFailed;
}

你打电话的

return processNext(getSampleFutures().iterator());

此方法将调用第一个未来，只有当它失败时，它才会递归地异步调用自己，从而调用下一个未来。

不幸的是，我们不得不用hande（）来实现它-