com.twitter.util.Future.Done()方法的使用及代码示例

x33g5p2x  于2022-01-19 转载在 其他  
字(1.1k)|赞(0)|评价(0)|浏览(142)

本文整理了Java中com.twitter.util.Future.Done()方法的一些代码示例,展示了Future.Done()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Future.Done()方法的具体详情如下:
包路径:com.twitter.util.Future
类名称:Future
方法名:Done

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();
 }
},

相关文章