本文整理了Java中com.twitter.util.Future.Done()
方法的一些代码示例,展示了Future.Done()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Future.Done()
方法的具体详情如下:
包路径:com.twitter.util.Future
类名称:Future
方法名:Done
暂无
代码示例来源:origin: twitter/distributedlog
/**
* Advances the position associated with the subscriber
*
* @param newPosition - new commit position
*/
@Override
public Future<BoxedUnit> advanceCommitPosition(DLSN newPosition) {
if (null == lastCommittedPosition.get() ||
(newPosition.compareTo(lastCommittedPosition.get()) > 0)) {
lastCommittedPosition.set(newPosition);
return Utils.zkAsyncCreateFullPathOptimisticAndSetData(zooKeeperClient,
zkPath, newPosition.serialize().getBytes(Charsets.UTF_8),
zooKeeperClient.getDefaultACL(),
CreateMode.PERSISTENT);
} else {
return Future.Done();
}
}
}
代码示例来源:origin: io.zipkin.finagle2/zipkin-finagle-kafka
@Override public Future<BoxedUnit> close(Time deadline) {
kafka.close(); // TODO: blocking
return Future.Done();
}
},
代码示例来源:origin: openzipkin/zipkin-finagle
@Override public Future<BoxedUnit> close(Time deadline) {
kafka.close(); // TODO: blocking
return Future.Done();
}
},
内容来源于网络,如有侵权,请联系作者删除!