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 virtualChannelthat 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 openChannels 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 forChannelpools.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 onSSLEngineio.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 classAbstractBootstrap.PendingRegistrationPromise -
Uses of Future in io.netty.channel
Subinterfaces of Future in io.netty.channel Modifier and Type Interface Description interfaceChannelFutureThe result of an asynchronousChannelI/O operation.interfaceChannelProgressiveFutureAn specialChannelFuturewhich is used to indicate theFileRegiontransfer progressinterfaceChannelProgressivePromiseSpecialChannelPromisewhich will be notified once the associated bytes is transferring.interfaceChannelPromiseSpecialChannelFuturewhich is writable.Classes in io.netty.channel that implement Future Modifier and Type Class Description (package private) static classAbstractChannel.CloseFuture(package private) classCompleteChannelFutureA skeletalChannelFutureimplementation which represents aChannelFuturewhich has been completed already.classDefaultChannelProgressivePromiseThe defaultChannelProgressivePromiseimplementation.classDefaultChannelPromiseThe defaultChannelPromiseimplementation.classDelegatingChannelPromiseNotifier(package private) classFailedChannelFutureTheCompleteChannelFuturewhich is failed already.(package private) classSucceededChannelFutureTheCompleteChannelFuturewhich is succeeded already.classVoidChannelPromiseMethods 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 ChannelFutureChannelFuture. addListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener)ChannelProgressiveFutureChannelProgressiveFuture. addListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener)ChannelProgressivePromiseChannelProgressivePromise. addListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener)ChannelPromiseChannelPromise. addListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener)ChannelFutureCompleteChannelFuture. addListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener)ChannelProgressivePromiseDefaultChannelProgressivePromise. addListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener)ChannelPromiseDefaultChannelPromise. addListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener)ChannelPromiseDelegatingChannelPromiseNotifier. addListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener)VoidChannelPromiseVoidChannelPromise. addListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener)ChannelFutureChannelFuture. removeListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener)ChannelProgressiveFutureChannelProgressiveFuture. removeListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener)ChannelProgressivePromiseChannelProgressivePromise. removeListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener)ChannelPromiseChannelPromise. removeListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener)ChannelFutureCompleteChannelFuture. removeListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener)ChannelProgressivePromiseDefaultChannelProgressivePromise. removeListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener)ChannelPromiseDefaultChannelPromise. removeListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener)ChannelPromiseDelegatingChannelPromiseNotifier. removeListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener)VoidChannelPromiseVoidChannelPromise. 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 interfaceChannelGroupFutureThe result of an asynchronousChannelGroupoperation.Classes in io.netty.channel.group that implement Future Modifier and Type Class Description (package private) classDefaultChannelGroupFutureThe defaultChannelGroupFutureimplementation.(package private) classVoidChannelGroupFutureMethod parameters in io.netty.channel.group with type arguments of type Future Modifier and Type Method Description ChannelGroupFutureChannelGroupFuture. addListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener)DefaultChannelGroupFutureDefaultChannelGroupFuture. addListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener)ChannelGroupFutureVoidChannelGroupFuture. addListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener)ChannelGroupFutureChannelGroupFuture. removeListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener)DefaultChannelGroupFutureDefaultChannelGroupFuture. removeListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener)ChannelGroupFutureVoidChannelGroupFuture. 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. finishReadFutureFields 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 aChannelfrom thisChannelPool.Future<Channel>ChannelPool. acquire(Promise<Channel> promise)Acquire aChannelfrom 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 aChannelback to thisChannelPool.Future<java.lang.Void>ChannelPool. release(Channel channel, Promise<java.lang.Void> promise)Release aChannelback 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 theChannelPoolfrom thisAbstractChannelPoolMap.Methods in io.netty.channel.pool with parameters of type Future Modifier and Type Method Description private voidSimpleChannelPool. notifyHealthCheck(Future<java.lang.Boolean> future, Channel ch, Promise<Channel> promise)voidFixedChannelPool.AcquireListener. operationComplete(Future<Channel> future)private voidSimpleChannelPool. 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 classHttp2CodecUtil.SimpleChannelPromiseAggregatorProvides the ability to associate the outcome of multipleChannelPromiseobjects into a singleChannelPromiseobject.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 newHttp2StreamChannelto use.Future<Http2StreamChannel>Http2StreamChannelBootstrap. open(Promise<Http2StreamChannel> promise)Open a newHttp2StreamChannelto 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 classProxyHandler.LazyChannelPromiseMethods in io.netty.handler.proxy that return Future Modifier and Type Method Description Future<Channel>ProxyHandler. connectFuture()Returns aFuturethat 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 classSslHandler.LazyChannelPromiseMethods in io.netty.handler.ssl that return Future Modifier and Type Method Description Future<Channel>SslHandler. handshakeFuture()Returns aFuturethat 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 aFuturewhich 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 givenClientHelloand returns aFuturewhich 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 theFuturethat will get notified if the inbound of theSSLEngineis closed.Methods in io.netty.handler.ssl with parameters of type Future Modifier and Type Method Description private voidAbstractSniHandler. fireSniCompletionEvent(ChannelHandlerContext ctx, java.lang.String hostname, Future<T> future)protected voidAbstractSniHandler. onLookupComplete(ChannelHandlerContext ctx, Future<T> future)protected abstract voidAbstractSniHandler. onLookupComplete(ChannelHandlerContext ctx, java.lang.String hostname, Future<T> future)Called upon completion of theAbstractSniHandler.lookup(ChannelHandlerContext, String)Future.protected voidSniHandler. onLookupComplete(ChannelHandlerContext ctx, java.lang.String hostname, Future<SslContext> future)protected abstract voidSslClientHelloHandler. 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. executorTerminationListenersMethods 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. channelFutureFields 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. queriesInProgressMethods 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 theDnsRecords 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 theDnsRecords 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 theDnsRecords 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 voidDnsQueryContext. operationComplete(Future<AddressedEnvelope<DnsResponse,java.net.InetSocketAddress>> future)private static <T> voidInflightNameResolver. 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 theFuturethat 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 interfaceGenericFutureListener<F extends Future<?>>Listens to the result of aFuture.classPromiseAggregator<V,F extends Future<V>>Deprecated.classPromiseNotifier<V,F extends Future<V>>GenericFutureListenerimplementation which takes otherPromises and notifies them on completion.Subinterfaces of Future in io.netty.util.concurrent Modifier and Type Interface Description interfaceProgressiveFuture<V>AFuturewhich is used to indicate the progress of an operation.interfaceProgressivePromise<V>SpecialProgressiveFuturewhich is writable.interfacePromise<V>SpecialFuturewhich is writable.interfaceScheduledFuture<V>The result of an scheduled asynchronous operation.Classes in io.netty.util.concurrent that implement Future Modifier and Type Class Description classAbstractFuture<V>AbstractFutureimplementation which does not allow for cancellation.classCompleteFuture<V>classDefaultProgressivePromise<V>classDefaultPromise<V>classFailedFuture<V>TheCompleteFuturewhich is failed already.(package private) static classImmediateEventExecutor.ImmediateProgressivePromise<V>(package private) static classImmediateEventExecutor.ImmediatePromise<V>(package private) classPromiseTask<V>(package private) classScheduledFutureTask<V>classSucceededFuture<V>TheCompleteFuturewhich is succeeded already.private static classUnorderedThreadPoolEventExecutor.RunnableScheduledFutureTask<V>Fields in io.netty.util.concurrent declared as Future Modifier and Type Field Description private Future<?>GlobalEventExecutor. terminationFutureprivate Future<?>ImmediateEventExecutor. terminationFutureFields in io.netty.util.concurrent with type parameters of type Future Modifier and Type Field Description private GenericFutureListener<Future<?>>PromiseCombiner. listenerMethods 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 newFuturewhich 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 newFuturewhich 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 theFuturewhich is notified when allEventExecutors managed by thisEventExecutorGrouphave 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 voidPromiseCombiner. add(Future future)Adds a new future to be combined.voidPromiseCombiner. addAll(Future... futures)Adds new futures to be combined.static <X> voidUnaryPromiseNotifier. cascadeTo(Future<X> completedFuture, Promise<? super X> promise)protected static voidDefaultPromise. notifyListener(EventExecutor eventExecutor, Future<?> future, GenericFutureListener<?> listener)Notify a listener that a future has completed.private static voidDefaultPromise. notifyListener0(Future future, GenericFutureListener l)private static voidDefaultPromise. 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 ofDefaultPromisesince the listener(s) may be changed and is protected by a synchronized operation.voidUnaryPromiseNotifier. operationComplete(Future<T> future)Method parameters in io.netty.util.concurrent with type arguments of type Future Modifier and Type Method Description voidDefaultFutureListeners. 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 voidDefaultPromise. addListener0(GenericFutureListener<? extends Future<? super V>> listener)voidDefaultFutureListeners. 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 voidDefaultPromise. 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)
-