io.netty.util.concurrent.Promise.awaitUninterruptibly()方法的使用及代码示例

x33g5p2x  于2022-01-26 转载在 其他  
字(2.4k)|赞(0)|评价(0)|浏览(253)

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

Promise.awaitUninterruptibly介绍

暂无

代码示例

代码示例来源:origin: redisson/redisson

@Override
public RPromise<T> awaitUninterruptibly() {
  promise.awaitUninterruptibly();
  return this;
}

代码示例来源:origin: redisson/redisson

@Override
public RPromise<T> awaitUninterruptibly() {
  promise.awaitUninterruptibly();
  return this;
}

代码示例来源:origin: redisson/redisson

@Override
public boolean awaitUninterruptibly(long timeoutMillis) {
  return promise.awaitUninterruptibly(timeoutMillis);
}

代码示例来源:origin: redisson/redisson

@Override
public boolean awaitUninterruptibly(long timeout, TimeUnit unit) {
  return promise.awaitUninterruptibly(timeout, unit);
}

代码示例来源:origin: redisson/redisson

@Override
public boolean awaitUninterruptibly(long timeout, TimeUnit unit) {
  return promise.awaitUninterruptibly(timeout, unit);
}

代码示例来源:origin: redisson/redisson

@Override
public boolean awaitUninterruptibly(long timeoutMillis) {
  return promise.awaitUninterruptibly(timeoutMillis);
}

代码示例来源:origin: line/armeria

@Override
public boolean awaitUninterruptibly(long timeout, TimeUnit unit) {
  return delegate.awaitUninterruptibly(timeout, unit);
}

代码示例来源:origin: line/armeria

@Override
public Promise<T> awaitUninterruptibly() {
  return delegate.awaitUninterruptibly();
}

代码示例来源:origin: line/armeria

@Override
public boolean awaitUninterruptibly(long timeoutMillis) {
  return delegate.awaitUninterruptibly(timeoutMillis);
}

代码示例来源:origin: org.nanoframework/nano-ext-etcd

/**
 * Wait for promise to be done
 *
 * @return true if success, false if fail
 * @throws IOException      on IOException
 * @throws TimeoutException on timeout
 */
protected boolean waitForPromiseSuccess() throws IOException, TimeoutException {
 if (!promise.isDone()) {
  Promise<T> listeningPromise = this.promise;
  listeningPromise.awaitUninterruptibly();
  if (listeningPromise != this.promise) {
   return false;
  }
  this.handlePromise(promise);
 }
 return true;
}

代码示例来源:origin: jurmous/etcd4j

/**
 * Wait for promise to be done
 *
 * @throws IOException      on IOException
 * @throws TimeoutException on timeout
 */
protected void waitForPromiseSuccess() throws IOException, TimeoutException {
 while(!promise.isDone() && !promise.isCancelled()) {
  Promise<T> listeningPromise = this.promise;
  listeningPromise.awaitUninterruptibly();
  if (listeningPromise == this.promise) {
   this.handlePromise(promise);
   break;
  }
 }
}

相关文章