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 openChannels 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 interfaceEventLoopWill handle all the I/O operations for aIoHandleonce registered.Classes in io.netty5.channel that implement EventExecutor Modifier and Type Class Description classSingleThreadEventLoopMethods in io.netty5.channel that return EventExecutor Modifier and Type Method Description EventExecutorChannelOutboundInvoker. executor()Returns theEventExecutorthat is used to execute the operations of thisChannelOutboundInvoker.EventExecutorDefaultChannelPipeline. executor()protected EventExecutorAbstractChannel.DefaultAbstractChannelPipeline. transportExecutor()protected abstract EventExecutorDefaultChannelPipeline. transportExecutor()Returns theEventExecutorthat 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 providedEventExecutorto notify theChannelGroupFutures.DefaultChannelGroup(EventExecutor executor, boolean stayClosed)Creates a new group with a generated name and the providedEventExecutorto notify theChannelGroupFutures.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 EventExecutorDelegatingChannelHandlerContext. 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 theAbstractTrafficShapingHandlerthat hosts it, theScheduledExecutorServiceto 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 EventExecutorAbstractAddressResolver. executor()Returns theEventExecutorwhich is used to notify the listeners of theFuturereturned byAbstractAddressResolver.resolve(SocketAddress).protected EventExecutorSimpleNameResolver. executor()Returns theEventExecutorwhich is used to notify the listeners of theFuturereturned 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 theAddressResolverassociated 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 interfaceOrderedEventExecutorMarker interface forEventExecutors 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 classAbstractEventExecutorAbstract base class forEventExecutorimplementations.classAbstractScheduledEventExecutorAbstract base class forEventExecutors that want to support scheduling.classGlobalEventExecutorSingle-thread singletonEventExecutor.classImmediateEventExecutorExecutesRunnableobjects in the caller's thread.classSingleThreadEventExecutorOrderedEventExecutor's implementation that execute all its submitted tasks in a single thread.classUnorderedThreadPoolEventExecutorEventExecutorimplementation 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 EventExecutorDefaultPromise. executor()Get the executor used to notify listeners when this promise is complete.default EventExecutorFutureCompletionStage. executor()protected EventExecutorMultithreadEventExecutorGroup. newChild(Executor executor, int maxPendingTasks, RejectedExecutionHandler rejectedExecutionHandler, Object... args)Create a new EventExecutor which will later then accessible via theMultithreadEventExecutorGroup.next()method.default EventExecutorEventExecutor. next()Returns a reference to itself.EventExecutorEventExecutorGroup. next()Returns one of theEventExecutors managed by thisEventExecutorGroup.EventExecutorMultithreadEventExecutorGroup. next()Returns the nextEventExecutorto use.EventExecutorNonStickyEventExecutorGroup. 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()TheEventExecutors 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 voidDefaultPromise. checkDeadLock(EventExecutor executor)static <U> FutureCompletionStage<U>FutureCompletionStage. toFutureCompletionStage(CompletionStage<U> stage, EventExecutor executor)Returns aFutureCompletionStagefor the givenCompletionStagethat 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)TheEventExecutorto 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 EventExecutorThreadExecutorMap. currentExecutor()Methods in io.netty5.util.internal with parameters of type EventExecutor Modifier and Type Method Description static RunnableThreadExecutorMap. apply(Runnable command, EventExecutor eventExecutor)Decorate the givenRunnableand ensureThreadExecutorMap.currentExecutor()will returneventExecutorwhen called from within theRunnableduring execution.static ExecutorThreadExecutorMap. apply(Executor executor, EventExecutor eventExecutor)Decorate the givenExecutorand ensureThreadExecutorMap.currentExecutor()will returneventExecutorwhen called from within theRunnableduring execution.static ThreadFactoryThreadExecutorMap. apply(ThreadFactory threadFactory, EventExecutor eventExecutor)Decorate the givenThreadFactoryand ensureThreadExecutorMap.currentExecutor()will returneventExecutorwhen called from within theRunnableduring execution.
-