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

Future.cause介绍

[英]Returns the cause of the failed I/O operation if the I/O operation has failed.
[中]如果I/O操作失败，则返回I/O操作失败的原因。

代码示例

代码示例来源：origin: netty/netty

@Override
  public void operationComplete(Future<?> future) throws Exception {
    ++doneCount;
    if (!future.isSuccess() && cause == null) {
      cause = future.cause();
    }
    if (doneCount == expectedCount && doneAdding) {
      tryPromise();
    }
  }
};

代码示例来源：origin: netty/netty

@Override
  public void operationComplete(Future<SocketAddress> future) throws Exception {
    if (future.cause() != null) {
      channel.close();
      promise.setFailure(future.cause());
    } else {
      doConnect(future.getNow(), localAddress, promise);
    }
  }
});

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

@Override
  public void operationComplete(Future<Long> future) throws Exception {
    if (future.isSuccess()) {
      count.addAndGet(future.getNow());
    } else {
      failed.set(future.cause());
    }
    checkExecution(result, failed, count, executed);
  }
};

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

@Override
  public void operationComplete(Future<Long> future) throws Exception {
    if (future.isSuccess()) {
      count.addAndGet(future.getNow());
    } else {
      failed.set(future.cause());
    }
    checkExecution(result, failed, count, executed);
  }
};

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

@Override
  public void operationComplete(Future<?> future) throws Exception {
    ++doneCount;
    if (!future.isSuccess() && cause == null) {
      cause = future.cause();
    }
    if (doneCount == expectedCount && doneAdding) {
      tryPromise();
    }
  }
};

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

@Override
  public void operationComplete(Future<SocketAddress> future) throws Exception {
    if (future.cause() != null) {
      channel.close();
      promise.setFailure(future.cause());
    } else {
      doConnect(future.getNow(), localAddress, promise);
    }
  }
});

代码示例来源：origin: netty/netty

@Override
  public void operationComplete(Future<T> future) throws Exception {
    if (future.isSuccess()) {
      promise.setSuccess(future.getNow());
    } else {
      doResolveRec(inetHost, promise, resolverIndex + 1, future.cause());
    }
  }
});

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

@Override
  public void operationComplete(Future<Void> future) throws Exception {
    if (future.isSuccess()) {
      runnable.run();
    } else {
      promise.tryFailure(future.cause());
    }
  }
});

代码示例来源：origin: netty/netty

@Override
  public void operationComplete(Future<List<T>> future) throws Exception {
    if (future.isSuccess()) {
      promise.setSuccess(future.getNow());
    } else {
      doResolveAllRec(inetHost, promise, resolverIndex + 1, future.cause());
    }
  }
});

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

@Override
  public void operationComplete(Future<Void> future) throws Exception {
    if (future.isSuccess()) {
      runnable.run();
    } else {
      promise.tryFailure(future.cause());
    }
  }
});

代码示例来源：origin: netty/netty

@Override
  public void operationComplete(Future<InetAddress> future) throws Exception {
    if (future.isSuccess()) {
      promise.setSuccess(new InetSocketAddress(future.getNow(), unresolvedAddress.getPort()));
    } else {
      promise.setFailure(future.cause());
    }
  }
});

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

@Override
  public void operationComplete(Future<PubSubConnectionEntry> future) throws Exception {
    if (!future.isSuccess()) {
      ((RPromise<RedisPubSubConnection>)connFuture).tryFailure(future.cause());
    }
  }
});

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

@Override
  public void operationComplete(Future<T> future) throws Exception {
    if (future.isSuccess()) {
      promise.setSuccess(future.getNow());
    } else {
      doResolveRec(inetHost, promise, resolverIndex + 1, future.cause());
    }
  }
});

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

@Override
  public void operationComplete(Future<Void> future) throws Exception {
    if (!future.isSuccess()) {
      promise.tryFailure(future.cause());
      return;
    }
    
    putAllAsync(batch, iter, counter, batchSize, promise);
  }
});

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

@Override
  public void operationComplete(Future<List<InetAddress>> future) {
    if (future.isSuccess()) {
      trySuccess(promise, future.getNow().get(0));
    } else {
      tryFailure(promise, future.cause());
    }
  }
});

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

@Override
  public void operationComplete(Future<Void> future) throws Exception {
    if (future.isSuccess()) {
      runnable.run();
    } else {
      promise.tryFailure(future.cause());
    }
  }
});

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

@Override
  public void operationComplete(Future<List<T>> future) throws Exception {
    if (future.isSuccess()) {
      promise.setSuccess(future.getNow());
    } else {
      doResolveAllRec(inetHost, promise, resolverIndex + 1, future.cause());
    }
  }
});

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

@Override
  public void operationComplete(Future<PubSubConnectionEntry> future) throws Exception {
    if (!future.isSuccess()) {
      ((RPromise<RedisPubSubConnection>)connFuture).tryFailure(future.cause());
    }
  }
});

代码示例来源：origin: netty/netty

@Override
  public void operationComplete(Future<List<InetAddress>> future) throws Exception {
    if (future.isSuccess()) {
      List<InetAddress> inetAddresses = future.getNow();
      List<InetSocketAddress> socketAddresses =
          new ArrayList<InetSocketAddress>(inetAddresses.size());
      for (InetAddress inetAddress : inetAddresses) {
        socketAddresses.add(new InetSocketAddress(inetAddress, unresolvedAddress.getPort()));
      }
      promise.setSuccess(socketAddresses);
    } else {
      promise.setFailure(future.cause());
    }
  }
});

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

@Override
  public void operationComplete(Future<Void> future) throws Exception {
    if (!future.isSuccess()) {
      result.tryFailure(future.cause());
      return;
    }
    
    if (counter.decrementAndGet() == 0) {
      result.trySuccess(null);
    }
  }
});