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

使用Promise的程序包

程序包	说明
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.pool	Implementations and API for Channel pools.
io.netty.example.socksproxy
io.netty.handler.ssl	SSL · TLS implementation based on SSLEngine
io.netty.util.concurrent	Utility classes for concurrent / async tasks.
io.netty.util.internal	Internal-use-only utilities which is not allowed to be used outside Netty.

io.netty.channel中Promise的使用

io.netty.channel中Promise的子接口

限定符和类型	接口和说明
interface	ChannelProgressivePromise Special ChannelPromise which will be notified once the associated bytes is transferring.
interface	ChannelPromise Special ChannelFuture which is writable.

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

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

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

参数类型为Promise的io.netty.channel.pool中的方法

限定符和类型	方法和说明
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.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.example.socksproxy中Promise的使用

参数类型为Promise的io.netty.example.socksproxy中的构造器

构造器和说明
DirectClientHandler(Promise<Channel> promise)

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

参数类型为Promise的io.netty.handler.ssl中的方法

限定符和类型	方法和说明
Future<Channel>	SslHandler.renegotiate(Promise<Channel> promise) Performs TLS renegotiation.

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

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

限定符和类型	接口和说明
interface	ProgressivePromise<V> Special ProgressiveFuture which is writable.

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

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

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

限定符和类型	方法和说明
Promise<V>	Promise.addListener(GenericFutureListener<? extends Future<? super V>> listener)
Promise<V>	DefaultPromise.addListener(GenericFutureListener<? extends Future<? super V>> listener)
Promise<V>	Promise.addListeners(GenericFutureListener<? extends Future<? super V>>... listeners)
Promise<V>	DefaultPromise.addListeners(GenericFutureListener<? extends Future<? super V>>... listeners)
Promise<V>	Promise.await()
Promise<V>	DefaultPromise.await()
Promise<V>	Promise.awaitUninterruptibly()
Promise<V>	DefaultPromise.awaitUninterruptibly()
<V> Promise<V>	UnorderedThreadPoolEventExecutor.newPromise()
<V> Promise<V>	ImmediateEventExecutor.newPromise()
<V> Promise<V>	EventExecutor.newPromise() Return a new Promise.
<V> Promise<V>	AbstractEventExecutor.newPromise()
Promise<V>	Promise.removeListener(GenericFutureListener<? extends Future<? super V>> listener)
Promise<V>	DefaultPromise.removeListener(GenericFutureListener<? extends Future<? super V>> listener)
Promise<V>	Promise.removeListeners(GenericFutureListener<? extends Future<? super V>>... listeners)
Promise<V>	DefaultPromise.removeListeners(GenericFutureListener<? extends Future<? super V>>... listeners)
Promise<V>	Promise.setFailure(java.lang.Throwable cause) Marks this future as a failure and notifies all listeners.
Promise<V>	DefaultPromise.setFailure(java.lang.Throwable cause)
Promise<V>	Promise.setSuccess(V result) Marks this future as a success and notifies all listeners.
Promise<V>	DefaultPromise.setSuccess(V result)
Promise<V>	Promise.sync()
Promise<V>	DefaultPromise.sync()
Promise<V>	Promise.syncUninterruptibly()
Promise<V>	DefaultPromise.syncUninterruptibly()

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

限定符和类型	方法和说明
void	PromiseCombiner.add(Promise promise)
PromiseAggregator<V,F>	PromiseAggregator.add(Promise<V>... promises) 已过时。 Add the given Promises to the aggregator.
void	PromiseCombiner.addAll(Promise... promises)
static <X> void	UnaryPromiseNotifier.cascadeTo(Future<X> completedFuture, Promise<? super X> promise)
void	PromiseCombiner.finish(Promise<java.lang.Void> aggregatePromise)

参数类型为Promise的io.netty.util.concurrent中的构造器

构造器和说明
PromiseAggregator(Promise<java.lang.Void> aggregatePromise) 已过时。 See PromiseAggregator.PromiseAggregator(Promise, boolean).
PromiseAggregator(Promise<java.lang.Void> aggregatePromise, boolean failPending) 已过时。 Creates a new instance.
PromiseNotifier(boolean logNotifyFailure, Promise<? super V>... promises) Create a new instance.
PromiseNotifier(Promise<? super V>... promises) Create a new instance.
UnaryPromiseNotifier(Promise<? super T> promise)

io.netty.util.internal中Promise的使用

返回Promise的io.netty.util.internal中的方法

限定符和类型	方法和说明
Promise<java.lang.Void>	PendingWrite.promise()
Promise<java.lang.Void>	PendingWrite.recycleAndGet() Recycle this instance and return the Promise.

参数类型为Promise的io.netty.util.internal中的方法

限定符和类型	方法和说明
static PendingWrite	PendingWrite.newInstance(java.lang.Object msg, Promise<java.lang.Void> promise) Create a new empty RecyclableArrayList instance
static void	PromiseNotificationUtil.tryCancel(Promise<?> p, InternalLogger logger) Try to cancel the Promise and log if logger is not null in case this fails.
static void	PromiseNotificationUtil.tryFailure(Promise<?> p, java.lang.Throwable cause, InternalLogger logger) Try to mark the Promise as failure and log if logger is not null in case this fails.
static <V> void	PromiseNotificationUtil.trySuccess(Promise<? super V> p, V result, InternalLogger logger) Try to mark the Promise as success and log if logger is not null in case this fails.