Uses of Interface
io.netty.util.concurrent.EventExecutor
-
Packages that use EventExecutor Package Description 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.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.nio NIO-based channel API implementation - recommended for a large number of connections (>= 1000).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.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.interface
IoEventLoop
Classes in io.netty.channel that implement EventExecutor Modifier and Type Class Description class
AbstractEventLoop
Skeletal implementation ofEventLoop
.class
DefaultEventLoop
class
ManualIoEventLoop
IoEventLoop
implementation that is owned by the user and so needs to be driven by the user manually with the givenThread
.class
SingleThreadEventLoop
Abstract base class forEventLoop
s that execute all its submitted tasks in a single thread.class
SingleThreadIoEventLoop
IoEventLoop
implementation that execute all its submitted tasks in a single thread using the providedIoHandler
.class
ThreadPerChannelEventLoop
Deprecated.this will be remove in the next-major release.Methods in io.netty.channel that return EventExecutor Modifier and Type Method Description EventExecutor
ChannelHandlerContext. executor()
Returns theEventExecutor
which is used to execute an arbitrary task.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.Constructors in io.netty.channel with parameters of type EventExecutor Constructor Description DefaultChannelProgressivePromise(Channel channel, EventExecutor executor)
Creates a new instance.DefaultChannelPromise(Channel channel, EventExecutor executor)
Creates a new instance. -
Uses of EventExecutor in io.netty.channel.epoll
Classes in io.netty.channel.epoll that implement EventExecutor Modifier and Type Class Description class
EpollEventLoop
Deprecated.UseSingleThreadIoEventLoop
withEpollIoHandler
-
Uses of EventExecutor in io.netty.channel.group
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)
-
Uses of EventExecutor in io.netty.channel.nio
Classes in io.netty.channel.nio that implement EventExecutor Modifier and Type Class Description class
NioEventLoop
Deprecated.UseSingleThreadIoEventLoop
withNioIoHandler
-
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
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
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)
-
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.class
SingleThreadEventExecutor
Abstract base class forOrderedEventExecutor
's that execute all its submitted tasks in a single thread.class
UnorderedThreadPoolEventExecutor
Deprecated.The behavior of this event executor deviates from the typical Netty execution model and can cause subtle issues as a result.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
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
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()
Deprecated.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()
Deprecated.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
.protected static void
DefaultPromise. notifyListener(EventExecutor eventExecutor, Future<?> future, GenericFutureListener<?> listener)
Notify a listener that a future has completed.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.PromiseCombiner(EventExecutor executor)
TheEventExecutor
to use for notifications.SucceededFuture(EventExecutor executor, V result)
Creates a new instance. -
Uses of EventExecutor in io.netty.util.internal
Methods in io.netty.util.internal that return EventExecutor Modifier and Type Method Description static 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 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.static EventExecutor
ThreadExecutorMap. setCurrentExecutor(EventExecutor executor)
Set the currentEventExecutor
that is used by theThread
.
-