Uses of Interface
io.netty.util.concurrent.Future

Packages that use Future

Package	Description
io.netty.bootstrap	The helper classes with fluent API which enable an easy implementation of typical client side and server side channel initialization.
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.embedded	A virtual Channel that helps wrapping a series of handlers to unit test the handlers or use them in non-I/O context.
io.netty.channel.epoll	Optimized transport for linux which uses EPOLL Edge-Triggered Mode for maximal performance.
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.kqueue	BSD specific transport.
io.netty.channel.local	A virtual transport that enables the communication between the two parties in the same virtual machine.
io.netty.channel.nio	NIO-based channel API implementation - recommended for a large number of connections (>= 1000).
io.netty.channel.pool	Implementations and API for Channel pools.
io.netty.handler.codec.http2	Handlers for sending and receiving HTTP/2 frames.
io.netty.handler.proxy	Adds support for client connections via proxy protocols such as SOCKS and HTTP CONNECT tunneling
io.netty.handler.ssl	SSL · TLS implementation based on SSLEngine
io.netty.handler.timeout	Adds support for read and write timeout and idle connection notification using a Timer.
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	Utility classes used across multiple packages.
io.netty.util.concurrent	Utility classes for concurrent / async tasks.

Uses of Future in io.netty.bootstrap

Classes in io.netty.bootstrap that implement Future

Modifier and Type	Class	Description
(package private) static final class	AbstractBootstrap.PendingRegistrationPromise

Uses of Future in io.netty.channel

Subinterfaces of Future in io.netty.channel

Modifier and Type	Interface	Description
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.

Classes in io.netty.channel that implement Future

Modifier and Type	Class	Description
(package private) static final class	AbstractChannel.CloseFuture
(package private) class	CompleteChannelFuture	A skeletal ChannelFuture implementation which represents a ChannelFuture which has been completed already.
class	DefaultChannelProgressivePromise	The default ChannelProgressivePromise implementation.
class	DefaultChannelPromise	The default ChannelPromise implementation.
final class	DelegatingChannelPromiseNotifier
(package private) final class	FailedChannelFuture	The CompleteChannelFuture which is failed already.
(package private) final class	SucceededChannelFuture	The CompleteChannelFuture which is succeeded already.
final class	VoidChannelPromise

Methods in io.netty.channel that return Future

Modifier and Type	Method	Description
Future<?>	ThreadPerChannelEventLoopGroup.shutdownGracefully(long quietPeriod, long timeout, TimeUnit unit)	Deprecated.
Future<?>	ThreadPerChannelEventLoopGroup.terminationFuture()	Deprecated.

Method parameters in io.netty.channel with type arguments of type Future

Modifier and Type	Method	Description
ChannelFuture	ChannelFuture.addListener(GenericFutureListener<? extends Future<? super Void>> listener)
ChannelProgressiveFuture	ChannelProgressiveFuture.addListener(GenericFutureListener<? extends Future<? super Void>> listener)
ChannelProgressivePromise	ChannelProgressivePromise.addListener(GenericFutureListener<? extends Future<? super Void>> listener)
ChannelPromise	ChannelPromise.addListener(GenericFutureListener<? extends Future<? super Void>> listener)
ChannelFuture	CompleteChannelFuture.addListener(GenericFutureListener<? extends Future<? super Void>> listener)
ChannelProgressivePromise	DefaultChannelProgressivePromise.addListener(GenericFutureListener<? extends Future<? super Void>> listener)
ChannelPromise	DefaultChannelPromise.addListener(GenericFutureListener<? extends Future<? super Void>> listener)
ChannelPromise	DelegatingChannelPromiseNotifier.addListener(GenericFutureListener<? extends Future<? super Void>> listener)
VoidChannelPromise	VoidChannelPromise.addListener(GenericFutureListener<? extends Future<? super Void>> listener)
ChannelFuture	ChannelFuture.removeListener(GenericFutureListener<? extends Future<? super Void>> listener)
ChannelProgressiveFuture	ChannelProgressiveFuture.removeListener(GenericFutureListener<? extends Future<? super Void>> listener)
ChannelProgressivePromise	ChannelProgressivePromise.removeListener(GenericFutureListener<? extends Future<? super Void>> listener)
ChannelPromise	ChannelPromise.removeListener(GenericFutureListener<? extends Future<? super Void>> listener)
ChannelFuture	CompleteChannelFuture.removeListener(GenericFutureListener<? extends Future<? super Void>> listener)
ChannelProgressivePromise	DefaultChannelProgressivePromise.removeListener(GenericFutureListener<? extends Future<? super Void>> listener)
ChannelPromise	DefaultChannelPromise.removeListener(GenericFutureListener<? extends Future<? super Void>> listener)
ChannelPromise	DelegatingChannelPromiseNotifier.removeListener(GenericFutureListener<? extends Future<? super Void>> listener)
VoidChannelPromise	VoidChannelPromise.removeListener(GenericFutureListener<? extends Future<? super Void>> listener)

