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

Packages that use EventExecutor

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.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.traffic	Implementation of a Traffic Shaping Handler and Dynamic Statistics.
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.concurrent	Utility classes for concurrent / async tasks.
io.netty.util.internal	Internal-use-only utilities which is not allowed to be used outside Netty.

Uses of EventExecutor in io.netty.bootstrap

Methods in io.netty.bootstrap that return EventExecutor

Modifier and Type	Method	Description
protected EventExecutor	AbstractBootstrap.PendingRegistrationPromise.executor()

Uses of EventExecutor in io.netty.channel

Subinterfaces of EventExecutor in io.netty.channel

Modifier and Type	Interface	Description
interface	EventLoop	Will handle all the I/O operations for a Channel once registered.

Classes in io.netty.channel that implement EventExecutor

Modifier and Type	Class	Description
class	AbstractEventLoop	Skeletal implementation of EventLoop.
class	DefaultEventLoop
class	SingleThreadEventLoop	Abstract base class for EventLoops that execute all its submitted tasks in a single thread.
class	ThreadPerChannelEventLoop	Deprecated. this will be remove in the next-major release.

Fields in io.netty.channel declared as EventExecutor

Modifier and Type	Field	Description
(package private) final EventExecutor	AbstractChannelHandlerContext.executor
private final EventExecutor	PendingWriteQueue.executor

Fields in io.netty.channel with type parameters of type EventExecutor

Modifier and Type	Field	Description
private Map<EventExecutorGroup, EventExecutor>	DefaultChannelPipeline.childExecutors

Methods in io.netty.channel that return EventExecutor

Modifier and Type	Method	Description
private EventExecutor	DefaultChannelPipeline.childExecutor(EventExecutorGroup group)
EventExecutor	AbstractChannelHandlerContext.executor()
EventExecutor	ChannelHandlerContext.executor()	Returns the EventExecutor which is used to execute an arbitrary task.
EventExecutor	CombinedChannelDuplexHandler.DelegatingChannelHandlerContext.executor()
protected EventExecutor	CompleteChannelFuture.executor()
protected EventExecutor	DefaultChannelProgressivePromise.executor()
protected EventExecutor	DefaultChannelPromise.executor()

Methods in io.netty.channel that return types with arguments of type EventExecutor

Modifier and Type	Method	Description
Iterator<EventExecutor>	ThreadPerChannelEventLoopGroup.iterator()	Deprecated.

Methods in io.netty.channel with parameters of type EventExecutor

Modifier and Type	Method	Description
private void	DefaultChannelPipeline.callHandlerAddedInEventLoop(AbstractChannelHandlerContext newCtx, EventExecutor executor)
private static boolean	AbstractChannelHandlerContext.safeExecute(EventExecutor executor, Runnable runnable, ChannelPromise promise, Object msg, boolean lazy)
private static boolean	AbstractChannelHandlerContext.skipContext(AbstractChannelHandlerContext ctx, EventExecutor currentExecutor, int mask, int onlyMask)

Constructors in io.netty.channel with parameters of type EventExecutor

Modifier	Constructor	Description
(package private)	AbstractChannelHandlerContext(DefaultChannelPipeline pipeline, EventExecutor executor, String name, Class<? extends ChannelHandler> handlerClass)
protected	CompleteChannelFuture(Channel channel, EventExecutor executor)	Creates a new instance.
(package private)	DefaultChannelHandlerContext(DefaultChannelPipeline pipeline, EventExecutor executor, String name, ChannelHandler handler)
	DefaultChannelProgressivePromise(Channel channel, EventExecutor executor)	Creates a new instance.
	DefaultChannelPromise(Channel channel, EventExecutor executor)	Creates a new instance.
(package private)	FailedChannelFuture(Channel channel, EventExecutor executor, Throwable cause)	Creates a new instance.
(package private)	SucceededChannelFuture(Channel channel, EventExecutor executor)	Creates a new instance.

Uses of EventExecutor in io.netty.channel.embedded

Classes in io.netty.channel.embedded that implement EventExecutor

Modifier and Type	Class	Description
(package private) final class	EmbeddedEventLoop

Uses of EventExecutor in io.netty.channel.epoll

Classes in io.netty.channel.epoll that implement EventExecutor

Modifier and Type	Class	Description
class	EpollEventLoop	EventLoop which uses epoll under the covers.

Uses of EventExecutor in io.netty.channel.group

Fields in io.netty.channel.group declared as EventExecutor

Modifier and Type	Field	Description
private final EventExecutor	DefaultChannelGroup.executor

Constructors in io.netty.channel.group with parameters of type EventExecutor

