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

Future.Void介绍

暂无

代码示例

代码示例来源：origin: twitter/distributedlog

@Override
  public Future<Void> asyncClose() {
    return Future.Void();
  }
};

代码示例来源：origin: twitter/distributedlog

@Override
  public Future<Void> asyncAbort() {
    return Future.Void();
  }
};

代码示例来源：origin: twitter/distributedlog

@Override
  public Future<Void> asyncClose() {
    return Future.Void();
  }
}

代码示例来源：origin: twitter/distributedlog

@Override
public Future<Void> execute() {
  return Future.Void();
}

代码示例来源：origin: twitter/distributedlog

Future<Void> unlockHandler() {
  if (null != lockFuture) {
    return lock.asyncClose();
  } else {
    return Future.Void();
  }
}

代码示例来源：origin: twitter/distributedlog

@Override
public Future<Void> setAcceptNewStream(boolean enabled) {
  closeLock.writeLock().lock();
  try {
    logger.info("Set AcceptNewStream = {}", enabled);
    if (ServerStatus.DOWN != serverStatus) {
      if (enabled) {
        serverStatus = ServerStatus.WRITE_AND_ACCEPT;
      } else {
        serverStatus = ServerStatus.WRITE_ONLY;
      }
    }
  } finally {
    closeLock.writeLock().unlock();
  }
  return Future.Void();
}

代码示例来源：origin: twitter/distributedlog

public static Future<Void> asyncClose(@Nullable AsyncCloseable closeable,
                   boolean swallowIOException) {
  if (null == closeable) {
    return Future.Void();
  } else if (swallowIOException) {
    return FutureUtils.ignore(closeable.asyncClose());
  } else {
    return closeable.asyncClose();
  }
}

代码示例来源：origin: twitter/distributedlog

public static Future<Void> asyncAbort(@Nullable AsyncAbortable abortable,
                   boolean swallowIOException) {
  if (null == abortable) {
    return Future.Void();
  } else if (swallowIOException) {
    return FutureUtils.ignore(abortable.asyncAbort());
  } else {
    return abortable.asyncAbort();
  }
}

代码示例来源：origin: twitter/distributedlog

@Override
public Future<Void> asyncClose() {
  // No-op
  this.zooKeeperClient.getWatcherManager().unregisterChildWatcher(logMetadata.getLogSegmentsPath(), this);
  return Future.Void();
}

代码示例来源：origin: twitter/distributedlog

@Override
  public Future<Void> asyncClose() {
    int schedTimeout = conf.getSchedulerShutdownTimeoutMs();
    // Clean up executor state.
    if (ownExecutor) {
      SchedulerUtils.shutdownScheduler(scheduler, schedTimeout, TimeUnit.MILLISECONDS);
      LOG.info("Stopped BKDL executor service for {}.", name);
      if (scheduler != readAheadScheduler) {
        SchedulerUtils.shutdownScheduler(readAheadScheduler, schedTimeout, TimeUnit.MILLISECONDS);
        LOG.info("Stopped BKDL ReadAhead Executor Service for {}.", name);
      }
      SchedulerUtils.shutdownScheduler(getLockStateExecutor(false), schedTimeout, TimeUnit.MILLISECONDS);
      LOG.info("Stopped BKDL Lock State Executor for {}.", name);
    }
    if (ownWriterBKC) {
      writerBKC.close();
    }
    if (ownReaderBKC) {
      readerBKC.close();
    }
    return Future.Void();
  }
};

代码示例来源：origin: twitter/distributedlog

@Override
public Future<Void> asyncClose() {
  LOG.info("Stopping Readahead worker for {}", fullyQualifiedName);
  running = false;
  this.zkc.getWatcherManager()
      .unregisterChildWatcher(this.logMetadata.getLogSegmentsPath(), this);
  // Aside from unfortunate naming of variables, this allows
  // the currently active long poll to be interrupted and completed
  AsyncNotification notification;
  synchronized (notificationLock) {
    notification = metadataNotification;
    metadataNotification = null;
  }
  if (null != notification) {
    notification.notifyOnOperationComplete();
  }
  if (null == stopPromise) {
    return Future.Void();
  }
  return FutureUtils.ignore(FutureUtils.within(
      stopPromise,
      2 * conf.getReadAheadWaitTime(),
      TimeUnit.MILLISECONDS,
      new TimeoutException("Timeout on waiting for ReadAhead worker to stop " + fullyQualifiedName),
      scheduler,
      fullyQualifiedName));
}

代码示例来源：origin: org.apache.distributedlog/distributedlog-service

@Override
public Future<Void> setAcceptNewStream(boolean enabled) {
  closeLock.writeLock().lock();
  try {
    logger.info("Set AcceptNewStream = {}", enabled);
    if (ServerStatus.DOWN != serverStatus) {
      if (enabled) {
        serverStatus = ServerStatus.WRITE_AND_ACCEPT;
      } else {
        serverStatus = ServerStatus.WRITE_ONLY;
      }
    }
  } finally {
    closeLock.writeLock().unlock();
  }
  return Future.Void();
}

代码示例来源：origin: openzipkin/zipkin-finagle

@Override public Future<Void> apply(byte[] responseBytes) {
  TBinaryProtocol iprot = new TBinaryProtocol(new TMemoryInputTransport(responseBytes));
  try {
   if (InternalScribeCodec.readLogResponse(0, iprot)) {
    return Future.Void();
   } else {
    return Future.exception(new IllegalStateException("try later"));
   }
  } catch (Exception e) {
   return Future.exception(e);
  }
 }
};

代码示例来源：origin: pinterest/pinlater

? ackDequeuedJobsImpl(request.getJobAckRequest()) : Future.Void();