本文整理了Java中com.twitter.util.Future.onFailure()
方法的一些代码示例,展示了Future.onFailure()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Future.onFailure()
方法的具体详情如下:
包路径:com.twitter.util.Future
类名称:Future
方法名:onFailure
暂无
代码示例来源:origin: twitter/distributedlog
void deleteLedger(final long ledgerId) {
final Future<Void> deleteFuture = bkc.deleteLedger(ledgerId, true);
synchronized (ledgerDeletions) {
ledgerDeletions.add(deleteFuture);
}
deleteFuture.onFailure(new AbstractFunction1<Throwable, BoxedUnit>() {
@Override
public BoxedUnit apply(Throwable cause) {
LOG.error("Error deleting ledger {} for ledger allocator {}, retrying : ",
new Object[] { ledgerId, allocatePath, cause });
if (!isClosing()) {
deleteLedger(ledgerId);
}
return BoxedUnit.UNIT;
}
}).ensure(new AbstractFunction0<BoxedUnit>() {
@Override
public BoxedUnit apply() {
synchronized (ledgerDeletions) {
ledgerDeletions.remove(deleteFuture);
}
return BoxedUnit.UNIT;
}
});
}
代码示例来源:origin: twitter/distributedlog
private void closeReader() {
if (null != reader) {
reader.asyncClose().onFailure(new AbstractFunction1<Throwable, BoxedUnit>() {
@Override
public BoxedUnit apply(Throwable cause) {
LOG.warn("Exception on closing reader {} : ", readerName, cause);
return BoxedUnit.UNIT;
}
});
}
}
代码示例来源:origin: twitter/distributedlog
return writer;
}).onFailure(new AbstractFunction1<Throwable, BoxedUnit>() {
@Override
public BoxedUnit apply(Throwable cause) {
代码示例来源:origin: org.apache.distributedlog/distributedlog-service
return BoxedUnit.UNIT;
}).onFailure(new Function<Throwable, BoxedUnit>() {
@Override
public BoxedUnit apply(Throwable t) {
内容来源于网络,如有侵权,请联系作者删除!