Modifier	Constructor	Description
	DefaultChannelGroup(EventExecutor executor)	Creates a new group with a generated name and the provided EventExecutor to notify the ChannelGroupFutures.
	DefaultChannelGroup(EventExecutor executor, boolean stayClosed)	Creates a new group with a generated name and the provided EventExecutor to notify the ChannelGroupFutures.
	DefaultChannelGroup(String name, EventExecutor executor)	Creates a new group with the specified name and EventExecutor to notify the ChannelGroupFutures.
	DefaultChannelGroup(String name, EventExecutor executor, boolean stayClosed)	Creates a new group with the specified name and EventExecutor to notify the ChannelGroupFutures.
(package private)	DefaultChannelGroupFuture(ChannelGroup group, Collection<ChannelFuture> futures, EventExecutor executor)	Creates a new instance.
(package private)	DefaultChannelGroupFuture(ChannelGroup group, Map<Channel, ChannelFuture> futures, EventExecutor executor)

Uses of EventExecutor in io.netty.channel.kqueue

Classes in io.netty.channel.kqueue that implement EventExecutor

Modifier and Type	Class	Description
(package private) final class	KQueueEventLoop	EventLoop which uses kqueue under the covers.

Uses of EventExecutor in io.netty.channel.nio

Classes in io.netty.channel.nio that implement EventExecutor

Modifier and Type	Class	Description
final class	NioEventLoop	SingleThreadEventLoop implementation which register the Channel's to a Selector and so does the multi-plexing of these in the event loop.

Uses of EventExecutor in io.netty.channel.pool

Fields in io.netty.channel.pool declared as EventExecutor

Modifier and Type	Field	Description
private final EventExecutor	FixedChannelPool.executor

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

Constructors in io.netty.handler.codec.http2 with parameters of type EventExecutor

Modifier	Constructor	Description
(package private)	SimpleChannelPromiseAggregator(ChannelPromise promise, Channel c, EventExecutor e)

Uses of EventExecutor in io.netty.handler.proxy

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

Modifier and Type	Method	Description
protected EventExecutor	ProxyHandler.LazyChannelPromise.executor()

Uses of EventExecutor in io.netty.handler.ssl

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

Modifier and Type	Method	Description
protected EventExecutor	SslHandler.LazyChannelPromise.executor()

Uses of EventExecutor in io.netty.handler.traffic

Constructors in io.netty.handler.traffic with parameters of type EventExecutor

Modifier	Constructor	Description
	GlobalTrafficShapingHandler(EventExecutor executor)	Create a new instance using default Check Interval value of 1000 ms and default max time as delay allowed value of 15000 ms and no limit.

Uses of EventExecutor in io.netty.resolver

Fields in io.netty.resolver declared as EventExecutor

Modifier and Type	Field	Description
private final EventExecutor	AbstractAddressResolver.executor
private final EventExecutor	SimpleNameResolver.executor

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

Modifier and Type	Field	Description
private final Map<EventExecutor, GenericFutureListener<Future<Object>>>	AddressResolverGroup.executorTerminationListeners
private final Map<EventExecutor, AddressResolver<T>>	AddressResolverGroup.resolvers	Note that we do not use a ConcurrentMap here because it is usually expensive to instantiate a resolver.

Methods in io.netty.resolver that return EventExecutor

Modifier and Type	Method	Description
protected EventExecutor	AbstractAddressResolver.executor()	Returns the EventExecutor which is used to notify the listeners of the Future returned by AbstractAddressResolver.resolve(SocketAddress).
protected EventExecutor	SimpleNameResolver.executor()	Returns the EventExecutor which is used to notify the listeners of the Future returned by SimpleNameResolver.resolve(String).

Methods in io.netty.resolver with parameters of type EventExecutor

Modifier and Type	Method	Description
AddressResolver<T>	AddressResolverGroup.getResolver(EventExecutor executor)	Returns the AddressResolver associated with the specified EventExecutor.
protected abstract AddressResolver<T>	AddressResolverGroup.newResolver(EventExecutor executor)	Invoked by AddressResolverGroup.getResolver(EventExecutor) to create a new AddressResolver.
protected AddressResolver<InetSocketAddress>	DefaultAddressResolverGroup.newResolver(EventExecutor executor)
protected AddressResolver<SocketAddress>	NoopAddressResolverGroup.newResolver(EventExecutor executor)

Constructors in io.netty.resolver with parameters of type EventExecutor