Uses of Future in io.netty.channel.embedded

Methods in io.netty.channel.embedded that return Future

Modifier and Type	Method	Description
Future<?>	EmbeddedEventLoop.shutdownGracefully(long quietPeriod, long timeout, TimeUnit unit)
Future<?>	EmbeddedEventLoop.terminationFuture()

Uses of Future in io.netty.channel.epoll

Fields in io.netty.channel.epoll declared as Future

Modifier and Type	Field	Description
private Future<?>	AbstractEpollChannel.connectTimeoutFuture

Uses of Future in io.netty.channel.group

Subinterfaces of Future in io.netty.channel.group

Modifier and Type	Interface	Description
interface	ChannelGroupFuture	The result of an asynchronous ChannelGroup operation.

Classes in io.netty.channel.group that implement Future

Modifier and Type	Class	Description
(package private) final class	DefaultChannelGroupFuture	The default ChannelGroupFuture implementation.
(package private) final class	VoidChannelGroupFuture

Method parameters in io.netty.channel.group with type arguments of type Future

Modifier and Type	Method	Description
ChannelGroupFuture	ChannelGroupFuture.addListener(GenericFutureListener<? extends Future<? super Void>> listener)
DefaultChannelGroupFuture	DefaultChannelGroupFuture.addListener(GenericFutureListener<? extends Future<? super Void>> listener)
ChannelGroupFuture	VoidChannelGroupFuture.addListener(GenericFutureListener<? extends Future<? super Void>> listener)
ChannelGroupFuture	ChannelGroupFuture.removeListener(GenericFutureListener<? extends Future<? super Void>> listener)
DefaultChannelGroupFuture	DefaultChannelGroupFuture.removeListener(GenericFutureListener<? extends Future<? super Void>> listener)
ChannelGroupFuture	VoidChannelGroupFuture.removeListener(GenericFutureListener<? extends Future<? super Void>> listener)

Uses of Future in io.netty.channel.kqueue

Fields in io.netty.channel.kqueue declared as Future

Modifier and Type	Field	Description
private Future<?>	AbstractKQueueChannel.connectTimeoutFuture

Uses of Future in io.netty.channel.local

Fields in io.netty.channel.local declared as Future

Modifier and Type	Field	Description
private Future<?>	LocalChannel.finishReadFuture

Fields in io.netty.channel.local with type parameters of type Future

Modifier and Type	Field	Description
private static final AtomicReferenceFieldUpdater<LocalChannel,Future>	LocalChannel.FINISH_READ_FUTURE_UPDATER

Uses of Future in io.netty.channel.nio

Fields in io.netty.channel.nio declared as Future

Modifier and Type	Field	Description
private Future<?>	AbstractNioChannel.connectTimeoutFuture

Uses of Future in io.netty.channel.pool

Methods in io.netty.channel.pool that return Future

