接口 io.netty.util.concurrent.Future
的使用

使用Future的程序包

程序包	说明
io.netty.channel	The core channel API which is asynchronous and event-driven abstraction of various transports such as a NIO Channel.
io.netty.channel.group	A channel registry which helps a user maintain the list of open Channels and perform bulk operations on them.
io.netty.channel.pool	Implementations and API for Channel pools.
io.netty.handler.ssl	SSL · TLS implementation based on SSLEngine
io.netty.util.concurrent	Utility classes for concurrent / async tasks.

io.netty.channel中Future的使用

io.netty.channel中Future的子接口

限定符和类型	接口和说明
interface	ChannelFuture The result of an asynchronous Channel I/O operation.
interface	ChannelProgressiveFuture An special ChannelFuture which is used to indicate the FileRegion transfer progress
interface	ChannelProgressivePromise Special ChannelPromise which will be notified once the associated bytes is transferring.
interface	ChannelPromise Special ChannelFuture which is writable.

实现Future的io.netty.channel中的类

限定符和类型	类和说明
class	DefaultChannelProgressivePromise The default ChannelProgressivePromise implementation.
class	DefaultChannelPromise The default ChannelPromise implementation.

返回Future的io.netty.channel中的方法

限定符和类型	方法和说明
Future<?>	ThreadPerChannelEventLoopGroup.shutdownGracefully(long quietPeriod, long timeout, java.util.concurrent.TimeUnit unit)
Future<?>	ThreadPerChannelEventLoopGroup.terminationFuture()

类型变量类型为Future的io.netty.channel中的方法参数

限定符和类型	方法和说明
ChannelPromise	DefaultChannelPromise.addListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener)
ChannelProgressivePromise	DefaultChannelProgressivePromise.addListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener)
ChannelPromise	ChannelPromise.addListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener)
ChannelProgressivePromise	ChannelProgressivePromise.addListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener)
ChannelProgressiveFuture	ChannelProgressiveFuture.addListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener)
ChannelFuture	ChannelFuture.addListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener)
ChannelPromise	DefaultChannelPromise.removeListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener)
ChannelProgressivePromise	DefaultChannelProgressivePromise.removeListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener)
ChannelPromise	ChannelPromise.removeListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener)
ChannelProgressivePromise	ChannelProgressivePromise.removeListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener)
ChannelProgressiveFuture	ChannelProgressiveFuture.removeListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener)
ChannelFuture	ChannelFuture.removeListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener)

io.netty.channel.group中Future的使用

io.netty.channel.group中Future的子接口

限定符和类型	接口和说明
interface	ChannelGroupFuture The result of an asynchronous ChannelGroup operation.

类型变量类型为Future的io.netty.channel.group中的方法参数

限定符和类型	方法和说明
ChannelGroupFuture	ChannelGroupFuture.addListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener)
ChannelGroupFuture	ChannelGroupFuture.removeListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener)

io.netty.channel.pool中Future的使用

返回Future的io.netty.channel.pool中的方法

限定符和类型	方法和说明
Future<Channel>	SimpleChannelPool.acquire()
Future<Channel>	ChannelPool.acquire() Acquire a Channel from this ChannelPool.
Future<Channel>	SimpleChannelPool.acquire(Promise<Channel> promise)
Future<Channel>	FixedChannelPool.acquire(Promise<Channel> promise)
Future<Channel>	ChannelPool.acquire(Promise<Channel> promise) Acquire a Channel from this ChannelPool.
Future<java.lang.Boolean>	ChannelHealthChecker.isHealthy(Channel channel) Check if the given channel is healthy which means it can be used.
Future<java.lang.Void>	SimpleChannelPool.release(Channel channel)
Future<java.lang.Void>	ChannelPool.release(Channel channel) Release a Channel back to this ChannelPool.
Future<java.lang.Void>	SimpleChannelPool.release(Channel channel, Promise<java.lang.Void> promise)
Future<java.lang.Void>	FixedChannelPool.release(Channel channel, Promise<java.lang.Void> promise)
Future<java.lang.Void>	ChannelPool.release(Channel channel, Promise<java.lang.Void> promise) Release a Channel back to this ChannelPool.

io.netty.handler.ssl中Future的使用

返回Future的io.netty.handler.ssl中的方法

