java - 如何捕获异步执行中的 astyanax 失败

Question

我从事的项目使用astyanax驱动程序来访问Cassandra。我想实现一个异步操作:

MutationBatch m;
//…
ListenableFuture<OperationResult<Void>> lf = m.executeAsync();
lf.addListener(myRunnableCallback, myExecutor);

问题:假设在 executeAsync() 调用中没有立即抛出异常，如何区分成功执行和失败执行？

我能想到的唯一方法是，当调用完成回调时，lf.get() 在失败的情况下抛出异常。如果这是正确的方法，astyanax 来源中是否有文档或行确认这一点？

Answer 1

我找到了一个解决方法:而不是 ListenableFuture的addListener服用方法Runnable我可以使用参数Futures.addCallback(ListenableFuture<V>, FutureCallback<V>, Executor) 。 FutureCallback有2个方法:onSuccess和onFailure 。这解决了我的问题。

https://code.google.com/p/guava-libraries/wiki/ListenableFutureExplained