Modifier and Type	Method	Description
Future<Channel>	ChannelPool.acquire()	Acquire a Channel from this ChannelPool.
Future<Channel>	ChannelPool.acquire(Promise<Channel> promise)	Acquire a Channel from this ChannelPool.
Future<Channel>	FixedChannelPool.acquire(Promise<Channel> promise)
final Future<Channel>	SimpleChannelPool.acquire()
Future<Channel>	SimpleChannelPool.acquire(Promise<Channel> promise)
private Future<Channel>	SimpleChannelPool.acquireHealthyFromPoolOrNew(Promise<Channel> promise)	Tries to retrieve healthy channel from the pool if any or creates a new channel otherwise.
private Future<Void>	FixedChannelPool.close0()
Future<Void>	FixedChannelPool.closeAsync()	Closes the pool in an async manner.
Future<Void>	SimpleChannelPool.closeAsync()	Closes the pool in an async manner.
Future<Boolean>	ChannelHealthChecker.isHealthy(Channel channel)	Check if the given channel is healthy which means it can be used.
private static Future<Void>	AbstractChannelPoolMap.poolCloseAsyncIfSupported(ChannelPool pool)	If the pool implementation supports asynchronous close, then use it to avoid a blocking close call in case the ChannelPoolMap operations are called from an EventLoop.
Future<Void>	ChannelPool.release(Channel channel)	Release a Channel back to this ChannelPool.
Future<Void>	ChannelPool.release(Channel channel, Promise<Void> promise)	Release a Channel back to this ChannelPool.
Future<Void>	FixedChannelPool.release(Channel channel, Promise<Void> promise)
final Future<Void>	SimpleChannelPool.release(Channel channel)
Future<Void>	SimpleChannelPool.release(Channel channel, Promise<Void> promise)
private Future<Boolean>	AbstractChannelPoolMap.removeAsyncIfSupported(K key)	Remove the ChannelPool from this AbstractChannelPoolMap.

Methods in io.netty.channel.pool with parameters of type Future

Modifier and Type	Method	Description
private void	SimpleChannelPool.notifyHealthCheck(Future<Boolean> future, Channel channel, Promise<Channel> promise)
void	FixedChannelPool.AcquireListener.operationComplete(Future<Channel> future)
private void	SimpleChannelPool.releaseAndOfferIfHealthy(Channel channel, Promise<Void> promise, Future<Boolean> future)	Adds the channel back to the pool only if the channel is healthy.

Uses of Future in io.netty.handler.codec.http2

Classes in io.netty.handler.codec.http2 that implement Future

Modifier and Type	Class	Description
(package private) static final class	Http2CodecUtil.SimpleChannelPromiseAggregator	Provides the ability to associate the outcome of multiple ChannelPromise objects into a single ChannelPromise object.

Fields in io.netty.handler.codec.http2 declared as Future

Modifier and Type	Field	Description
private final Future<?>	Http2ConnectionHandler.ClosingChannelFutureListener.timeoutTask

Methods in io.netty.handler.codec.http2 that return Future

Modifier and Type	Method	Description
Future<Void>	DefaultHttp2Connection.close(Promise<Void> promise)
Future<Void>	Http2Connection.close(Promise<Void> promise)	Close this connection.
Future<Http2StreamChannel>	Http2StreamChannelBootstrap.open()	Open a new Http2StreamChannel to use.
Future<Http2StreamChannel>	Http2StreamChannelBootstrap.open(Promise<Http2StreamChannel> promise)	Open a new Http2StreamChannel to use and notifies the given Promise.

Uses of Future in io.netty.handler.proxy

Classes in io.netty.handler.proxy that implement Future

Modifier and Type	Class	Description
private final class	ProxyHandler.LazyChannelPromise

Fields in io.netty.handler.proxy declared as Future

Modifier and Type	Field	Description
private Future<?>	ProxyHandler.connectTimeoutFuture

Methods in io.netty.handler.proxy that return Future

Modifier and Type	Method	Description
final Future<Channel>	ProxyHandler.connectFuture()	Returns a Future that is notified when the connection to the destination has been established or the connection attempt has failed.

Uses of Future in io.netty.handler.ssl

Classes in io.netty.handler.ssl that implement Future

Modifier and Type	Class	Description
private final class	SslHandler.LazyChannelPromise

Methods in io.netty.handler.ssl that return Future