Modifier	Constructor	Description
protected	AbstractAddressResolver(EventExecutor executor)
protected	AbstractAddressResolver(EventExecutor executor, Class<? extends T> addressType)
	CompositeNameResolver(EventExecutor executor, NameResolver<T>... resolvers)
	DefaultNameResolver(EventExecutor executor)
protected	InetNameResolver(EventExecutor executor)
	InetSocketAddressResolver(EventExecutor executor, NameResolver<InetAddress> nameResolver)
	NoopAddressResolver(EventExecutor executor)
	RoundRobinInetAddressResolver(EventExecutor executor, NameResolver<InetAddress> nameResolver)
protected	SimpleNameResolver(EventExecutor executor)

Uses of EventExecutor in io.netty.resolver.dns

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

Modifier and Type	Field	Description
private final EventExecutor	InflightNameResolver.executor

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

Modifier and Type	Method	Description
protected final AddressResolver<InetSocketAddress>	DnsAddressResolverGroup.newResolver(EventExecutor executor)

Constructors in io.netty.resolver.dns with parameters of type EventExecutor

Modifier	Constructor	Description
(package private)	InflightNameResolver(EventExecutor executor, NameResolver<T> delegate, ConcurrentMap<String, Promise<T>> resolvesInProgress, ConcurrentMap<String, Promise<List<T>>> resolveAllsInProgress)

Uses of EventExecutor in io.netty.util.concurrent

Subinterfaces of EventExecutor in io.netty.util.concurrent

Modifier and Type	Interface	Description
interface	OrderedEventExecutor	Marker interface for EventExecutors that will process all submitted tasks in an ordered / serial fashion.

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

Modifier and Type	Class	Description
class	AbstractEventExecutor	Abstract base class for EventExecutor implementations.
class	AbstractScheduledEventExecutor	Abstract base class for EventExecutors that want to support scheduling.
final class	DefaultEventExecutor	Default SingleThreadEventExecutor implementation which just execute all submitted task in a serial fashion.
final class	GlobalEventExecutor	Single-thread singleton EventExecutor.
final class	ImmediateEventExecutor	Executes Runnable objects in the caller's thread.
private static final class	NonStickyEventExecutorGroup.NonStickyOrderedEventExecutor
class	SingleThreadEventExecutor	Abstract base class for OrderedEventExecutor's that execute all its submitted tasks in a single thread.
final class	UnorderedThreadPoolEventExecutor	EventExecutor implementation which makes no guarantees about the ordering of task execution that are submitted because there may be multiple threads executing these tasks.

Subinterfaces with type arguments of type EventExecutor in io.netty.util.concurrent

Modifier and Type	Interface	Description
interface	EventExecutorGroup	The EventExecutorGroup is responsible for providing the EventExecutor's to use via its EventExecutorGroup.next() method.

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

Modifier and Type	Field	Description
private final EventExecutor[]	MultithreadEventExecutorGroup.children
private final EventExecutor	CompleteFuture.executor
private final EventExecutor	DefaultPromise.executor
private final EventExecutor	NonStickyEventExecutorGroup.NonStickyOrderedEventExecutor.executor
private final EventExecutor	PromiseCombiner.executor
private final EventExecutor[]	DefaultEventExecutorChooserFactory.GenericEventExecutorChooser.executors
private final EventExecutor[]	DefaultEventExecutorChooserFactory.PowerOfTwoEventExecutorChooser.executors

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

Modifier and Type	Field	Description
private final Set<EventExecutor>	UnorderedThreadPoolEventExecutor.executorSet
private final Set<EventExecutor>	MultithreadEventExecutorGroup.readonlyChildren
private final Collection<EventExecutor>	AbstractEventExecutor.selfCollection

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

Modifier and Type	Method	Description
protected EventExecutor	CompleteFuture.executor()	Return the EventExecutor which is used by this CompleteFuture.
protected EventExecutor	DefaultPromise.executor()	Get the executor used to notify listeners when this promise is complete.
protected EventExecutor	ScheduledFutureTask.executor()
protected EventExecutor	DefaultEventExecutorGroup.newChild(Executor executor, Object... args)
protected abstract EventExecutor	MultithreadEventExecutorGroup.newChild(Executor executor, Object... args)	Create a new EventExecutor which will later then accessible via the MultithreadEventExecutorGroup.next() method.
EventExecutor	AbstractEventExecutor.next()
EventExecutor	DefaultEventExecutorChooserFactory.GenericEventExecutorChooser.next()
EventExecutor	DefaultEventExecutorChooserFactory.PowerOfTwoEventExecutorChooser.next()
EventExecutor	EventExecutor.next()	Returns a reference to itself.
EventExecutor	EventExecutorChooserFactory.EventExecutorChooser.next()	Returns the new EventExecutor to use.
EventExecutor	EventExecutorGroup.next()	Returns one of the EventExecutors managed by this EventExecutorGroup.
EventExecutor	MultithreadEventExecutorGroup.next()
EventExecutor	NonStickyEventExecutorGroup.next()
EventExecutor	UnorderedThreadPoolEventExecutor.next()

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