限定符和类型	方法和说明
Future<Channel>	SslHandler.handshakeFuture() Returns a Future that will get notified once the current TLS handshake completes.
Future<Channel>	SslHandler.renegotiate() Performs TLS renegotiation.
Future<Channel>	SslHandler.renegotiate(Promise<Channel> promise) Performs TLS renegotiation.
Future<Channel>	SslHandler.sslCloseFuture() Return the Future that will get notified if the inbound of the SSLEngine is closed.

io.netty.util.concurrent中Future的使用

类型参数类型为Future的io.netty.util.concurrent中的类

限定符和类型	接口和说明
interface	GenericFutureListener<F extends Future<?>> Listens to the result of a Future.
class	PromiseAggregator<V,F extends Future<V>> 已过时。 Use PromiseCombiner GenericFutureListener implementation which consolidates multiple Futures into one, by listening to individual Futures and producing an aggregated result (success/failure) when all Futures have completed.
class	PromiseNotifier<V,F extends Future<V>> GenericFutureListener implementation which takes other Promises and notifies them on completion.

io.netty.util.concurrent中Future的子接口

限定符和类型	接口和说明
interface	ProgressiveFuture<V> A Future which is used to indicate the progress of an operation.
interface	ProgressivePromise<V> Special ProgressiveFuture which is writable.
interface	Promise<V> Special Future which is writable.
interface	ScheduledFuture<V> The result of an scheduled asynchronous operation.

实现Future的io.netty.util.concurrent中的类

限定符和类型	类和说明
class	DefaultProgressivePromise<V>
class	DefaultPromise<V>

返回Future的io.netty.util.concurrent中的方法

限定符和类型	方法和说明
Future<V>	Future.addListener(GenericFutureListener<? extends Future<? super V>> listener) Adds the specified listener to this future.
Future<V>	CompleteFuture.addListener(GenericFutureListener<? extends Future<? super V>> listener)
Future<V>	Future.addListeners(GenericFutureListener<? extends Future<? super V>>... listeners) Adds the specified listeners to this future.
Future<V>	CompleteFuture.addListeners(GenericFutureListener<? extends Future<? super V>>... listeners)
Future<V>	Future.await() Waits for this future to be completed.
Future<V>	CompleteFuture.await()
Future<V>	Future.awaitUninterruptibly() Waits for this future to be completed without interruption.
Future<V>	CompleteFuture.awaitUninterruptibly()
<V> Future<V>	UnorderedThreadPoolEventExecutor.newFailedFuture(java.lang.Throwable cause)
<V> Future<V>	EventExecutor.newFailedFuture(java.lang.Throwable cause) Create a new Future which is marked as fakued already.
<V> Future<V>	AbstractEventExecutor.newFailedFuture(java.lang.Throwable cause)
<V> Future<V>	UnorderedThreadPoolEventExecutor.newSucceededFuture(V result)
<V> Future<V>	EventExecutor.newSucceededFuture(V result) Create a new Future which is marked as successes already.
<V> Future<V>	AbstractEventExecutor.newSucceededFuture(V result)
Future<V>	Future.removeListener(GenericFutureListener<? extends Future<? super V>> listener) Removes the first occurrence of the specified listener from this future.
Future<V>	CompleteFuture.removeListener(GenericFutureListener<? extends Future<? super V>> listener)
Future<V>	Future.removeListeners(GenericFutureListener<? extends Future<? super V>>... listeners) Removes the first occurrence for each of the listeners from this future.
Future<V>	CompleteFuture.removeListeners(GenericFutureListener<? extends Future<? super V>>... listeners)
Future<?>	UnorderedThreadPoolEventExecutor.shutdownGracefully()
Future<?>	EventExecutorGroup.shutdownGracefully() Shortcut method for EventExecutorGroup.shutdownGracefully(long, long, TimeUnit) with sensible default values.
Future<?>	AbstractEventExecutorGroup.shutdownGracefully()
Future<?>	AbstractEventExecutor.shutdownGracefully()
Future<?>	UnorderedThreadPoolEventExecutor.shutdownGracefully(long quietPeriod, long timeout, java.util.concurrent.TimeUnit unit)
Future<?>	SingleThreadEventExecutor.shutdownGracefully(long quietPeriod, long timeout, java.util.concurrent.TimeUnit unit)
Future<?>	MultithreadEventExecutorGroup.shutdownGracefully(long quietPeriod, long timeout, java.util.concurrent.TimeUnit unit)
Future<?>	ImmediateEventExecutor.shutdownGracefully(long quietPeriod, long timeout, java.util.concurrent.TimeUnit unit)
Future<?>	GlobalEventExecutor.shutdownGracefully(long quietPeriod, long timeout, java.util.concurrent.TimeUnit unit)
Future<?>	EventExecutorGroup.shutdownGracefully(long quietPeriod, long timeout, java.util.concurrent.TimeUnit unit) Signals this executor that the caller wants the executor to be shut down.
<T> Future<T>	UnorderedThreadPoolEventExecutor.submit(java.util.concurrent.Callable<T> task)
<T> Future<T>	EventExecutorGroup.submit(java.util.concurrent.Callable<T> task)
<T> Future<T>	AbstractEventExecutorGroup.submit(java.util.concurrent.Callable<T> task)
<T> Future<T>	AbstractEventExecutor.submit(java.util.concurrent.Callable<T> task)
Future<?>	UnorderedThreadPoolEventExecutor.submit(java.lang.Runnable task)
Future<?>	EventExecutorGroup.submit(java.lang.Runnable task)
Future<?>	AbstractEventExecutorGroup.submit(java.lang.Runnable task)
Future<?>	AbstractEventExecutor.submit(java.lang.Runnable task)
<T> Future<T>	UnorderedThreadPoolEventExecutor.submit(java.lang.Runnable task, T result)
<T> Future<T>	EventExecutorGroup.submit(java.lang.Runnable task, T result)
<T> Future<T>	AbstractEventExecutorGroup.submit(java.lang.Runnable task, T result)
<T> Future<T>	AbstractEventExecutor.submit(java.lang.Runnable task, T result)
Future<V>	Future.sync() Waits for this future until it is done, and rethrows the cause of the failure if this future failed.
Future<V>	FailedFuture.sync()
Future<V>	CompleteFuture.sync()
Future<V>	Future.syncUninterruptibly() Waits for this future until it is done, and rethrows the cause of the failure if this future failed.
Future<V>	FailedFuture.syncUninterruptibly()
Future<V>	CompleteFuture.syncUninterruptibly()
Future<?>	UnorderedThreadPoolEventExecutor.terminationFuture()
Future<?>	SingleThreadEventExecutor.terminationFuture()
Future<?>	MultithreadEventExecutorGroup.terminationFuture()
Future<?>	ImmediateEventExecutor.terminationFuture()
Future<?>	GlobalEventExecutor.terminationFuture()
Future<?>	EventExecutorGroup.terminationFuture() Returns the Future which is notified when this executor has been terminated.