Modifier and Type	Method	Description
Future<byte[]>	OpenSslAsyncPrivateKeyMethod.decrypt(SSLEngine engine, byte[] input)	Decrypts the input with the given key and notifies the returned Future with the decrypted bytes.
Future<Channel>	SslHandler.handshakeFuture()	Returns a Future that will get notified once the current TLS handshake completes.
protected Future<T>	AbstractSniHandler.lookup(ChannelHandlerContext ctx, ByteBuf clientHello)
protected abstract Future<T>	AbstractSniHandler.lookup(ChannelHandlerContext ctx, String hostname)	Kicks off a lookup for the given SNI value and returns a Future which in turn will notify the AbstractSniHandler.onLookupComplete(ChannelHandlerContext, String, Future) on completion.
protected Future<SslContext>	SniHandler.lookup(ChannelHandlerContext ctx, String hostname)	The default implementation will simply call AsyncMapping.map(Object, Promise) but users can override this method to implement custom behavior.
protected abstract Future<T>	SslClientHelloHandler.lookup(ChannelHandlerContext ctx, ByteBuf clientHello)	Kicks off a lookup for the given ClientHello and returns a Future which in turn will notify the SslClientHelloHandler.onLookupComplete(ChannelHandlerContext, Future) on completion.
Future<SslContext>	SniHandler.AsyncMappingAdapter.map(String input, Promise<SslContext> promise)
Future<Channel>	SslHandler.renegotiate()	Performs TLS renegotiation.
Future<Channel>	SslHandler.renegotiate(Promise<Channel> promise)	Performs TLS renegotiation.
Future<byte[]>	OpenSslAsyncPrivateKeyMethod.sign(SSLEngine engine, int signatureAlgorithm, byte[] input)	Signs the input with the given key and notifies the returned Future with the signed bytes.
Future<Channel>	SslHandler.sslCloseFuture()	Return the Future that will get notified if the inbound of the SSLEngine is closed.

Methods in io.netty.handler.ssl with parameters of type Future

Modifier and Type	Method	Description
private static void	AbstractSniHandler.fireSniCompletionEvent(ChannelHandlerContext ctx, String hostname, Future<?> future)
protected void	AbstractSniHandler.onLookupComplete(ChannelHandlerContext ctx, Future<T> future)
protected abstract void	AbstractSniHandler.onLookupComplete(ChannelHandlerContext ctx, String hostname, Future<T> future)	Called upon completion of the AbstractSniHandler.lookup(ChannelHandlerContext, String) Future.
protected final void	SniHandler.onLookupComplete(ChannelHandlerContext ctx, String hostname, Future<SslContext> future)
protected abstract void	SslClientHelloHandler.onLookupComplete(ChannelHandlerContext ctx, Future<T> future)	Called upon completion of the SslClientHelloHandler.lookup(ChannelHandlerContext, ByteBuf) Future.
void	ReferenceCountedOpenSslContext.AsyncPrivateKeyMethod.ResultCallbackListener.operationComplete(Future<byte[]> future)

Uses of Future in io.netty.handler.timeout

Fields in io.netty.handler.timeout declared as Future

Modifier and Type	Field	Description
private Future<?>	IdleStateHandler.allIdleTimeout
private Future<?>	IdleStateHandler.readerIdleTimeout
(package private) Future<?>	WriteTimeoutHandler.WriteTimeoutTask.scheduledFuture
private Future<?>	IdleStateHandler.writerIdleTimeout

Methods in io.netty.handler.timeout that return Future

Modifier and Type	Method	Description
(package private) Future<?>	IdleStateHandler.schedule(ChannelHandlerContext ctx, Runnable task, long delay, TimeUnit unit)	This method is visible for testing!

Uses of Future in io.netty.resolver

Fields in io.netty.resolver with type parameters of type Future

Modifier and Type	Field	Description
private final Map<EventExecutor,GenericFutureListener<Future<Object>>>	AddressResolverGroup.executorTerminationListeners

Methods in io.netty.resolver that return Future

Modifier and Type	Method	Description
final Future<T>	AbstractAddressResolver.resolve(SocketAddress address)
final Future<T>	AbstractAddressResolver.resolve(SocketAddress address, Promise<T> promise)
Future<T>	AddressResolver.resolve(SocketAddress address)	Resolves the specified address.
Future<T>	AddressResolver.resolve(SocketAddress address, Promise<T> promise)	Resolves the specified address.
Future<T>	NameResolver.resolve(String inetHost)	Resolves the specified name into an address.
Future<T>	NameResolver.resolve(String inetHost, Promise<T> promise)	Resolves the specified name into an address.
final Future<T>	SimpleNameResolver.resolve(String inetHost)
Future<T>	SimpleNameResolver.resolve(String inetHost, Promise<T> promise)
final Future<List<T>>	AbstractAddressResolver.resolveAll(SocketAddress address)
final Future<List<T>>	AbstractAddressResolver.resolveAll(SocketAddress address, Promise<List<T>> promise)
Future<List<T>>	AddressResolver.resolveAll(SocketAddress address)	Resolves the specified address.
Future<List<T>>	AddressResolver.resolveAll(SocketAddress address, Promise<List<T>> promise)	Resolves the specified address.
Future<List<T>>	NameResolver.resolveAll(String inetHost)	Resolves the specified host name and port into a list of address.
Future<List<T>>	NameResolver.resolveAll(String inetHost, Promise<List<T>> promise)	Resolves the specified host name and port into a list of address.
final Future<List<T>>	SimpleNameResolver.resolveAll(String inetHost)
Future<List<T>>	SimpleNameResolver.resolveAll(String inetHost, Promise<List<T>> promise)

