ListenableFuture-在接收到集群中的消息并执行耗时的代码后完成

请参阅Akka有关期货的文档: http://doc.akka.io/docs/akka/current/java/futures.html

您可以创建两个不同的未来,一个执行耗时的代码:

Future<String> f1 = future(new Callable<String>() {
  public String call() {
    return "Hello" + "World";
  }
}, system.dispatcher());

另一个是给演员发信息 ask

Timeout timeout = new Timeout(Duration.create(5, "seconds"));
Future<Object> f2 = Patterns.ask(actor, msg, timeout);

Future.sequence

Iterable<Future<Integer>> listOfFutureInts = source;
Future<Iterable<Integer>> futureListOfInts = sequence(listOfFutureInts, ec);

我是这样解决的。我创建了 ListenableFuture CountDownLatch 并将其(使用creator)传递给akka actor。这一可倾听的未来随后被 countDownLatch.await() countDownLatch.countDown() . 这打通了未来的障碍 await() 调用和future finished并返回值。