如何辜负java.util.concurrent.未来

Question

有相当多的io使用。维特斯。果心vertx生态系统中的未来：https://vertx.io/docs/apidocs/io/vertx/core/Future.html

使用VertxFuture的示例如下：

private Future<Void> prepareDatabase() {

  Future<Void> future = Future.future();

  dbClient = JDBCClient.createShared(vertx, new JsonObject(...));

  dbClient.getConnection(ar -> {    

    if (ar.failed()) {
      LOGGER.error("Could not open a database connection", ar.cause());
      future.fail(ar.cause());  // here
      return; 
    } 

    SQLConnection connection = ar.result();   
    connection.execute(SQL_CREATE_PAGES_TABLE, create -> {
        connection.close();   
        if (create.failed()) {
          future.fail(create.cause());  // here
        } else {
          future.complete();  
        }
     });
  });

  return future;
}

我的印象是，io。维特斯。果心未来与java有关。util。同时发生的Future，但它似乎没有。正如您所看到的，告诉Vertx Future失败的方法是调用它的fail（）方法。

另一方面，我们有完全未来，这是一个实现的java.util.concurrent.未来接口：https://docs.oracle.com/javase/8/docs/api/java/util/concurrent/CompletableFuture.html

在CompletableFuture上我没有看到失败的方法，我只看到“resolve（）”。

所以我的猜测是，让完全未来失败的唯一方法是抛出一个例外？

CompletableFuture<String> f = CompletableFuture.supplyAsync(() -> {
    throw new RuntimeException("fail this future");
    return "This would be the success result";
});

除了抛出一个错误，还有什么方法可以让一个完整的未来“失败”吗？换句话说，使用Vertx Future，我们只调用f.fail（），但是对于CompletableFuture呢？

Answer 1

鼓励您抛出异常从供应Async（）方法来描述失败。

如评论中所述，还有一个completeeexceptionaly（）方法，如果您手头有一个未来，并且希望失败，可以使用该方法。

https://docs.oracle.com/javase/8/docs/api/java/util/concurrent/CompletableFuture.html#completeExceptionally-爪哇。可丢弃的-

自Java9以来，如果您想返回一个已经失败的未来，还有CompletableFuture.failedFuture（Throwable ex）构造。

https://docs.oracle.com/javase/9/docs/api/java/util/concurrent/CompletableFuture.html#failedFuture-java.lang.Throwable-