Uses of Future in io.netty.resolver.dns

Fields in io.netty.resolver.dns declared as Future

Modifier and Type	Field	Description
private Future<?>	DnsQueryContext.timeoutFuture

Fields in io.netty.resolver.dns with type parameters of type Future

Modifier and Type	Field	Description
private final Map<String,Future<List<InetAddress>>>	DnsNameResolver.inflightLookups
private final Set<Future<AddressedEnvelope<DnsResponse,InetSocketAddress>>>	DnsResolveContext.queriesInProgress

Methods in io.netty.resolver.dns that return Future

Modifier and Type	Method	Description
(package private) final Future<AddressedEnvelope<DnsResponse,InetSocketAddress>>	DnsNameResolver.doQuery(Channel channel, InetSocketAddress nameServerAddr, DnsQuestion question, DnsQueryLifecycleObserver queryLifecycleObserver, DnsRecord[] additionals, boolean flush, Promise<AddressedEnvelope<? extends DnsResponse,InetSocketAddress>> promise)
Future<AddressedEnvelope<DnsResponse,InetSocketAddress>>	DnsNameResolver.query(DnsQuestion question)	Sends a DNS query with the specified question.
Future<AddressedEnvelope<DnsResponse,InetSocketAddress>>	DnsNameResolver.query(DnsQuestion question, Promise<AddressedEnvelope<? extends DnsResponse,InetSocketAddress>> promise)	Sends a DNS query with the specified question.
Future<AddressedEnvelope<DnsResponse,InetSocketAddress>>	DnsNameResolver.query(DnsQuestion question, Iterable<DnsRecord> additionals)	Sends a DNS query with the specified question with additional records.
Future<AddressedEnvelope<DnsResponse,InetSocketAddress>>	DnsNameResolver.query(InetSocketAddress nameServerAddr, DnsQuestion question)	Sends a DNS query with the specified question using the specified name server list.
Future<AddressedEnvelope<DnsResponse,InetSocketAddress>>	DnsNameResolver.query(InetSocketAddress nameServerAddr, DnsQuestion question, Promise<AddressedEnvelope<? extends DnsResponse,InetSocketAddress>> promise)	Sends a DNS query with the specified question using the specified name server list.
Future<AddressedEnvelope<DnsResponse,InetSocketAddress>>	DnsNameResolver.query(InetSocketAddress nameServerAddr, DnsQuestion question, Iterable<DnsRecord> additionals)	Sends a DNS query with the specified question with additional records using the specified name server list.
Future<AddressedEnvelope<DnsResponse,InetSocketAddress>>	DnsNameResolver.query(InetSocketAddress nameServerAddr, DnsQuestion question, Iterable<DnsRecord> additionals, Promise<AddressedEnvelope<? extends DnsResponse,InetSocketAddress>> promise)	Sends a DNS query with the specified question with additional records using the specified name server list.
final Future<InetAddress>	DnsNameResolver.resolve(String inetHost, Iterable<DnsRecord> additionals)	Resolves the specified name into an address.
final Future<InetAddress>	DnsNameResolver.resolve(String inetHost, Iterable<DnsRecord> additionals, Promise<InetAddress> promise)	Resolves the specified name into an address.
Future<T>	InflightNameResolver.resolve(String inetHost)
final Future<List<DnsRecord>>	DnsNameResolver.resolveAll(DnsQuestion question)	Resolves the DnsRecords that are matched by the specified DnsQuestion.
private Future<List<DnsRecord>>	DnsNameResolver.resolveAll(DnsQuestion question, DnsRecord[] additionals, Promise<List<DnsRecord>> promise)
final Future<List<DnsRecord>>	DnsNameResolver.resolveAll(DnsQuestion question, Iterable<DnsRecord> additionals)	Resolves the DnsRecords that are matched by the specified DnsQuestion.
final Future<List<DnsRecord>>	DnsNameResolver.resolveAll(DnsQuestion question, Iterable<DnsRecord> additionals, Promise<List<DnsRecord>> promise)	Resolves the DnsRecords that are matched by the specified DnsQuestion.
final Future<List<InetAddress>>	DnsNameResolver.resolveAll(String inetHost, Iterable<DnsRecord> additionals)	Resolves the specified host name and port into a list of address.
final Future<List<InetAddress>>	DnsNameResolver.resolveAll(String inetHost, Iterable<DnsRecord> additionals, Promise<List<InetAddress>> promise)	Resolves the specified host name and port into a list of address.
Future<List<T>>	InflightNameResolver.resolveAll(String inetHost)

