接口的使用
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.codec.http2	Benchmarks for io.netty.handler.codec.http2.
io.netty.handler.ssl	SSL · TLS implementation based on SSLEngine
io.netty.resolver	Resolves an arbitrary string that represents the name of an endpoint into an address.
io.netty.resolver.dns	An alternative to Java's built-in domain name lookup mechanism that resolves a domain name asynchronously, which supports the queries of an arbitrary DNS record type as well.
io.netty.util	Benchmarks for io.netty.util.
io.netty.util.concurrent	Benchmarks for io.netty.util.concurrent.
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.
class	DelegatingChannelPromiseNotifier
class	VoidChannelPromise

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.codec.http2中Promise的使用

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

限定符和类型	方法和说明
Future<java.lang.Void>	Http2Connection.close(Promise<java.lang.Void> promise) Close this connection.
Future<java.lang.Void>	DefaultHttp2Connection.close(Promise<java.lang.Void> promise)
Future<Http2StreamChannel>	Http2StreamChannelBootstrap.open(Promise<Http2StreamChannel> promise) Open a new Http2StreamChannel to use and notifies the given Promise.
void	Http2StreamChannelBootstrap.open0(ChannelHandlerContext ctx, Promise<Http2StreamChannel> promise) 已过时。 should not be used directly. Use Http2StreamChannelBootstrap.open() or Http2StreamChannelBootstrap.open(Promise)

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

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

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

io.netty.resolver中Promise的使用

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

限定符和类型	方法和说明
protected void	InetSocketAddressResolver.doResolve(java.net.InetSocketAddress unresolvedAddress, Promise<java.net.InetSocketAddress> promise)
protected void	NoopAddressResolver.doResolve(java.net.SocketAddress unresolvedAddress, Promise<java.net.SocketAddress> promise)
protected void	RoundRobinInetAddressResolver.doResolve(java.lang.String inetHost, Promise<java.net.InetAddress> promise)
protected void	DefaultNameResolver.doResolve(java.lang.String inetHost, Promise<java.net.InetAddress> promise)
protected abstract void	SimpleNameResolver.doResolve(java.lang.String inetHost, Promise<T> promise) Invoked by SimpleNameResolver.resolve(String) to perform the actual name resolution.
protected void	CompositeNameResolver.doResolve(java.lang.String inetHost, Promise<T> promise)
protected abstract void	AbstractAddressResolver.doResolve(T unresolvedAddress, Promise<T> promise) Invoked by AbstractAddressResolver.resolve(SocketAddress) to perform the actual name resolution.
protected void	InetSocketAddressResolver.doResolveAll(java.net.InetSocketAddress unresolvedAddress, Promise<java.util.List<java.net.InetSocketAddress>> promise)
protected void	NoopAddressResolver.doResolveAll(java.net.SocketAddress unresolvedAddress, Promise<java.util.List<java.net.SocketAddress>> promise)
protected void	RoundRobinInetAddressResolver.doResolveAll(java.lang.String inetHost, Promise<java.util.List<java.net.InetAddress>> promise)
protected void	DefaultNameResolver.doResolveAll(java.lang.String inetHost, Promise<java.util.List<java.net.InetAddress>> promise)
protected abstract void	SimpleNameResolver.doResolveAll(java.lang.String inetHost, Promise<java.util.List<T>> promise) Invoked by SimpleNameResolver.resolveAll(String) to perform the actual name resolution.
protected void	CompositeNameResolver.doResolveAll(java.lang.String inetHost, Promise<java.util.List<T>> promise)
protected abstract void	AbstractAddressResolver.doResolveAll(T unresolvedAddress, Promise<java.util.List<T>> promise) Invoked by AbstractAddressResolver.resolveAll(SocketAddress) to perform the actual name resolution.
Future<T>	AddressResolver.resolve(java.net.SocketAddress address, Promise<T> promise) Resolves the specified address.
Future<T>	AbstractAddressResolver.resolve(java.net.SocketAddress address, Promise<T> promise)
Future<T>	SimpleNameResolver.resolve(java.lang.String inetHost, Promise<T> promise)
Future<T>	NameResolver.resolve(java.lang.String inetHost, Promise<T> promise) Resolves the specified name into an address.
Future<java.util.List<T>>	AddressResolver.resolveAll(java.net.SocketAddress address, Promise<java.util.List<T>> promise) Resolves the specified address.
Future<java.util.List<T>>	AbstractAddressResolver.resolveAll(java.net.SocketAddress address, Promise<java.util.List<T>> promise)
Future<java.util.List<T>>	SimpleNameResolver.resolveAll(java.lang.String inetHost, Promise<java.util.List<T>> promise)
Future<java.util.List<T>>	NameResolver.resolveAll(java.lang.String inetHost, Promise<java.util.List<T>> promise) Resolves the specified host name and port into a list of address.

