异常拆解"/>
Guava1.1—— Future的异常拆解
1.addListener模式对异常的封装
如果用addListener这种方式,setException的异常会被包装,作为ExecutionException的cause,这样捕获到ExecutionException时,用getCause得到的结果进行类型判断,看看是不是想要的业务异常。
final SettableFuture settableFuture = SettableFuture.create();
settableFuture.addListener(new Runnable() {
@Override public void run() {
try {
settableFuture.get();
} catch (InterruptedException e) {
System.out.println("InterruptedException---" + e);
} catch (ExecutionException e) {
System.out.println("ExecutionException---" + e);
System.out.println("ExecutionException_msg---" + e.getMessage());
System.out.println("ExecutionException_cause---" + e.getCause());
if (e.getCause() instanceof NumberFormatException) {
System.out.println("---cause:NumberFormatException---");
}
}
}
}, Executors.newFixedThreadPool(10));
settableFuture.setException(new NumberFormatException("abc"));
2.addCallback对异常的拆解
callback会将封装好的ExecutionException异常拆解开来,详情见Futures类源码的public static <V> void addCallback(...)方法:
catch (ExecutionException e) {
callback.onFailure(e.getCause());//传递的是我们setException的异常
return;
}
上述方法块中将e的cause取出来之后再回调的onFailure方法,所以onFailure方法中得到的已经是我们想要的业务异常了。
final SettableFuture settableFuture = SettableFuture.create();
Futures.addCallback(settableFuture, new FutureCallback() {
@Override public void onSuccess(Object result) {
}
@Override public void onFailure(Throwable e) {
System.out.println("ExecutionException---" + e);
System.out.println("ExecutionException_msg---" + e.getMessage());
System.out.println("ExecutionException_cause---" + e.getCause());
// 这里的getCause得到的结果会使Null,因为e已经是getCause得到的结果了
if (e.getCause() instanceof NumberFormatException) {
System.out.println("---cause:NumberFormatException---");
}
// 这里的e是setException时候的异常类型
if (e instanceof NumberFormatException) {
System.out.println("---e:NumberFormatException---");
}
}
}, Executors.newFixedThreadPool(1));
settableFuture.setException(new NumberFormatException("abc"));
更多推荐
Guava1.1—— Future的异常拆解
发布评论