参数类型为Future的io.netty.util.concurrent中的方法

限定符和类型	方法和说明
static <X> void	UnaryPromiseNotifier.cascadeTo(Future<X> completedFuture, Promise<? super X> promise)
protected static void	DefaultPromise.notifyListener(EventExecutor eventExecutor, Future<?> future, GenericFutureListener<?> listener) Notify a listener that a future has completed.
void	UnaryPromiseNotifier.operationComplete(Future<T> future)

类型变量类型为Future的io.netty.util.concurrent中的方法参数

限定符和类型	方法和说明
Promise<V>	Promise.addListener(GenericFutureListener<? extends Future<? super V>> listener)
ProgressivePromise<V>	ProgressivePromise.addListener(GenericFutureListener<? extends Future<? super V>> listener)
ProgressiveFuture<V>	ProgressiveFuture.addListener(GenericFutureListener<? extends Future<? super V>> listener)
Future<V>	Future.addListener(GenericFutureListener<? extends Future<? super V>> listener) Adds the specified listener to this future.
Promise<V>	DefaultPromise.addListener(GenericFutureListener<? extends Future<? super V>> listener)
ProgressivePromise<V>	DefaultProgressivePromise.addListener(GenericFutureListener<? extends Future<? super V>> listener)
Future<V>	CompleteFuture.addListener(GenericFutureListener<? extends Future<? super V>> listener)
Promise<V>	Promise.removeListener(GenericFutureListener<? extends Future<? super V>> listener)
ProgressivePromise<V>	ProgressivePromise.removeListener(GenericFutureListener<? extends Future<? super V>> listener)
ProgressiveFuture<V>	ProgressiveFuture.removeListener(GenericFutureListener<? extends Future<? super V>> listener)
Future<V>	Future.removeListener(GenericFutureListener<? extends Future<? super V>> listener) Removes the first occurrence of the specified listener from this future.
Promise<V>	DefaultPromise.removeListener(GenericFutureListener<? extends Future<? super V>> listener)
ProgressivePromise<V>	DefaultProgressivePromise.removeListener(GenericFutureListener<? extends Future<? super V>> listener)
Future<V>	CompleteFuture.removeListener(GenericFutureListener<? extends Future<? super V>> listener)