我有一个异步发送消息列表的方法。每个发送都返回ApiFuture<String>（番石榴ListenableFuture的GCP版本）。我需要此方法来返回一个Future<Boolean>，所以我
在每个ApiFuture<String>上创建一个列表依赖项
使用ApiFuture<List<String>>方法将生成的Future<Boolean>转换为ApiFutures.transform
ApiFuture< List < String > > allSentFuture = ApiFutures.allAsList(futures);
return ApiFutures.transform(allSentFuture, val -> {
return true;
},
Executors.newCachedThreadPool()
);
我的问题是：如果一个或多个原始期货失败/取消，则上述lambda的
val参数的值是多少？在这种情况下，甚至会调用lambda吗？谢谢！
最佳答案
ApiFuture<V>在类型V上形成monad，并且transform将函数应用于类型为V的封装值。如果ApiFuture<V>因为失败或取消而不包含V值，则转换后的将来是相同的。
如果要处理由于异常导致的故障，则可以使用ApiFutures.catching()产生替代结果（例如Boolean.FALSE）。
如果您想将取消转换为成功的值，我相信您将需要直接使用ApiFuture.addListener，并让侦听器完成您返回的SettableApiFuture。然后，侦听器（取消源未来时将被调用）可以检查isCancelled来检测这种情况，或者可以捕获并处理CancellationException。
例如：
/**
* Adapt an iterable of {@link ApiFuture} instances into a single {@code ApiFuture}.
*/
static <T> ApiFuture<Boolean> adaptFutures(Iterable<ApiFuture<T>> futures) {
final SettableApiFuture<Boolean> result = SettableApiFuture.create();
final ApiFuture<List<T>> allFutures = ApiFutures.allAsList(futures);
allFutures.addListener(
() -> {
if (allFutures.isCancelled()) {
result.set(Boolean.FALSE);
return;
}
try {
allFutures.get();
result.set(Boolean.TRUE);
} catch (ExecutionException | InterruptedException ex) {
// Maybe log something here?
//
// Note that InterruptedException is actually impossible here
// because we're running in the listener callback, but the API
// still marks it as potentially thrown by .get() above.
//
// So if we reach here it means that the allAsList future failed.
result.set(Boolean.FALSE);
}
},
// Not normally safe, but we know our listener runs fast enough
// to run inline on the thread that completes the last future.
Runnable::run);
return result;
}