Methods in io.netty.resolver.dns with parameters of type Future

Modifier and Type	Method	Description
private void	DnsQueryContext.finishOriginal(Object originalResult, Future<?> future)
<T> ChannelFuture	DnsNameResolver.DnsResolveChannelPerResolutionProvider.nextResolveChannel(Future<T> resolutionFuture)
<T> ChannelFuture	DnsNameResolver.DnsResolveChannelPerResolverProvider.nextResolveChannel(Future<T> resolutionFuture)
<T> ChannelFuture	DnsNameResolver.DnsResolveChannelProvider.nextResolveChannel(Future<T> resolutionFuture)	Return the next ChannelFuture that contains the Channel that should be used for resolving a chain of queries.
private static <T> void	InflightNameResolver.transferResult(Future<T> src, Promise<T> dst)

Uses of Future in io.netty.util

Methods in io.netty.util that return Future

Modifier and Type	Method	Description
Future<OUT>	AsyncMapping.map(IN input, Promise<OUT> promise)	Returns the Future that will provide the result of the mapping.

Uses of Future in io.netty.util.concurrent

Classes in io.netty.util.concurrent with type parameters of type Future

Modifier and Type	Interface	Description
interface	GenericFutureListener<F extends Future<?>>	Listens to the result of a Future.
class	PromiseAggregator<V,F extends Future<V>>	Deprecated. Use PromiseCombiner(EventExecutor).
class	PromiseNotifier<V,F extends Future<V>>	GenericFutureListener implementation which takes other Promises and notifies them on completion.

Subinterfaces of Future in io.netty.util.concurrent

Modifier and Type	Interface	Description
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 a scheduled asynchronous operation.

Classes in io.netty.util.concurrent that implement Future

Modifier and Type	Class	Description
class	AbstractFuture<V>	Abstract Future implementation which does not allow for cancellation.
class	CompleteFuture<V>	A skeletal Future implementation which represents a Future which has been completed already.
class	DefaultProgressivePromise<V>
class	DefaultPromise<V>
final class	FailedFuture<V>	The CompleteFuture which is failed already.
(package private) static class	ImmediateEventExecutor.ImmediateProgressivePromise<V>
(package private) static class	ImmediateEventExecutor.ImmediatePromise<V>
(package private) class	PromiseTask<V>
(package private) final class	ScheduledFutureTask<V>
final class	SucceededFuture<V>	The CompleteFuture which is succeeded already.
private static final class	UnorderedThreadPoolEventExecutor.RunnableScheduledFutureTask<V>

Fields in io.netty.util.concurrent declared as Future

Modifier and Type	Field	Description
private final Future<?>	GlobalEventExecutor.terminationFuture
private final Future<?>	ImmediateEventExecutor.terminationFuture

Fields in io.netty.util.concurrent with type parameters of type Future

Modifier and Type	Field	Description
private GenericFutureListener<? extends Future<?>>	DefaultPromise.listener	One or more listeners.
private final GenericFutureListener<Future<?>>	PromiseCombiner.listener

Methods in io.netty.util.concurrent with type parameters of type Future

Modifier and Type	Method	Description
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.

Methods in io.netty.util.concurrent that return Future

