Interface EventLoopAwareNettyIoExecutor
- All Superinterfaces:
AsyncCloseable,Executor,Executor,IoExecutor,ListenableAsyncCloseable,NettyIoExecutor,TimeSource
A special
NettyIoExecutor that exposes the underlying netty EventLoopGroup.-
Method Summary
Modifier and TypeMethodDescriptionio.netty.channel.EventLoopGroupReturns the underlyingEventLoopGroup.booleanChecks if the calling thread is an I/O thread managed by thisNettyIoExecutor.next()Returns aEventLoopAwareNettyIoExecutorthat is tied to a singleEventLoopand not aEventLoopGroup.Methods inherited from interface io.servicetalk.concurrent.api.AsyncCloseable
closeAsync, closeAsyncGracefullyMethods inherited from interface io.servicetalk.concurrent.api.Executor
submit, submit, submitCallable, submitRunnable, timer, timerMethods inherited from interface io.servicetalk.concurrent.Executor
currentTime, scheduleMethods inherited from interface io.servicetalk.transport.api.IoExecutor
execute, isFileDescriptorSocketAddressSupported, isIoThreadSupported, isUnixDomainSocketSupported, schedule, shouldOffloadSupplierMethods inherited from interface io.servicetalk.concurrent.api.ListenableAsyncCloseable
onClose, onClosingMethods inherited from interface io.servicetalk.transport.netty.internal.NettyIoExecutor
asExecutor
-
Method Details
-
isCurrentThreadEventLoop
boolean isCurrentThreadEventLoop()Checks if the calling thread is an I/O thread managed by thisNettyIoExecutor.- Returns:
trueif the calling thread is an I/O thread managed by thisNettyIoExecutor.
-
eventLoopGroup
io.netty.channel.EventLoopGroup eventLoopGroup()Returns the underlyingEventLoopGroup.- Returns:
EventLoopGroupused by thisEventLoopAwareNettyIoExecutor.
-
next
Returns aEventLoopAwareNettyIoExecutorthat is tied to a singleEventLoopand not aEventLoopGroup.- Returns:
EventLoopAwareNettyIoExecutorthat is tied to a singleEventLoopand not aEventLoopGroup.
-