Uses of Interface
io.netty.util.concurrent.EventExecutor
Packages that use EventExecutor
Package
Description
The helper classes with fluent API which enable an easy implementation of
typical client side and server side channel initialization.
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
Channel
s and perform bulk operations on them.BSD specific transport.
NIO-based channel
API implementation - recommended for a large number of connections (>= 1000).
Implementations and API for
Channel
pools.Handlers for sending and receiving HTTP/2 frames.
Adds support for client connections via proxy protocols such as
SOCKS and
HTTP CONNECT tunneling
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 for concurrent / async tasks.
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 EventExecutorModifier and TypeMethodDescriptionprotected EventExecutor
AbstractBootstrap.PendingRegistrationPromise.executor()
-
Uses of EventExecutor in io.netty.channel
Subinterfaces of EventExecutor in io.netty.channelModifier and TypeInterfaceDescriptioninterface
Will handle all the I/O operations for aChannel
once registered.Classes in io.netty.channel that implement EventExecutorModifier and TypeClassDescriptionclass
Skeletal implementation ofEventLoop
.class
class
Abstract base class forEventLoop
s that execute all its submitted tasks in a single thread.class
Deprecated.this will be remove in the next-major release.Fields in io.netty.channel declared as EventExecutorModifier and TypeFieldDescription(package private) final EventExecutor
AbstractChannelHandlerContext.executor
private final EventExecutor
PendingWriteQueue.executor
Fields in io.netty.channel with type parameters of type EventExecutorModifier and TypeFieldDescriptionprivate Map
<EventExecutorGroup, EventExecutor> DefaultChannelPipeline.childExecutors
Methods in io.netty.channel that return EventExecutorModifier and TypeMethodDescriptionprivate EventExecutor
DefaultChannelPipeline.childExecutor
(EventExecutorGroup group) AbstractChannelHandlerContext.executor()
ChannelHandlerContext.executor()
Returns theEventExecutor
which is used to execute an arbitrary task.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 EventExecutorMethods in io.netty.channel with parameters of type EventExecutorModifier and TypeMethodDescriptionprivate 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 EventExecutorModifierConstructorDescription(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 -
Uses of EventExecutor in io.netty.channel.epoll
Classes in io.netty.channel.epoll that implement EventExecutor -
Uses of EventExecutor in io.netty.channel.group
Fields in io.netty.channel.group declared as EventExecutorConstructors in io.netty.channel.group with parameters of type EventExecutorModifierConstructorDescriptionDefaultChannelGroup
(EventExecutor executor) Creates a new group with a generated name and the providedEventExecutor
to notify theChannelGroupFuture
s.DefaultChannelGroup
(EventExecutor executor, boolean stayClosed) Creates a new group with a generated name and the providedEventExecutor
to notify theChannelGroupFuture
s.DefaultChannelGroup
(String name, EventExecutor executor) DefaultChannelGroup
(String name, EventExecutor executor, boolean stayClosed) (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 EventExecutorModifier and TypeClassDescription(package private) final class
EventLoop
which uses kqueue under the covers. -
Uses of EventExecutor in io.netty.channel.nio
Classes in io.netty.channel.nio that implement EventExecutorModifier and TypeClassDescriptionfinal class
SingleThreadEventLoop
implementation which register theChannel
's to aSelector
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 -
Uses of EventExecutor in io.netty.handler.codec.http2
Constructors in io.netty.handler.codec.http2 with parameters of type EventExecutorModifierConstructorDescription(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 EventExecutorModifier and TypeMethodDescriptionprotected EventExecutor
ProxyHandler.LazyChannelPromise.executor()
-
Uses of EventExecutor in io.netty.handler.ssl
Methods in io.netty.handler.ssl that return EventExecutorModifier and TypeMethodDescriptionprotected EventExecutor
SslHandler.LazyChannelPromise.executor()
-
Uses of EventExecutor in io.netty.handler.traffic
Constructors in io.netty.handler.traffic with parameters of type EventExecutorModifierConstructorDescriptionGlobalTrafficShapingHandler
(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 EventExecutorModifier and TypeFieldDescriptionprivate final EventExecutor
AbstractAddressResolver.executor
private final EventExecutor
SimpleNameResolver.executor
Fields in io.netty.resolver with type parameters of type EventExecutorModifier and TypeFieldDescriptionprivate final Map
<EventExecutor, GenericFutureListener<Future<Object>>> AddressResolverGroup.executorTerminationListeners
private final Map
<EventExecutor, AddressResolver<T>> AddressResolverGroup.resolvers
Note that we do not use aConcurrentMap
here because it is usually expensive to instantiate a resolver.Methods in io.netty.resolver that return EventExecutorModifier and TypeMethodDescriptionprotected EventExecutor
AbstractAddressResolver.executor()
Returns theEventExecutor
which is used to notify the listeners of theFuture
returned byAbstractAddressResolver.resolve(SocketAddress)
.protected EventExecutor
SimpleNameResolver.executor()
Returns theEventExecutor
which is used to notify the listeners of theFuture
returned bySimpleNameResolver.resolve(String)
.Methods in io.netty.resolver with parameters of type EventExecutorModifier and TypeMethodDescriptionAddressResolverGroup.getResolver
(EventExecutor executor) Returns theAddressResolver
associated with the specifiedEventExecutor
.protected abstract AddressResolver
<T> AddressResolverGroup.newResolver
(EventExecutor executor) Invoked byAddressResolverGroup.getResolver(EventExecutor)
to create a newAddressResolver
.protected AddressResolver
<InetSocketAddress> DefaultAddressResolverGroup.newResolver
(EventExecutor executor) protected AddressResolver
<SocketAddress> NoopAddressResolverGroup.newResolver
(EventExecutor executor) Constructors in io.netty.resolver with parameters of type EventExecutorModifierConstructorDescriptionprotected
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 EventExecutorMethods in io.netty.resolver.dns with parameters of type EventExecutorModifier and TypeMethodDescriptionprotected final AddressResolver
<InetSocketAddress> DnsAddressResolverGroup.newResolver
(EventExecutor executor) Constructors in io.netty.resolver.dns with parameters of type EventExecutorModifierConstructorDescription(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.concurrentModifier and TypeInterfaceDescriptioninterface
Marker interface forEventExecutor
s that will process all submitted tasks in an ordered / serial fashion.Classes in io.netty.util.concurrent that implement EventExecutorModifier and TypeClassDescriptionclass
Abstract base class forEventExecutor
implementations.class
Abstract base class forEventExecutor
s that want to support scheduling.final class
DefaultSingleThreadEventExecutor
implementation which just execute all submitted task in a serial fashion.final class
Single-thread singletonEventExecutor
.final class
ExecutesRunnable
objects in the caller's thread.private static final class
class
Abstract base class forOrderedEventExecutor
's that execute all its submitted tasks in a single thread.final class
EventExecutor
implementation which makes no guarantees about the ordering of task execution that are submitted because there may be multiple threads executing these tasks.Fields in io.netty.util.concurrent declared as EventExecutorModifier and TypeFieldDescriptionprivate 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 EventExecutorModifier and TypeFieldDescriptionprivate 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 EventExecutorModifier and TypeMethodDescriptionprotected EventExecutor
CompleteFuture.executor()
Return theEventExecutor
which is used by thisCompleteFuture
.protected EventExecutor
DefaultPromise.executor()
Get the executor used to notify listeners when this promise is complete.protected EventExecutor
ScheduledFutureTask.executor()
protected EventExecutor
protected abstract EventExecutor
Create a new EventExecutor which will later then accessible via theMultithreadEventExecutorGroup.next()
method.AbstractEventExecutor.next()
DefaultEventExecutorChooserFactory.GenericEventExecutorChooser.next()
DefaultEventExecutorChooserFactory.PowerOfTwoEventExecutorChooser.next()
EventExecutor.next()
Returns a reference to itself.EventExecutorChooserFactory.EventExecutorChooser.next()
Returns the newEventExecutor
to use.EventExecutorGroup.next()
Returns one of theEventExecutor
s managed by thisEventExecutorGroup
.MultithreadEventExecutorGroup.next()
NonStickyEventExecutorGroup.next()
UnorderedThreadPoolEventExecutor.next()
Methods in io.netty.util.concurrent that return types with arguments of type EventExecutorModifier and TypeMethodDescriptionAbstractEventExecutor.iterator()
EventExecutorGroup.iterator()
MultithreadEventExecutorGroup.iterator()
NonStickyEventExecutorGroup.iterator()
UnorderedThreadPoolEventExecutor.iterator()
Methods in io.netty.util.concurrent with parameters of type EventExecutorModifier and TypeMethodDescriptionDefaultEventExecutorChooserFactory.newChooser
(EventExecutor[] executors) EventExecutorChooserFactory.newChooser
(EventExecutor[] executors) Returns a newEventExecutorChooserFactory.EventExecutorChooser
.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 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.private static void
DefaultPromise.safeExecute
(EventExecutor executor, Runnable task) Constructors in io.netty.util.concurrent with parameters of type EventExecutorModifierConstructorDescriptionprotected
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) TheEventExecutor
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 EventExecutorModifier and TypeFieldDescriptionprivate static final FastThreadLocal
<EventExecutor> ThreadExecutorMap.mappings
Methods in io.netty.util.internal that return EventExecutorModifier and TypeMethodDescriptionstatic EventExecutor
ThreadExecutorMap.currentExecutor()
static EventExecutor
ThreadExecutorMap.setCurrentExecutor
(EventExecutor executor) Set the currentEventExecutor
that is used by theThread
.Methods in io.netty.util.internal with parameters of type EventExecutorModifier and TypeMethodDescriptionstatic Runnable
ThreadExecutorMap.apply
(Runnable command, EventExecutor eventExecutor) Decorate the givenRunnable
and ensureThreadExecutorMap.currentExecutor()
will returneventExecutor
when called from within theRunnable
during execution.static Executor
ThreadExecutorMap.apply
(Executor executor, EventExecutor eventExecutor) Decorate the givenExecutor
and ensureThreadExecutorMap.currentExecutor()
will returneventExecutor
when called from within theRunnable
during execution.static ThreadFactory
ThreadExecutorMap.apply
(ThreadFactory threadFactory, EventExecutor eventExecutor) Decorate the givenThreadFactory
and ensureThreadExecutorMap.currentExecutor()
will returneventExecutor
when called from within theRunnable
during execution.static EventExecutor
ThreadExecutorMap.setCurrentExecutor
(EventExecutor executor) Set the currentEventExecutor
that is used by theThread
.