Modifier and Type	Method	Description
Future<V>	CompleteFuture.addListener(GenericFutureListener<? extends Future<? super V>> listener)
Future<V>	Future.addListener(GenericFutureListener<? extends Future<? super V>> listener)	Adds the specified listener to this future.
Future<V>	CompleteFuture.addListeners(GenericFutureListener<? extends Future<? super V>>... listeners)
Future<V>	Future.addListeners(GenericFutureListener<? extends Future<? super V>>... listeners)	Adds the specified listeners to this future.
Future<V>	CompleteFuture.await()
Future<V>	Future.await()	Waits for this future to be completed.
Future<V>	CompleteFuture.awaitUninterruptibly()
Future<V>	Future.awaitUninterruptibly()	Waits for this future to be completed without interruption.
<V> Future<V>	AbstractEventExecutor.newFailedFuture(Throwable cause)
<V> Future<V>	EventExecutor.newFailedFuture(Throwable cause)	Create a new Future which is marked as failed already.
<V> Future<V>	UnorderedThreadPoolEventExecutor.newFailedFuture(Throwable cause)
<V> Future<V>	AbstractEventExecutor.newSucceededFuture(V result)
<V> Future<V>	EventExecutor.newSucceededFuture(V result)	Create a new Future which is marked as succeeded already.
<V> Future<V>	UnorderedThreadPoolEventExecutor.newSucceededFuture(V result)
Future<V>	CompleteFuture.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.
Future<V>	CompleteFuture.removeListeners(GenericFutureListener<? extends Future<? super V>>... listeners)
Future<V>	Future.removeListeners(GenericFutureListener<? extends Future<? super V>>... listeners)	Removes the first occurrence for each of the listeners from this future.
Future<?>	AbstractEventExecutor.shutdownGracefully()
Future<?>	AbstractEventExecutorGroup.shutdownGracefully()
Future<?>	EventExecutorGroup.shutdownGracefully()	Shortcut method for EventExecutorGroup.shutdownGracefully(long, long, TimeUnit) with sensible default values.
Future<?>	EventExecutorGroup.shutdownGracefully(long quietPeriod, long timeout, TimeUnit unit)	Signals this executor that the caller wants the executor to be shut down.
Future<?>	GlobalEventExecutor.shutdownGracefully(long quietPeriod, long timeout, TimeUnit unit)
Future<?>	ImmediateEventExecutor.shutdownGracefully(long quietPeriod, long timeout, TimeUnit unit)
Future<?>	MultithreadEventExecutorGroup.shutdownGracefully(long quietPeriod, long timeout, TimeUnit unit)
Future<?>	NonStickyEventExecutorGroup.NonStickyOrderedEventExecutor.shutdownGracefully(long quietPeriod, long timeout, TimeUnit unit)
Future<?>	NonStickyEventExecutorGroup.shutdownGracefully()
Future<?>	NonStickyEventExecutorGroup.shutdownGracefully(long quietPeriod, long timeout, TimeUnit unit)
Future<?>	SingleThreadEventExecutor.shutdownGracefully(long quietPeriod, long timeout, TimeUnit unit)
Future<?>	UnorderedThreadPoolEventExecutor.shutdownGracefully()
Future<?>	UnorderedThreadPoolEventExecutor.shutdownGracefully(long quietPeriod, long timeout, TimeUnit unit)
Future<?>	AbstractEventExecutor.submit(Runnable task)
<T> Future<T>	AbstractEventExecutor.submit(Runnable task, T result)
<T> Future<T>	AbstractEventExecutor.submit(Callable<T> task)
Future<?>	AbstractEventExecutorGroup.submit(Runnable task)
<T> Future<T>	AbstractEventExecutorGroup.submit(Runnable task, T result)
<T> Future<T>	AbstractEventExecutorGroup.submit(Callable<T> task)
Future<?>	EventExecutorGroup.submit(Runnable task)
<T> Future<T>	EventExecutorGroup.submit(Runnable task, T result)
<T> Future<T>	EventExecutorGroup.submit(Callable<T> task)
Future<?>	NonStickyEventExecutorGroup.submit(Runnable task)
<T> Future<T>	NonStickyEventExecutorGroup.submit(Runnable task, T result)
<T> Future<T>	NonStickyEventExecutorGroup.submit(Callable<T> task)
Future<?>	UnorderedThreadPoolEventExecutor.submit(Runnable task)
<T> Future<T>	UnorderedThreadPoolEventExecutor.submit(Runnable task, T result)
<T> Future<T>	UnorderedThreadPoolEventExecutor.submit(Callable<T> task)
Future<V>	CompleteFuture.sync()
Future<V>	FailedFuture.sync()
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>	CompleteFuture.syncUninterruptibly()
Future<V>	FailedFuture.syncUninterruptibly()
Future<V>	Future.syncUninterruptibly()	Waits for this future until it is done, and rethrows the cause of the failure if this future failed.
Future<?>	EventExecutorGroup.terminationFuture()	Returns the Future which is notified when all EventExecutors managed by this EventExecutorGroup have been terminated.
Future<?>	GlobalEventExecutor.terminationFuture()
Future<?>	ImmediateEventExecutor.terminationFuture()
Future<?>	MultithreadEventExecutorGroup.terminationFuture()
Future<?>	NonStickyEventExecutorGroup.NonStickyOrderedEventExecutor.terminationFuture()
Future<?>	NonStickyEventExecutorGroup.terminationFuture()
Future<?>	SingleThreadEventExecutor.terminationFuture()
Future<?>	UnorderedThreadPoolEventExecutor.terminationFuture()

