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 virtualChannel
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 openChannel
s 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 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.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 aChannel
once registered.Classes in io.netty.channel that implement EventExecutor Modifier and Type Class Description class
AbstractEventLoop
Skeletal implementation ofEventLoop
.class
DefaultEventLoop
class
SingleThreadEventLoop
Abstract base class forEventLoop
s 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) EventExecutor
AbstractChannelHandlerContext. executor
private EventExecutor
PendingWriteQueue. executor
Fields in io.netty.channel with type parameters of type EventExecutor Modifier and Type Field Description private java.util.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 theEventExecutor
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 java.util.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, java.lang.Runnable runnable, ChannelPromise promise, java.lang.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 Constructor Description AbstractChannelHandlerContext(DefaultChannelPipeline pipeline, EventExecutor executor, java.lang.String name, java.lang.Class<? extends ChannelHandler> handlerClass)
CompleteChannelFuture(Channel channel, EventExecutor executor)
Creates a new instance.DefaultChannelHandlerContext(DefaultChannelPipeline pipeline, EventExecutor executor, java.lang.String name, ChannelHandler handler)
DefaultChannelProgressivePromise(Channel channel, EventExecutor executor)
Creates a new instance.DefaultChannelPromise(Channel channel, EventExecutor executor)
Creates a new instance.FailedChannelFuture(Channel channel, EventExecutor executor, java.lang.Throwable cause)
Creates a new instance.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) class
EmbeddedEventLoop
-
Uses of EventExecutor in io.netty.channel.epoll
Classes in io.netty.channel.epoll that implement EventExecutor Modifier and Type Class Description (package private) 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 EventExecutor
DefaultChannelGroup. executor
Constructors in io.netty.channel.group with parameters of type EventExecutor Constructor Description DefaultChannelGroup(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(java.lang.String name, EventExecutor executor)
DefaultChannelGroup(java.lang.String name, EventExecutor executor, boolean stayClosed)
DefaultChannelGroupFuture(ChannelGroup group, java.util.Collection<ChannelFuture> futures, EventExecutor executor)
Creates a new instance.DefaultChannelGroupFuture(ChannelGroup group, java.util.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) 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 class
NioEventLoop
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 Modifier and Type Field Description private EventExecutor
FixedChannelPool. executor
-
Uses of EventExecutor in io.netty.handler.codec.http2
Constructors in io.netty.handler.codec.http2 with parameters of type EventExecutor Constructor Description 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 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 EventExecutor
AbstractAddressResolver. executor
private EventExecutor
SimpleNameResolver. executor
Fields in io.netty.resolver with type parameters of type EventExecutor Modifier and Type Field Description private java.util.Map<EventExecutor,GenericFutureListener<Future<java.lang.Object>>>
AddressResolverGroup. executorTerminationListeners
private java.util.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 EventExecutor Modifier and Type Method Description protected 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 EventExecutor Modifier and Type Method Description AddressResolver<T>
AddressResolverGroup. 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<java.net.InetSocketAddress>
DefaultAddressResolverGroup. newResolver(EventExecutor executor)
protected AddressResolver<java.net.SocketAddress>
NoopAddressResolverGroup. newResolver(EventExecutor executor)
Constructors in io.netty.resolver with parameters of type EventExecutor Constructor Description AbstractAddressResolver(EventExecutor executor)
AbstractAddressResolver(EventExecutor executor, java.lang.Class<? extends T> addressType)
CompositeNameResolver(EventExecutor executor, NameResolver<T>... resolvers)
DefaultNameResolver(EventExecutor executor)
InetNameResolver(EventExecutor executor)
InetSocketAddressResolver(EventExecutor executor, NameResolver<java.net.InetAddress> nameResolver)
NoopAddressResolver(EventExecutor executor)
RoundRobinInetAddressResolver(EventExecutor executor, NameResolver<java.net.InetAddress> nameResolver)
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 EventExecutor
InflightNameResolver. executor
Methods in io.netty.resolver.dns with parameters of type EventExecutor Modifier and Type Method Description protected AddressResolver<java.net.InetSocketAddress>
DnsAddressResolverGroup. newResolver(EventExecutor executor)
Constructors in io.netty.resolver.dns with parameters of type EventExecutor Constructor Description InflightNameResolver(EventExecutor executor, NameResolver<T> delegate, java.util.concurrent.ConcurrentMap<java.lang.String,Promise<T>> resolvesInProgress, java.util.concurrent.ConcurrentMap<java.lang.String,Promise<java.util.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 forEventExecutor
s 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 forEventExecutor
implementations.class
AbstractScheduledEventExecutor
Abstract base class forEventExecutor
s that want to support scheduling.class
DefaultEventExecutor
DefaultSingleThreadEventExecutor
implementation which just execute all submitted task in a serial fashion.class
GlobalEventExecutor
Single-thread singletonEventExecutor
.class
ImmediateEventExecutor
ExecutesRunnable
objects in the caller's thread.private static class
NonStickyEventExecutorGroup.NonStickyOrderedEventExecutor
class
SingleThreadEventExecutor
Abstract base class forOrderedEventExecutor
's that execute all its submitted tasks in a single thread.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.Fields in io.netty.util.concurrent declared as EventExecutor Modifier and Type Field Description private EventExecutor[]
MultithreadEventExecutorGroup. children
private EventExecutor
CompleteFuture. executor
private EventExecutor
DefaultPromise. executor
private EventExecutor
NonStickyEventExecutorGroup.NonStickyOrderedEventExecutor. executor
private EventExecutor
PromiseCombiner. executor
private EventExecutor[]
DefaultEventExecutorChooserFactory.GenericEventExecutorChooser. executors
private EventExecutor[]
DefaultEventExecutorChooserFactory.PowerOfTwoEventExecutorChooser. executors
Fields in io.netty.util.concurrent with type parameters of type EventExecutor Modifier and Type Field Description private java.util.Set<EventExecutor>
UnorderedThreadPoolEventExecutor. executorSet
private java.util.Set<EventExecutor>
MultithreadEventExecutorGroup. readonlyChildren
private java.util.Collection<EventExecutor>
AbstractEventExecutor. selfCollection
Methods in io.netty.util.concurrent that return EventExecutor Modifier and Type Method Description protected 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
DefaultEventExecutorGroup. newChild(java.util.concurrent.Executor executor, java.lang.Object... args)
protected abstract EventExecutor
MultithreadEventExecutorGroup. newChild(java.util.concurrent.Executor executor, java.lang.Object... args)
Create a new EventExecutor which will later then accessible via theMultithreadEventExecutorGroup.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 newEventExecutor
to use.EventExecutor
EventExecutorGroup. next()
Returns one of theEventExecutor
s managed by thisEventExecutorGroup
.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 java.util.Iterator<EventExecutor>
AbstractEventExecutor. iterator()
java.util.Iterator<EventExecutor>
EventExecutorGroup. iterator()
java.util.Iterator<EventExecutor>
MultithreadEventExecutorGroup. iterator()
java.util.Iterator<EventExecutor>
NonStickyEventExecutorGroup. iterator()
java.util.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 newEventExecutorChooserFactory.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 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, java.lang.Runnable task)
Constructors in io.netty.util.concurrent with parameters of type EventExecutor Constructor Description CompleteFuture(EventExecutor executor)
Creates a new instance.DefaultProgressivePromise(EventExecutor executor)
Creates a new instance.DefaultPromise(EventExecutor executor)
Creates a new instance.FailedFuture(EventExecutor executor, java.lang.Throwable cause)
Creates a new instance.GenericEventExecutorChooser(EventExecutor[] executors)
ImmediateProgressivePromise(EventExecutor executor)
ImmediatePromise(EventExecutor executor)
NonStickyOrderedEventExecutor(EventExecutor executor, int maxTaskExecutePerRun)
PowerOfTwoEventExecutorChooser(EventExecutor[] executors)
PromiseCombiner(EventExecutor executor)
TheEventExecutor
to use for notifications.PromiseTask(EventExecutor executor, java.lang.Runnable runnable)
PromiseTask(EventExecutor executor, java.lang.Runnable runnable, V result)
PromiseTask(EventExecutor executor, java.util.concurrent.Callable<V> callable)
RunnableScheduledFutureTask(EventExecutor executor, java.util.concurrent.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 FastThreadLocal<EventExecutor>
ThreadExecutorMap. mappings
Methods in io.netty.util.internal that return EventExecutor Modifier and Type Method Description static EventExecutor
ThreadExecutorMap. currentExecutor()
Methods in io.netty.util.internal with parameters of type EventExecutor Modifier and Type Method Description static java.lang.Runnable
ThreadExecutorMap. apply(java.lang.Runnable command, EventExecutor eventExecutor)
Decorate the givenRunnable
and ensureThreadExecutorMap.currentExecutor()
will returneventExecutor
when called from within theRunnable
during execution.static java.util.concurrent.Executor
ThreadExecutorMap. apply(java.util.concurrent.Executor executor, EventExecutor eventExecutor)
Decorate the givenExecutor
and ensureThreadExecutorMap.currentExecutor()
will returneventExecutor
when called from within theRunnable
during execution.static java.util.concurrent.ThreadFactory
ThreadExecutorMap. apply(java.util.concurrent.ThreadFactory threadFactory, EventExecutor eventExecutor)
Decorate the givenThreadFactory
and ensureThreadExecutorMap.currentExecutor()
will returneventExecutor
when called from within theRunnable
during execution.private static void
ThreadExecutorMap. setCurrentEventExecutor(EventExecutor executor)
Set the currentEventExecutor
that is used by theThread
.
-