【发布时间】:2014-06-24 17:36:07
【问题描述】:
我正在尝试在 java 中进行 akka 编码,我需要进行阻塞调用。我知道 Await.result 可用于阻止这很好,但我不知道如何获得 Await.result 调用所需的 Awaitable。
这是我可以访问 scala Future 的代码。我需要帮助来获取未来的可等待对象。
final Timeout t = new Timeout(Duration.create(5, TimeUnit.SECONDS));
final ArrayList<Future<Object>> futures = new ArrayList<Future<Object>>();
futures.add(ask(foo, "message", 5000));
final Future<Iterable<Object>> aggregate = Futures.sequence(futures,
this.actorSystem.dispatcher());
【问题讨论】:
标签: java scala akka scala-java-interop