用Java组成阿卡可能失败的未来

Question

我试图在我自己的应用程序中应用未来合成的概念。根据Akka文档，您可以这样做(http://doc.akka.io/docs/akka/snapshot/java/futures.html):

final ExecutionContext ec = system.dispatcher();
//Some source generating a sequence of Future<Integer>:s
Iterable<Future<Integer>> listOfFutureInts = source;

// now we have a Future[Iterable[Integer]]
Future<Iterable<Integer>> futureListOfInts = sequence(listOfFutureInts, ec);

// Find the sum of the odd numbers
Future<Long> futureSum = futureListOfInts.map(
     new Mapper<Iterable<Integer>, Long>() {
          public Long apply(Iterable<Integer> ints) {
              long sum = 0;
              for (Integer i : ints)
                   sum += i;
              return sum;
         }
     }, ec);

futureSum.onSuccess(new PrintResult<Long>(), system.dispatcher());

请记住，我正在使用Akka的Java版本进行开发，因为我对Scala不够熟悉。当你想创作成功的未来作品时，这个方法很好用。在这里，您只是将所有期货（INT）的结果进行汇总，并将其相加，然后将其结果放入另一个可以稍后处理的未来。现在，如果其中一个期货可能失败，即抛出异常，会发生什么。当然，对于任何一个特定的未来，您都可以使用“onFailure”回调来处理失败，但我还没有找到一种在编写futures时处理失败的方法。

最好的方法是什么？我应该完全应用另一个概念吗？

谢谢

Answer 1

您正在查找recover和recoverWith，如下所述：http://doc.akka.io/docs/akka/2.3.2/java/futures.html#Exceptions

final ExecutionContext ec = system.dispatcher();

Future<Integer> future = future(new Callable<Integer>() {
  public Integer call() {
    return 1 / 0;
  }
}, ec).recover(new Recover<Integer>() {
  public Integer recover(Throwable problem) throws Throwable {
    if (problem instanceof ArithmeticException)
      return 0;
    else
      throw problem;
  }
}, ec);

future.onSuccess(new PrintResult<Integer>(), system.dispatcher());