ListenableFuture 链可以处理内部 ExecutionException 吗？

我提供了一个 api (fnGrpc）执行 gRPC 调用并返回ListenableFuture解析为某个值v（其实现是固定且不可修改的）。

我想提供一个辅助函数（fnHelper) that:

1. 对 gRPC 结果进行一些转换处理，并返回一个ListenableFuture解析为转换后的值t1.

2. 处理 gRPC 调用的失败，并返回一些其他值t2而不是有fnHelper的呼叫者看到ExecutionException.

我可以使用以下方法解决（1）Futures.transform():

package myHelper;

ListenableFuture<T> fnHelper() {
  return Futures.transform(fnGrpc(), new Function<V, T>() {
    @Override
    public T apply(V v) {
      T t1 = f(v);
      return t1;
    }
  });
} 

和来电者：

package myApp;

// ...

try {
  T t = fnHelper().get();
} catch (ExecutionException | InterruptedException ex) {
  // ...
}

我怎样才能实现（2），同时仍然享受乐趣 Helper return aListenableFuture并保持非阻塞？

我本可以有fnHelper它本身创建了一个额外的线程，我将在其中调用.get() on fnGrpc，但是还有另一种方法可以避免这个额外的线程吗？

我不是番石榴专家，但似乎你可以使用相同的方法来做到这一点Futures http://google.github.io/guava/releases/23.0/api/docs/com/google/common/util/concurrent/Futures.html实用程序类，特别是方法catchingAsync http://google.github.io/guava/releases/23.0/api/docs/com/google/common/util/concurrent/Futures.html#catchingAsync-com.google.common.util.concurrent.ListenableFuture-java.lang.Class-com.google.common.util.concurrent.AsyncFunction-java.util.concurrent.Executor-，您可以在其中传递返回一个的函数ListenableFuture与后备值（t2):

ListenableFuture<Integer> faultTolerantFuture = Futures.catchingAsync(originalFuture,
                       Exception.class, x -> immediateFuture(t2), executor);

然后你应该能够将其与transform方法，它进行转换：

ListenableFuture<T> fnHelper() {
    return Futures.catching(Futures.transform(fnGrpc(), new Function<V, T>() {
        @Override
        public T apply(V v) {
            T t1 = f(v);
            return t1;
        }
    }),
    Exception.class, x -> immediateFuture(t2));
}

Note:在最后一个片段中，我使用了catching代替catchingAsync为了与您问题中的代码保持一致，并且我没有指定执行者。您可能需要将这些方法与Async非阻塞处理的后缀。