Modifier and Type	Method	Description
Iterator<EventExecutor>	AbstractEventExecutor.iterator()
Iterator<EventExecutor>	EventExecutorGroup.iterator()
Iterator<EventExecutor>	MultithreadEventExecutorGroup.iterator()
Iterator<EventExecutor>	NonStickyEventExecutorGroup.iterator()
Iterator<EventExecutor>	UnorderedThreadPoolEventExecutor.iterator()

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

Modifier and Type	Method	Description
EventExecutorChooserFactory.EventExecutorChooser	DefaultEventExecutorChooserFactory.newChooser(EventExecutor[] executors)
EventExecutorChooserFactory.EventExecutorChooser	EventExecutorChooserFactory.newChooser(EventExecutor[] executors)	Returns a new EventExecutorChooserFactory.EventExecutorChooser.
private NonStickyEventExecutorGroup.NonStickyOrderedEventExecutor	NonStickyEventExecutorGroup.newExecutor(EventExecutor executor)
protected static void	DefaultPromise.notifyListener(EventExecutor eventExecutor, Future<?> future, GenericFutureListener<?> listener)	Notify a listener that a future has completed.
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.
private static void	DefaultPromise.safeExecute(EventExecutor executor, Runnable task)

Constructors in io.netty.util.concurrent with parameters of type EventExecutor

Modifier	Constructor	Description
protected	CompleteFuture(EventExecutor executor)	Creates a new instance.
	DefaultProgressivePromise(EventExecutor executor)	Creates a new instance.
	DefaultPromise(EventExecutor executor)	Creates a new instance.
	FailedFuture(EventExecutor executor, Throwable cause)	Creates a new instance.
(package private)	GenericEventExecutorChooser(EventExecutor[] executors)
(package private)	ImmediateProgressivePromise(EventExecutor executor)
(package private)	ImmediatePromise(EventExecutor executor)
(package private)	NonStickyOrderedEventExecutor(EventExecutor executor, int maxTaskExecutePerRun)
(package private)	PowerOfTwoEventExecutorChooser(EventExecutor[] executors)
	PromiseCombiner(EventExecutor executor)	The EventExecutor to use for notifications.
(package private)	PromiseTask(EventExecutor executor, Runnable runnable)
(package private)	PromiseTask(EventExecutor executor, Runnable runnable, V result)
(package private)	PromiseTask(EventExecutor executor, Callable<V> callable)
(package private)	RunnableScheduledFutureTask(EventExecutor executor, RunnableScheduledFuture<V> future, boolean wasCallable)
	SucceededFuture(EventExecutor executor, V result)	Creates a new instance.

Uses of EventExecutor in io.netty.util.internal

Fields in io.netty.util.internal with type parameters of type EventExecutor

Modifier and Type	Field	Description
private static final FastThreadLocal<EventExecutor>	ThreadExecutorMap.mappings

Methods in io.netty.util.internal that return EventExecutor

Modifier and Type	Method	Description
static EventExecutor	ThreadExecutorMap.currentExecutor()	Returns the current EventExecutor that uses the Thread, or null if none / unknown.
static EventExecutor	ThreadExecutorMap.setCurrentExecutor(EventExecutor executor)	Set the current EventExecutor that is used by the Thread.

Methods in io.netty.util.internal with parameters of type EventExecutor

Modifier and Type	Method	Description
static Runnable	ThreadExecutorMap.apply(Runnable command, EventExecutor eventExecutor)	Decorate the given Runnable and ensure ThreadExecutorMap.currentExecutor() will return eventExecutor when called from within the Runnable during execution.
static Executor	ThreadExecutorMap.apply(Executor executor, EventExecutor eventExecutor)	Decorate the given Executor and ensure ThreadExecutorMap.currentExecutor() will return eventExecutor when called from within the Runnable during execution.
static ThreadFactory	ThreadExecutorMap.apply(ThreadFactory threadFactory, EventExecutor eventExecutor)	Decorate the given ThreadFactory and ensure ThreadExecutorMap.currentExecutor() will return eventExecutor when called from within the Runnable during execution.
static EventExecutor	ThreadExecutorMap.setCurrentExecutor(EventExecutor executor)	Set the current EventExecutor that is used by the Thread.