Uses of Interface
io.netty5.util.concurrent.EventExecutor
-
Packages that use EventExecutor Package Description io.netty5.channel The core channel API which is asynchronous and event-driven abstraction of various transports such as a NIO Channel.io.netty5.channel.group A channel registry which helps a user maintain the list of openChannel
s and perform bulk operations on them.io.netty5.channel.internal Internal utilities for channel implementations.io.netty5.handler.traffic Implementation of a Traffic Shaping Handler and Dynamic Statistics.io.netty5.resolver Resolves an arbitrary string that represents the name of an endpoint into an address.io.netty5.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.netty5.util.concurrent Utility classes for concurrent / async tasks.io.netty5.util.internal Internal-use-only utilities which is not allowed to be used outside Netty. -
-
Uses of EventExecutor in io.netty5.channel
Subinterfaces of EventExecutor in io.netty5.channel Modifier and Type Interface Description interface
EventLoop
Will handle all the I/O operations for aIoHandle
once registered.Classes in io.netty5.channel that implement EventExecutor Modifier and Type Class Description class
SingleThreadEventLoop
Methods in io.netty5.channel that return EventExecutor Modifier and Type Method Description EventExecutor
ChannelOutboundInvoker. executor()
Returns theEventExecutor
that is used to execute the operations of thisChannelOutboundInvoker
.EventExecutor
DefaultChannelPipeline. executor()
protected EventExecutor
AbstractChannel.DefaultAbstractChannelPipeline. transportExecutor()
protected abstract EventExecutor
DefaultChannelPipeline. transportExecutor()
Returns theEventExecutor
that is used for all the abstract transport operations.Constructors in io.netty5.channel with parameters of type EventExecutor Constructor Description PendingWriteQueue(EventExecutor executor, MessageSizeEstimator.Handle handle)
-
Uses of EventExecutor in io.netty5.channel.group
Constructors in io.netty5.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(String name, EventExecutor executor)
DefaultChannelGroup(String name, EventExecutor executor, boolean stayClosed)
-
Uses of EventExecutor in io.netty5.channel.internal
Methods in io.netty5.channel.internal that return EventExecutor Modifier and Type Method Description EventExecutor
DelegatingChannelHandlerContext. executor()
-
Uses of EventExecutor in io.netty5.handler.traffic
Constructors in io.netty5.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.TrafficCounter(EventExecutor executor, String name, long checkInterval)
Constructor with theAbstractTrafficShapingHandler
that hosts it, theScheduledExecutorService
to use, its name, the checkInterval between two computations in milliseconds. -
Uses of EventExecutor in io.netty5.resolver
Methods in io.netty5.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.netty5.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<InetSocketAddress>
DefaultAddressResolverGroup. newResolver(EventExecutor executor)
protected AddressResolver<SocketAddress>
NoopAddressResolverGroup. newResolver(EventExecutor executor)
Constructors in io.netty5.resolver with parameters of type EventExecutor Constructor Description AbstractAddressResolver(EventExecutor executor)
AbstractAddressResolver(EventExecutor executor, Class<? extends T> addressType)
CompositeNameResolver(EventExecutor executor, NameResolver<T>... resolvers)
DefaultNameResolver(EventExecutor executor)
InetNameResolver(EventExecutor executor)
InetSocketAddressResolver(EventExecutor executor, NameResolver<InetAddress> nameResolver)
NoopAddressResolver(EventExecutor executor)
RoundRobinInetAddressResolver(EventExecutor executor, NameResolver<InetAddress> nameResolver)
SimpleNameResolver(EventExecutor executor)
-
Uses of EventExecutor in io.netty5.resolver.dns
Methods in io.netty5.resolver.dns with parameters of type EventExecutor Modifier and Type Method Description protected AddressResolver<InetSocketAddress>
DnsAddressResolverGroup. newResolver(EventExecutor executor)
-
Uses of EventExecutor in io.netty5.util.concurrent
Subinterfaces of EventExecutor in io.netty5.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.netty5.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
GlobalEventExecutor
Single-thread singletonEventExecutor
.class
ImmediateEventExecutor
ExecutesRunnable
objects in the caller's thread.class
SingleThreadEventExecutor
OrderedEventExecutor
's implementation 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.Methods in io.netty5.util.concurrent that return EventExecutor Modifier and Type Method Description EventExecutor
DefaultPromise. executor()
Get the executor used to notify listeners when this promise is complete.default EventExecutor
FutureCompletionStage. executor()
protected EventExecutor
MultithreadEventExecutorGroup. newChild(Executor executor, int maxPendingTasks, RejectedExecutionHandler rejectedExecutionHandler, Object... args)
Create a new EventExecutor which will later then accessible via theMultithreadEventExecutorGroup.next()
method.default EventExecutor
EventExecutor. next()
Returns a reference to itself.EventExecutor
EventExecutorGroup. next()
Returns one of theEventExecutor
s managed by thisEventExecutorGroup
.EventExecutor
MultithreadEventExecutorGroup. next()
Returns the nextEventExecutor
to use.EventExecutor
NonStickyEventExecutorGroup. next()
Methods in io.netty5.util.concurrent that return types with arguments of type EventExecutor Modifier and Type Method Description protected List<EventExecutor>
MultithreadEventExecutorGroup. executors()
TheEventExecutor
s that are used by thisMultithreadEventExecutorGroup
.default Iterator<EventExecutor>
EventExecutor. iterator()
Iterator<EventExecutor>
EventExecutorGroup. iterator()
Iterator<EventExecutor>
MultithreadEventExecutorGroup. iterator()
Iterator<EventExecutor>
NonStickyEventExecutorGroup. iterator()
Methods in io.netty5.util.concurrent with parameters of type EventExecutor Modifier and Type Method Description protected void
DefaultPromise. checkDeadLock(EventExecutor executor)
static <U> FutureCompletionStage<U>
FutureCompletionStage. toFutureCompletionStage(CompletionStage<U> stage, EventExecutor executor)
Returns aFutureCompletionStage
for the givenCompletionStage
that is pinned to the givenEventExecutor
.Constructors in io.netty5.util.concurrent with parameters of type EventExecutor Constructor Description DefaultPromise(EventExecutor executor)
Creates a new unfulfilled promise.PromiseCombiner(EventExecutor executor)
TheEventExecutor
to use for notifications. -
Uses of EventExecutor in io.netty5.util.internal
Methods in io.netty5.util.internal that return EventExecutor Modifier and Type Method Description static EventExecutor
ThreadExecutorMap. currentExecutor()
Methods in io.netty5.util.internal with parameters of type EventExecutor Modifier and Type Method Description static 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.
-