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 virtualChannel
that helps wrapping a series of handlers to unit test the handlers or use them in non-I/O context.io.netty.channel.group A channel registry which helps a user maintain the list of openChannel
s and perform bulk operations on them.io.netty.channel.local A virtual transport that enables the communication between the two parties in the same virtual machine.io.netty.channel.pool Implementations and API forChannel
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 tunnelingio.netty.handler.ssl SSL · TLS implementation based onSSLEngine
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 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 asynchronousChannel
I/O operation.interface
ChannelProgressiveFuture
An specialChannelFuture
which is used to indicate theFileRegion
transfer progressinterface
ChannelProgressivePromise
SpecialChannelPromise
which will be notified once the associated bytes is transferring.interface
ChannelPromise
SpecialChannelFuture
which is writable.Classes in io.netty.channel that implement Future Modifier and Type Class Description (package private) static class
AbstractChannel.CloseFuture
(package private) class
CompleteChannelFuture
A skeletalChannelFuture
implementation which represents aChannelFuture
which has been completed already.class
DefaultChannelProgressivePromise
The defaultChannelProgressivePromise
implementation.class
DefaultChannelPromise
The defaultChannelPromise
implementation.class
DelegatingChannelPromiseNotifier
(package private) class
FailedChannelFuture
TheCompleteChannelFuture
which is failed already.(package private) class
SucceededChannelFuture
TheCompleteChannelFuture
which is succeeded already.class
VoidChannelPromise
Methods in io.netty.channel that return Future Modifier and Type Method Description Future<?>
ThreadPerChannelEventLoopGroup. shutdownGracefully(long quietPeriod, long timeout, java.util.concurrent.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 java.lang.Void>> listener)
ChannelProgressiveFuture
ChannelProgressiveFuture. addListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener)
ChannelProgressivePromise
ChannelProgressivePromise. addListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener)
ChannelPromise
ChannelPromise. addListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener)
ChannelFuture
CompleteChannelFuture. addListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener)
ChannelProgressivePromise
DefaultChannelProgressivePromise. addListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener)
ChannelPromise
DefaultChannelPromise. addListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener)
ChannelPromise
DelegatingChannelPromiseNotifier. addListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener)
VoidChannelPromise
VoidChannelPromise. addListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener)
ChannelFuture
ChannelFuture. removeListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener)
ChannelProgressiveFuture
ChannelProgressiveFuture. removeListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener)
ChannelProgressivePromise
ChannelProgressivePromise. removeListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener)
ChannelPromise
ChannelPromise. removeListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener)
ChannelFuture
CompleteChannelFuture. removeListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener)
ChannelProgressivePromise
DefaultChannelProgressivePromise. removeListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener)
ChannelPromise
DefaultChannelPromise. removeListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener)
ChannelPromise
DelegatingChannelPromiseNotifier. removeListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener)
VoidChannelPromise
VoidChannelPromise. removeListener(GenericFutureListener<? extends Future<? super java.lang.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, java.util.concurrent.TimeUnit unit)
Future<?>
EmbeddedEventLoop. terminationFuture()
-
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 asynchronousChannelGroup
operation.Classes in io.netty.channel.group that implement Future Modifier and Type Class Description (package private) class
DefaultChannelGroupFuture
The defaultChannelGroupFuture
implementation.(package private) 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 java.lang.Void>> listener)
DefaultChannelGroupFuture
DefaultChannelGroupFuture. addListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener)
ChannelGroupFuture
VoidChannelGroupFuture. addListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener)
ChannelGroupFuture
ChannelGroupFuture. removeListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener)
DefaultChannelGroupFuture
DefaultChannelGroupFuture. removeListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener)
ChannelGroupFuture
VoidChannelGroupFuture. removeListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener)
-
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 java.util.concurrent.atomic.AtomicReferenceFieldUpdater<LocalChannel,Future>
LocalChannel. FINISH_READ_FUTURE_UPDATER
-
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 aChannel
from thisChannelPool
.Future<Channel>
ChannelPool. acquire(Promise<Channel> promise)
Acquire aChannel
from thisChannelPool
.Future<Channel>
FixedChannelPool. acquire(Promise<Channel> promise)
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<java.lang.Void>
FixedChannelPool. close0()
Future<java.lang.Void>
FixedChannelPool. closeAsync()
Closes the pool in an async manner.Future<java.lang.Void>
SimpleChannelPool. closeAsync()
Closes the pool in an async manner.Future<java.lang.Boolean>
ChannelHealthChecker. isHealthy(Channel channel)
Check if the given channel is healthy which means it can be used.private static Future<java.lang.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<java.lang.Void>
ChannelPool. release(Channel channel)
Release aChannel
back to thisChannelPool
.Future<java.lang.Void>
ChannelPool. release(Channel channel, Promise<java.lang.Void> promise)
Release aChannel
back to thisChannelPool
.Future<java.lang.Void>
FixedChannelPool. release(Channel channel, Promise<java.lang.Void> promise)
Future<java.lang.Void>
SimpleChannelPool. release(Channel channel)
Future<java.lang.Void>
SimpleChannelPool. release(Channel channel, Promise<java.lang.Void> promise)
private Future<java.lang.Boolean>
AbstractChannelPoolMap. removeAsyncIfSupported(K key)
Remove theChannelPool
from thisAbstractChannelPoolMap
.Methods in io.netty.channel.pool with parameters of type Future Modifier and Type Method Description private void
SimpleChannelPool. notifyHealthCheck(Future<java.lang.Boolean> future, Channel ch, Promise<Channel> promise)
void
FixedChannelPool.AcquireListener. operationComplete(Future<Channel> future)
private void
SimpleChannelPool. releaseAndOfferIfHealthy(Channel channel, Promise<java.lang.Void> promise, Future<java.lang.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 class
Http2CodecUtil.SimpleChannelPromiseAggregator
Provides the ability to associate the outcome of multipleChannelPromise
objects into a singleChannelPromise
object.Methods in io.netty.handler.codec.http2 that return Future Modifier and Type Method Description Future<java.lang.Void>
DefaultHttp2Connection. close(Promise<java.lang.Void> promise)
Future<java.lang.Void>
Http2Connection. close(Promise<java.lang.Void> promise)
Close this connection.Future<Http2StreamChannel>
Http2StreamChannelBootstrap. open()
Open a newHttp2StreamChannel
to use.Future<Http2StreamChannel>
Http2StreamChannelBootstrap. open(Promise<Http2StreamChannel> promise)
Open a newHttp2StreamChannel
to use and notifies the givenPromise
. -
Uses of Future in io.netty.handler.proxy
Classes in io.netty.handler.proxy that implement Future Modifier and Type Class Description private class
ProxyHandler.LazyChannelPromise
Methods in io.netty.handler.proxy that return Future Modifier and Type Method Description Future<Channel>
ProxyHandler. connectFuture()
Returns aFuture
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 class
SslHandler.LazyChannelPromise
Methods in io.netty.handler.ssl that return Future Modifier and Type Method Description Future<Channel>
SslHandler. handshakeFuture()
Returns aFuture
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, java.lang.String hostname)
Kicks off a lookup for the given SNI value and returns aFuture
which in turn will notify theAbstractSniHandler.onLookupComplete(ChannelHandlerContext, String, Future)
on completion.protected Future<SslContext>
SniHandler. lookup(ChannelHandlerContext ctx, java.lang.String hostname)
The default implementation will simply callAsyncMapping.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 givenClientHello
and returns aFuture
which in turn will notify theSslClientHelloHandler.onLookupComplete(ChannelHandlerContext, Future)
on completion.Future<SslContext>
SniHandler.AsyncMappingAdapter. map(java.lang.String input, Promise<SslContext> promise)
Future<Channel>
SslHandler. renegotiate()
Performs TLS renegotiation.Future<Channel>
SslHandler. renegotiate(Promise<Channel> promise)
Performs TLS renegotiation.Future<Channel>
SslHandler. sslCloseFuture()
Return theFuture
that will get notified if the inbound of theSSLEngine
is closed.Methods in io.netty.handler.ssl with parameters of type Future Modifier and Type Method Description private void
AbstractSniHandler. fireSniCompletionEvent(ChannelHandlerContext ctx, java.lang.String hostname, Future<T> future)
protected void
AbstractSniHandler. onLookupComplete(ChannelHandlerContext ctx, Future<T> future)
protected abstract void
AbstractSniHandler. onLookupComplete(ChannelHandlerContext ctx, java.lang.String hostname, Future<T> future)
Called upon completion of theAbstractSniHandler.lookup(ChannelHandlerContext, String)
Future
.protected void
SniHandler. onLookupComplete(ChannelHandlerContext ctx, java.lang.String hostname, Future<SslContext> future)
protected abstract void
SslClientHelloHandler. onLookupComplete(ChannelHandlerContext ctx, Future<T> future)
Called upon completion of theSslClientHelloHandler.lookup(ChannelHandlerContext, ByteBuf)
Future
. -
Uses of Future in io.netty.resolver
Fields in io.netty.resolver with type parameters of type Future Modifier and Type Field Description private java.util.Map<EventExecutor,GenericFutureListener<Future<java.lang.Object>>>
AddressResolverGroup. executorTerminationListeners
Methods in io.netty.resolver that return Future Modifier and Type Method Description Future<T>
AbstractAddressResolver. resolve(java.net.SocketAddress address)
Future<T>
AbstractAddressResolver. resolve(java.net.SocketAddress address, Promise<T> promise)
Future<T>
AddressResolver. resolve(java.net.SocketAddress address)
Resolves the specified address.Future<T>
AddressResolver. resolve(java.net.SocketAddress address, Promise<T> promise)
Resolves the specified address.Future<T>
NameResolver. resolve(java.lang.String inetHost)
Resolves the specified name into an address.Future<T>
NameResolver. resolve(java.lang.String inetHost, Promise<T> promise)
Resolves the specified name into an address.Future<T>
SimpleNameResolver. resolve(java.lang.String inetHost)
Future<T>
SimpleNameResolver. resolve(java.lang.String inetHost, Promise<T> promise)
Future<java.util.List<T>>
AbstractAddressResolver. resolveAll(java.net.SocketAddress address)
Future<java.util.List<T>>
AbstractAddressResolver. resolveAll(java.net.SocketAddress address, Promise<java.util.List<T>> promise)
Future<java.util.List<T>>
AddressResolver. resolveAll(java.net.SocketAddress address)
Resolves the specified 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>>
NameResolver. resolveAll(java.lang.String inetHost)
Resolves the specified host name and port into a list of address.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.Future<java.util.List<T>>
SimpleNameResolver. resolveAll(java.lang.String inetHost)
Future<java.util.List<T>>
SimpleNameResolver. resolveAll(java.lang.String inetHost, Promise<java.util.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 (package private) Future<Channel>
DnsNameResolver. channelFuture
Fields in io.netty.resolver.dns with type parameters of type Future Modifier and Type Field Description private java.util.Set<Future<AddressedEnvelope<DnsResponse,java.net.InetSocketAddress>>>
DnsResolveContext. queriesInProgress
Methods in io.netty.resolver.dns that return Future Modifier and Type Method Description Future<AddressedEnvelope<DnsResponse,java.net.InetSocketAddress>>
DnsNameResolver. query(DnsQuestion question)
Sends a DNS query with the specified question.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(DnsQuestion question, java.lang.Iterable<DnsRecord> additionals)
Sends a DNS query with the specified question with additional records.Future<AddressedEnvelope<DnsResponse,java.net.InetSocketAddress>>
DnsNameResolver. query(java.net.InetSocketAddress nameServerAddr, DnsQuestion question)
Sends a DNS query with the specified question 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<AddressedEnvelope<DnsResponse,java.net.InetSocketAddress>>
DnsNameResolver. query(java.net.InetSocketAddress nameServerAddr, DnsQuestion question, java.lang.Iterable<DnsRecord> additionals)
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, 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.(package private) Future<AddressedEnvelope<DnsResponse,java.net.InetSocketAddress>>
DnsNameResolver. query0(java.net.InetSocketAddress nameServerAddr, DnsQuestion question, DnsRecord[] additionals, boolean flush, ChannelPromise writePromise, Promise<AddressedEnvelope<? extends DnsResponse,java.net.InetSocketAddress>> promise)
Future<java.net.InetAddress>
DnsNameResolver. resolve(java.lang.String inetHost, java.lang.Iterable<DnsRecord> additionals)
Resolves the specified name into an address.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<T>
InflightNameResolver. resolve(java.lang.String inetHost)
Future<java.util.List<DnsRecord>>
DnsNameResolver. resolveAll(DnsQuestion question)
Resolves theDnsRecord
s that are matched by the specifiedDnsQuestion
.private Future<java.util.List<DnsRecord>>
DnsNameResolver. resolveAll(DnsQuestion question, DnsRecord[] additionals, Promise<java.util.List<DnsRecord>> promise)
Future<java.util.List<DnsRecord>>
DnsNameResolver. resolveAll(DnsQuestion question, java.lang.Iterable<DnsRecord> additionals)
Resolves theDnsRecord
s that are matched by the specifiedDnsQuestion
.Future<java.util.List<DnsRecord>>
DnsNameResolver. resolveAll(DnsQuestion question, java.lang.Iterable<DnsRecord> additionals, Promise<java.util.List<DnsRecord>> promise)
Resolves theDnsRecord
s that are matched by the specifiedDnsQuestion
.Future<java.util.List<java.net.InetAddress>>
DnsNameResolver. resolveAll(java.lang.String inetHost, java.lang.Iterable<DnsRecord> additionals)
Resolves the specified host name and port into a list of address.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.Future<java.util.List<T>>
InflightNameResolver. resolveAll(java.lang.String inetHost)
Methods in io.netty.resolver.dns with parameters of type Future Modifier and Type Method Description void
DnsQueryContext. operationComplete(Future<AddressedEnvelope<DnsResponse,java.net.InetSocketAddress>> future)
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 theFuture
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 aFuture
.class
PromiseAggregator<V,F extends Future<V>>
Deprecated.class
PromiseNotifier<V,F extends Future<V>>
GenericFutureListener
implementation which takes otherPromise
s and notifies them on completion.Subinterfaces of Future in io.netty.util.concurrent Modifier and Type Interface Description interface
ProgressiveFuture<V>
AFuture
which is used to indicate the progress of an operation.interface
ProgressivePromise<V>
SpecialProgressiveFuture
which is writable.interface
Promise<V>
SpecialFuture
which is writable.interface
ScheduledFuture<V>
The result of an scheduled asynchronous operation.Classes in io.netty.util.concurrent that implement Future Modifier and Type Class Description class
AbstractFuture<V>
AbstractFuture
implementation which does not allow for cancellation.class
CompleteFuture<V>
class
DefaultProgressivePromise<V>
class
DefaultPromise<V>
class
FailedFuture<V>
TheCompleteFuture
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) class
ScheduledFutureTask<V>
class
SucceededFuture<V>
TheCompleteFuture
which is succeeded already.private static class
UnorderedThreadPoolEventExecutor.RunnableScheduledFutureTask<V>
Fields in io.netty.util.concurrent declared as Future Modifier and Type Field Description private Future<?>
GlobalEventExecutor. terminationFuture
private Future<?>
ImmediateEventExecutor. terminationFuture
Fields in io.netty.util.concurrent with type parameters of type Future Modifier and Type Field Description private GenericFutureListener<Future<?>>
PromiseCombiner. listener
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(java.lang.Throwable cause)
<V> Future<V>
EventExecutor. newFailedFuture(java.lang.Throwable cause)
Create a newFuture
which is marked as failed already.<V> Future<V>
UnorderedThreadPoolEventExecutor. newFailedFuture(java.lang.Throwable cause)
<V> Future<V>
AbstractEventExecutor. newSucceededFuture(V result)
<V> Future<V>
EventExecutor. newSucceededFuture(V result)
Create a newFuture
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 forEventExecutorGroup.shutdownGracefully(long, long, TimeUnit)
with sensible default values.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.Future<?>
GlobalEventExecutor. shutdownGracefully(long quietPeriod, long timeout, java.util.concurrent.TimeUnit unit)
Future<?>
ImmediateEventExecutor. shutdownGracefully(long quietPeriod, long timeout, java.util.concurrent.TimeUnit unit)
Future<?>
MultithreadEventExecutorGroup. shutdownGracefully(long quietPeriod, long timeout, java.util.concurrent.TimeUnit unit)
Future<?>
NonStickyEventExecutorGroup.NonStickyOrderedEventExecutor. shutdownGracefully(long quietPeriod, long timeout, java.util.concurrent.TimeUnit unit)
Future<?>
NonStickyEventExecutorGroup. shutdownGracefully()
Future<?>
NonStickyEventExecutorGroup. shutdownGracefully(long quietPeriod, long timeout, java.util.concurrent.TimeUnit unit)
Future<?>
SingleThreadEventExecutor. shutdownGracefully(long quietPeriod, long timeout, java.util.concurrent.TimeUnit unit)
Future<?>
UnorderedThreadPoolEventExecutor. shutdownGracefully()
Future<?>
UnorderedThreadPoolEventExecutor. shutdownGracefully(long quietPeriod, long timeout, java.util.concurrent.TimeUnit unit)
Future<?>
AbstractEventExecutor. submit(java.lang.Runnable task)
<T> Future<T>
AbstractEventExecutor. submit(java.lang.Runnable task, T result)
<T> Future<T>
AbstractEventExecutor. submit(java.util.concurrent.Callable<T> task)
Future<?>
AbstractEventExecutorGroup. submit(java.lang.Runnable task)
<T> Future<T>
AbstractEventExecutorGroup. submit(java.lang.Runnable task, T result)
<T> Future<T>
AbstractEventExecutorGroup. submit(java.util.concurrent.Callable<T> task)
Future<?>
EventExecutorGroup. submit(java.lang.Runnable task)
<T> Future<T>
EventExecutorGroup. submit(java.lang.Runnable task, T result)
<T> Future<T>
EventExecutorGroup. submit(java.util.concurrent.Callable<T> task)
Future<?>
NonStickyEventExecutorGroup. submit(java.lang.Runnable task)
<T> Future<T>
NonStickyEventExecutorGroup. submit(java.lang.Runnable task, T result)
<T> Future<T>
NonStickyEventExecutorGroup. submit(java.util.concurrent.Callable<T> task)
Future<?>
UnorderedThreadPoolEventExecutor. submit(java.lang.Runnable task)
<T> Future<T>
UnorderedThreadPoolEventExecutor. submit(java.lang.Runnable task, T result)
<T> Future<T>
UnorderedThreadPoolEventExecutor. submit(java.util.concurrent.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 theFuture
which is notified when allEventExecutor
s managed by thisEventExecutorGroup
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)
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 toDefaultPromise.notifyListeners()
but cannot share code because the listener(s) cannot be cached for an instance ofDefaultPromise
since the listener(s) may be changed and is protected by a synchronized operation.void
UnaryPromiseNotifier. operationComplete(Future<T> future)
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>> listener)
Constructor parameters in io.netty.util.concurrent with type arguments of type Future Constructor Description DefaultFutureListeners(GenericFutureListener<? extends Future<?>> first, GenericFutureListener<? extends Future<?>> second)
-