Vert.X：如何等待未来的完成

Question

是否有一种方法可以在不阻塞事件循环的情况下等待一个未来完成？

Future<Result> dbFut = Future.future();
mongo.findOne("myusers", myQuery, new JsonObject(), res -> {
    if(res.succeeded()) {
      ...
      dbFut.complete(res.result());
    }
    else {
      ...
      dbFut.fail(res.cause());
    }
  }
  });

// Here I need the result of the DB query
if(dbFut.succeeded()) {
  doSomethingWith(dbFut.result());
}
else {
  error();
}

maurice@mickey> java \
  -javaagent:~/.m2/repository/co/paralleluniverse/quasar-core/0.7.5/quasar-core-0.7.5-jdk8.jar \
  -jar target/app-dev-0.1-fat.jar \
  -conf conf/config.json 
Error opening zip file or JAR manifest missing : ~/.m2/repository/co/paralleluniverse/quasar-core/0.7.5/quasar-core-0.7.5-jdk8.jar
Error occurred during initialization of VM
agent library failed to init: instrument

我知道这个错误通常意味着什么，但我不知道在这种情况下...我试图在谷歌上搜索它，但没有找到任何关于将哪份清单放在哪里的明确解释。和以前一样，除非是强制性的，我更喜欢一次学一件事。

那么，回到这个问题：“基本”Vert.x是否有一种方法可以在事件循环不受干扰的情况下等待未来？

Answer 1

您可以为将来设置一个处理程序，以便在完成或失败时执行：

Future<Result> dbFut = Future.future();
mongo.findOne("myusers", myQuery, new JsonObject(), res -> {
    if(res.succeeded()) {
      ...
      dbFut.complete(res.result());
    }
    else {
      ...
      dbFut.fail(res.cause());
    }
  }
  });

dbFut.setHandler(asyncResult -> {
    if(asyncResult.succeeded()) {
      // your logic here
    }
});

这是一种不阻塞事件循环的纯Vert.x方式