Uses of Package
io.netty.util.concurrent
Packages that use io.netty.util.concurrent
Package
Description
The helper classes with fluent API which enable an easy implementation of
typical client side and server side channel initialization.
Abstraction of a byte buffer - the fundamental data structure
to represent a low-level binary and text message.
The core channel API which is asynchronous and event-driven abstraction of
various transports such as a
NIO Channel.
A virtual
Channel that helps wrapping a series of handlers to
unit test the handlers or use them in non-I/O context.Optimized transport for linux which uses EPOLL Edge-Triggered Mode
for maximal performance.
A channel registry which helps a user maintain the list of open
Channels and perform bulk operations on them.BSD specific transport.
A virtual transport that enables the communication between the two
parties in the same virtual machine.
NIO-based channel
API implementation - recommended for a large number of connections (>= 1000).
Old blocking I/O based channel API implementation - recommended for
a small number of connections (< 1000).
Implementations and API for
Channel pools.Extensible decoder and its common implementations which deal with the
packet fragmentation and reassembly issue found in a stream-based transport
such as TCP/IP.
Encoder, decoder and their related message types for HTTP.
Encoder, decoder, handshakers and their related message types for
Web Socket data frames.
Handlers for sending and receiving HTTP/2 frames.
Encoder, decoder, session handler and their related message types for the SPDY protocol.
STOMP codec
Adds support for client connections via proxy protocols such as
SOCKS and
HTTP CONNECT tunneling
Certificate validation using OCSP
Utility classes that helps easier development of TLS/SSL applications.
Adds support for read and write timeout and idle connection notification
using a
Timer.Implementation of a Traffic Shaping Handler and Dynamic Statistics.
Resolves an arbitrary string that represents the name of an endpoint into an address.
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.
Utility classes used across multiple packages.
Utility classes for concurrent / async tasks.
Internal-use-only utilities which is not allowed to be used
outside Netty.
-
Classes in io.netty.util.concurrent used by io.netty.bootstrapClassDescriptionAbstract
Futureimplementation which does not allow for cancellation.TheEventExecutoris a specialEventExecutorGroupwhich comes with some handy methods to see if aThreadis executed in a event loop.The result of an asynchronous operation.SpecialFuturewhich is writable. -
Classes in io.netty.util.concurrent used by io.netty.bufferClassDescriptionA scalable concurrent multimap implementation.A special variant of
ThreadLocalthat yields higher access performance when accessed from aFastThreadLocalThread.A multi-producer (concurrent and thread-safeofferandfill), single-consumer (single-threadedpollanddrain) queue of primitive integers. -
Classes in io.netty.util.concurrent used by io.netty.channelClassDescriptionAbstract base class for
EventExecutorimplementations.Abstract base class forEventExecutorGroupimplementations.AbstractFutureimplementation which does not allow for cancellation.Abstract base class forEventExecutors that want to support scheduling.TheEventExecutoris a specialEventExecutorGroupwhich comes with some handy methods to see if aThreadis executed in a event loop.Factory that creates newEventExecutorChooserFactory.EventExecutorChoosers.TheEventExecutorGroupis responsible for providing theEventExecutor's to use via itsEventExecutorGroup.next()method.A special variant ofThreadLocalthat yields higher access performance when accessed from aFastThreadLocalThread.The result of an asynchronous operation.A subtype ofGenericFutureListenerthat hides type parameter for convenience.Listens to the result of aFuture.Abstract base class forEventExecutorGroupimplementations that handles their tasks with multiple threads at the same time.Marker interface forEventExecutors that will process all submitted tasks in an ordered / serial fashion.AFuturewhich is used to indicate the progress of an operation.SpecialProgressiveFuturewhich is writable.SpecialFuturewhich is writable.Deprecated.GenericFutureListenerimplementation which takes otherPromises and notifies them on completion.Similar toRejectedExecutionHandlerbut specific toSingleThreadEventExecutor.Abstract base class forOrderedEventExecutor's that execute all its submitted tasks in a single thread. -
Classes in io.netty.util.concurrent used by io.netty.channel.embeddedClassDescriptionAbstract base class for
EventExecutorimplementations.Abstract base class forEventExecutors that want to support scheduling.TheEventExecutoris a specialEventExecutorGroupwhich comes with some handy methods to see if aThreadis executed in a event loop.TheEventExecutorGroupis responsible for providing theEventExecutor's to use via itsEventExecutorGroup.next()method.The result of an asynchronous operation.Marker interface forEventExecutors that will process all submitted tasks in an ordered / serial fashion. -
Classes in io.netty.util.concurrent used by io.netty.channel.epollClassDescriptionAbstract base class for
EventExecutorimplementations.Abstract base class forEventExecutorGroupimplementations.Abstract base class forEventExecutors that want to support scheduling.TheEventExecutoris a specialEventExecutorGroupwhich comes with some handy methods to see if aThreadis executed in a event loop.Factory that creates newEventExecutorChooserFactory.EventExecutorChoosers.TheEventExecutorGroupis responsible for providing theEventExecutor's to use via itsEventExecutorGroup.next()method.The result of an asynchronous operation.Listens to the result of aFuture.Abstract base class forEventExecutorGroupimplementations that handles their tasks with multiple threads at the same time.Marker interface forEventExecutors that will process all submitted tasks in an ordered / serial fashion.Similar toRejectedExecutionHandlerbut specific toSingleThreadEventExecutor.Abstract base class forOrderedEventExecutor's that execute all its submitted tasks in a single thread. -
Classes in io.netty.util.concurrent used by io.netty.channel.groupClassDescriptionAbstract
Futureimplementation which does not allow for cancellation.TheEventExecutoris a specialEventExecutorGroupwhich comes with some handy methods to see if aThreadis executed in a event loop.The result of an asynchronous operation.Listens to the result of aFuture.SpecialFuturewhich is writable. -
Classes in io.netty.util.concurrent used by io.netty.channel.kqueueClassDescriptionAbstract base class for
EventExecutorimplementations.Abstract base class forEventExecutorGroupimplementations.Abstract base class forEventExecutors that want to support scheduling.TheEventExecutoris a specialEventExecutorGroupwhich comes with some handy methods to see if aThreadis executed in a event loop.Factory that creates newEventExecutorChooserFactory.EventExecutorChoosers.TheEventExecutorGroupis responsible for providing theEventExecutor's to use via itsEventExecutorGroup.next()method.The result of an asynchronous operation.Abstract base class forEventExecutorGroupimplementations that handles their tasks with multiple threads at the same time.Marker interface forEventExecutors that will process all submitted tasks in an ordered / serial fashion.Similar toRejectedExecutionHandlerbut specific toSingleThreadEventExecutor.Abstract base class forOrderedEventExecutor's that execute all its submitted tasks in a single thread. -
Classes in io.netty.util.concurrent used by io.netty.channel.localClassDescriptionAbstract base class for
EventExecutorGroupimplementations.TheEventExecutorGroupis responsible for providing theEventExecutor's to use via itsEventExecutorGroup.next()method.The result of an asynchronous operation.Abstract base class forEventExecutorGroupimplementations that handles their tasks with multiple threads at the same time. -
Classes in io.netty.util.concurrent used by io.netty.channel.nioClassDescriptionAbstract base class for
EventExecutorimplementations.Abstract base class forEventExecutorGroupimplementations.Abstract base class forEventExecutors that want to support scheduling.TheEventExecutoris a specialEventExecutorGroupwhich comes with some handy methods to see if aThreadis executed in a event loop.Factory that creates newEventExecutorChooserFactory.EventExecutorChoosers.TheEventExecutorGroupis responsible for providing theEventExecutor's to use via itsEventExecutorGroup.next()method.The result of an asynchronous operation.Abstract base class forEventExecutorGroupimplementations that handles their tasks with multiple threads at the same time.Marker interface forEventExecutors that will process all submitted tasks in an ordered / serial fashion.Similar toRejectedExecutionHandlerbut specific toSingleThreadEventExecutor.Abstract base class forOrderedEventExecutor's that execute all its submitted tasks in a single thread. -
Classes in io.netty.util.concurrent used by io.netty.channel.oioClassDescriptionAbstract base class for
EventExecutorGroupimplementations.TheEventExecutorGroupis responsible for providing theEventExecutor's to use via itsEventExecutorGroup.next()method. -
Classes in io.netty.util.concurrent used by io.netty.channel.poolClassDescriptionThe
EventExecutoris a specialEventExecutorGroupwhich comes with some handy methods to see if aThreadis executed in a event loop.The result of an asynchronous operation.A subtype ofGenericFutureListenerthat hides type parameter for convenience.Listens to the result of aFuture.SpecialFuturewhich is writable. -
Classes in io.netty.util.concurrent used by io.netty.handler.codecClassDescriptionA special variant of
ThreadLocalthat yields higher access performance when accessed from aFastThreadLocalThread. -
Classes in io.netty.util.concurrent used by io.netty.handler.codec.compressionClassDescriptionA special variant of
ThreadLocalthat yields higher access performance when accessed from aFastThreadLocalThread. -
Classes in io.netty.util.concurrent used by io.netty.handler.codec.httpClassDescriptionA special variant of
ThreadLocalthat yields higher access performance when accessed from aFastThreadLocalThread. -
Classes in io.netty.util.concurrent used by io.netty.handler.codec.http.websocketxClassDescriptionA special variant of
ThreadLocalthat yields higher access performance when accessed from aFastThreadLocalThread. -
Classes in io.netty.util.concurrent used by io.netty.handler.codec.http2ClassDescriptionAbstract
Futureimplementation which does not allow for cancellation.TheEventExecutoris a specialEventExecutorGroupwhich comes with some handy methods to see if aThreadis executed in a event loop.The result of an asynchronous operation.Listens to the result of aFuture.SpecialFuturewhich is writable. -
Classes in io.netty.util.concurrent used by io.netty.handler.codec.spdy
-
Classes in io.netty.util.concurrent used by io.netty.handler.codec.stompClassDescriptionA special variant of
ThreadLocalthat yields higher access performance when accessed from aFastThreadLocalThread. -
Classes in io.netty.util.concurrent used by io.netty.handler.proxyClassDescriptionAbstract
Futureimplementation which does not allow for cancellation.TheEventExecutoris a specialEventExecutorGroupwhich comes with some handy methods to see if aThreadis executed in a event loop.The result of an asynchronous operation.SpecialFuturewhich is writable. -
Classes in io.netty.util.concurrent used by io.netty.handler.sslClassDescriptionAbstract
Futureimplementation which does not allow for cancellation.TheEventExecutoris a specialEventExecutorGroupwhich comes with some handy methods to see if aThreadis executed in a event loop.The result of an asynchronous operation.A subtype ofGenericFutureListenerthat hides type parameter for convenience.Listens to the result of aFuture.SpecialFuturewhich is writable.The result of a scheduled asynchronous operation. -
Classes in io.netty.util.concurrent used by io.netty.handler.ssl.ocsp
-
Classes in io.netty.util.concurrent used by io.netty.handler.ssl.utilClassDescriptionA special variant of
ThreadLocalthat yields higher access performance when accessed from aFastThreadLocalThread. -
Classes in io.netty.util.concurrent used by io.netty.handler.timeout
-
Classes in io.netty.util.concurrent used by io.netty.handler.trafficClassDescriptionThe
EventExecutoris a specialEventExecutorGroupwhich comes with some handy methods to see if aThreadis executed in a event loop. -
Classes in io.netty.util.concurrent used by io.netty.resolverClassDescriptionThe
EventExecutoris a specialEventExecutorGroupwhich comes with some handy methods to see if aThreadis executed in a event loop.The result of an asynchronous operation.Listens to the result of aFuture.SpecialFuturewhich is writable. -
Classes in io.netty.util.concurrent used by io.netty.resolver.dnsClassDescriptionThe
EventExecutoris a specialEventExecutorGroupwhich comes with some handy methods to see if aThreadis executed in a event loop.A special variant ofThreadLocalthat yields higher access performance when accessed from aFastThreadLocalThread.The result of an asynchronous operation.SpecialFuturewhich is writable. -
Classes in io.netty.util.concurrent used by io.netty.utilClassDescriptionA special variant of
ThreadLocalthat yields higher access performance when accessed from aFastThreadLocalThread.The result of an asynchronous operation.SpecialFuturewhich is writable. -
Classes in io.netty.util.concurrent used by io.netty.util.concurrentClassDescriptionAbstract base class for
EventExecutorimplementations.Deprecated.overrideSingleThreadEventExecutor.wakesUpForTask(java.lang.Runnable)to re-create this behaviourAbstract base class forEventExecutorGroupimplementations.AbstractFutureimplementation which does not allow for cancellation.Abstract base class forEventExecutors that want to support scheduling.A scalable concurrent multimap implementation.Index nodes represent the levels of the skip list.The multimap entry type with primitiveintkeys.Base of iterator classesNodes hold keys and values, and are singly linked in sorted order, possibly with some intervening marker nodes.Default implementation which uses simple round-robin to choose nextEventExecutor.TheEventExecutoris a specialEventExecutorGroupwhich comes with some handy methods to see if aThreadis executed in a event loop.Factory that creates newEventExecutorChooserFactory.EventExecutorChoosers.Chooses the nextEventExecutorto use.TheEventExecutorGroupis responsible for providing theEventExecutor's to use via itsEventExecutorGroup.next()method.A special variant ofThreadLocalthat yields higher access performance when accessed from aFastThreadLocalThread.The result of an asynchronous operation.A subtype ofGenericFutureListenerthat hides type parameter for convenience.Listens to the result of aFuture.Single-thread singletonEventExecutor.ExecutesRunnableobjects in the caller's thread.Executorwhich execute tasks in the callers thread.This implementation is based on MpscAtomicUnpaddedArrayQueue from JCTools.A multi-producer (concurrent and thread-safeofferandfill), single-consumer (single-threadedpollanddrain) queue of primitive integers.Abstract base class forEventExecutorGroupimplementations that handles their tasks with multiple threads at the same time.Marker interface forEventExecutors that will process all submitted tasks in an ordered / serial fashion.AFuturewhich is used to indicate the progress of an operation.SpecialProgressiveFuturewhich is writable.SpecialFuturewhich is writable.Deprecated.Similar toRejectedExecutionHandlerbut specific toSingleThreadEventExecutor.The result of a scheduled asynchronous operation.Abstract base class forOrderedEventExecutor's that execute all its submitted tasks in a single thread.Expose details for aThread. -
Classes in io.netty.util.concurrent used by io.netty.util.internalClassDescriptionThe
EventExecutoris a specialEventExecutorGroupwhich comes with some handy methods to see if aThreadis executed in a event loop.A special variant ofThreadLocalthat yields higher access performance when accessed from aFastThreadLocalThread.A specialThreadthat provides fast access toFastThreadLocalvariables.SpecialFuturewhich is writable.
PromiseCombiner(EventExecutor).