Methods in io.netty.util.concurrent that return types with arguments of type Future

Modifier and Type	Method	Description
GenericFutureListener<? extends Future<?>>[]	DefaultFutureListeners.listeners()

Methods in io.netty.util.concurrent with parameters of type Future

Modifier and Type	Method	Description
void	PromiseCombiner.add(Future future)	Adds a new future to be combined.
void	PromiseCombiner.addAll(Future... futures)	Adds new futures to be combined.
static <X> void	UnaryPromiseNotifier.cascadeTo(Future<X> completedFuture, Promise<? super X> promise)	Deprecated.
protected static void	DefaultPromise.notifyListener(EventExecutor eventExecutor, Future<?> future, GenericFutureListener<?> listener)	Notify a listener that a future has completed.
private static void	DefaultPromise.notifyListener0(Future future, GenericFutureListener l)
private static void	DefaultPromise.notifyListenerWithStackOverFlowProtection(EventExecutor executor, Future<?> future, GenericFutureListener<?> listener)	The logic in this method should be identical to DefaultPromise.notifyListeners() but cannot share code because the listener(s) cannot be cached for an instance of DefaultPromise since the listener(s) may be changed and is protected by a synchronized operation.
void	UnaryPromiseNotifier.operationComplete(Future<T> future)	Deprecated.

Method parameters in io.netty.util.concurrent with type arguments of type Future

Modifier and Type	Method	Description
void	DefaultFutureListeners.add(GenericFutureListener<? extends Future<?>> l)
Future<V>	CompleteFuture.addListener(GenericFutureListener<? extends Future<? super V>> listener)
ProgressivePromise<V>	DefaultProgressivePromise.addListener(GenericFutureListener<? extends Future<? super V>> listener)
Promise<V>	DefaultPromise.addListener(GenericFutureListener<? extends Future<? super V>> listener)
Future<V>	Future.addListener(GenericFutureListener<? extends Future<? super V>> listener)	Adds the specified listener to this future.
ProgressiveFuture<V>	ProgressiveFuture.addListener(GenericFutureListener<? extends Future<? super V>> listener)
ProgressivePromise<V>	ProgressivePromise.addListener(GenericFutureListener<? extends Future<? super V>> listener)
Promise<V>	Promise.addListener(GenericFutureListener<? extends Future<? super V>> listener)
private void	DefaultPromise.addListener0(GenericFutureListener<? extends Future<? super V>> listener)
void	DefaultFutureListeners.remove(GenericFutureListener<? extends Future<?>> l)
Future<V>	CompleteFuture.removeListener(GenericFutureListener<? extends Future<? super V>> listener)
ProgressivePromise<V>	DefaultProgressivePromise.removeListener(GenericFutureListener<? extends Future<? super V>> listener)
Promise<V>	DefaultPromise.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.
ProgressiveFuture<V>	ProgressiveFuture.removeListener(GenericFutureListener<? extends Future<? super V>> listener)
ProgressivePromise<V>	ProgressivePromise.removeListener(GenericFutureListener<? extends Future<? super V>> listener)
Promise<V>	Promise.removeListener(GenericFutureListener<? extends Future<? super V>> listener)
private void	DefaultPromise.removeListener0(GenericFutureListener<? extends Future<? super V>> toRemove)

Constructor parameters in io.netty.util.concurrent with type arguments of type Future

Modifier	Constructor	Description
(package private)	DefaultFutureListeners(GenericFutureListener<? extends Future<?>> first, GenericFutureListener<? extends Future<?>> second)