io.netty.resolver.dns中Promise的使用

参数类型为Promise的io.netty.resolver.dns中的方法

限定符和类型	方法和说明
protected void	DnsNameResolver.doResolve(java.lang.String inetHost, DnsRecord[] additionals, Promise<java.net.InetAddress> promise, DnsCache resolveCache) Hook designed for extensibility so one can pass a different cache on each resolution attempt instead of using the global one.
protected void	DnsNameResolver.doResolve(java.lang.String inetHost, Promise<java.net.InetAddress> promise)
protected void	DnsNameResolver.doResolveAll(java.lang.String inetHost, DnsRecord[] additionals, Promise<java.util.List<java.net.InetAddress>> promise, DnsCache resolveCache) Hook designed for extensibility so one can pass a different cache on each resolution attempt instead of using the global one.
protected void	DnsNameResolver.doResolveAll(java.lang.String inetHost, Promise<java.util.List<java.net.InetAddress>> promise)
Future<AddressedEnvelope<DnsResponse,java.net.InetSocketAddress>>	DnsNameResolver.query(DnsQuestion question, Promise<AddressedEnvelope<? extends DnsResponse,java.net.InetSocketAddress>> promise) Sends a DNS query with the specified question.
Future<AddressedEnvelope<DnsResponse,java.net.InetSocketAddress>>	DnsNameResolver.query(java.net.InetSocketAddress nameServerAddr, DnsQuestion question, java.lang.Iterable<DnsRecord> additionals, Promise<AddressedEnvelope<? extends DnsResponse,java.net.InetSocketAddress>> promise) Sends a DNS query with the specified question with additional records using the specified name server list.
Future<AddressedEnvelope<DnsResponse,java.net.InetSocketAddress>>	DnsNameResolver.query(java.net.InetSocketAddress nameServerAddr, DnsQuestion question, Promise<AddressedEnvelope<? extends DnsResponse,java.net.InetSocketAddress>> promise) Sends a DNS query with the specified question using the specified name server list.
Future<java.net.InetAddress>	DnsNameResolver.resolve(java.lang.String inetHost, java.lang.Iterable<DnsRecord> additionals, Promise<java.net.InetAddress> promise) Resolves the specified name into an address.
Future<java.util.List<DnsRecord>>	DnsNameResolver.resolveAll(DnsQuestion question, java.lang.Iterable<DnsRecord> additionals, Promise<java.util.List<DnsRecord>> promise) Resolves the DnsRecords that are matched by the specified DnsQuestion.
Future<java.util.List<java.net.InetAddress>>	DnsNameResolver.resolveAll(java.lang.String inetHost, java.lang.Iterable<DnsRecord> additionals, Promise<java.util.List<java.net.InetAddress>> promise) Resolves the specified host name and port into a list of address.

io.netty.util中Promise的使用

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

限定符和类型	方法和说明
Future<OUT>	AsyncMapping.map(IN input, Promise<OUT> promise) Returns the Future that will provide the result of the mapping.

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) 已过时。 Replaced by PromiseCombiner.add(Future).
PromiseAggregator<V,F>	PromiseAggregator.add(Promise<V>... promises) 已过时。 Add the given Promises to the aggregator.
void	PromiseCombiner.addAll(Promise... promises) 已过时。 Replaced by PromiseCombiner.addAll(Future[])
static <V,F extends Future<V>> F	PromiseNotifier.cascade(boolean logNotifyFailure, F future, Promise<? super V> promise) Link the Future and Promise such that if the Future completes the Promise will be notified.
static <V,F extends Future<V>> F	PromiseNotifier.cascade(F future, Promise<? super V> promise) Link the Future and Promise such that if the Future completes the Promise will be notified.
static <X> void	UnaryPromiseNotifier.cascadeTo(Future<X> completedFuture, Promise<? super X> promise) 已过时。
void	PromiseCombiner.finish(Promise<java.lang.Void> aggregatePromise) Sets the promise to be notified when all combined futures have finished.

参数类型为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.