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.EventLoopGroup
Returns the underlyingEventLoopGroup
.boolean
Checks if the calling thread is an I/O thread managed by thisNettyIoExecutor
.next()
Returns aEventLoopAwareNettyIoExecutor
that is tied to a singleEventLoop
and not aEventLoopGroup
.Methods inherited from interface io.servicetalk.concurrent.api.AsyncCloseable
closeAsync, closeAsyncGracefully
Methods inherited from interface io.servicetalk.concurrent.api.Executor
submit, submit, submitCallable, submitRunnable, timer, timer
Methods inherited from interface io.servicetalk.concurrent.Executor
currentTime, schedule
Methods inherited from interface io.servicetalk.transport.api.IoExecutor
execute, isFileDescriptorSocketAddressSupported, isIoThreadSupported, isUnixDomainSocketSupported, schedule, shouldOffloadSupplier
Methods inherited from interface io.servicetalk.concurrent.api.ListenableAsyncCloseable
onClose, onClosing
Methods 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:
true
if the calling thread is an I/O thread managed by thisNettyIoExecutor
.
-
eventLoopGroup
io.netty.channel.EventLoopGroup eventLoopGroup()Returns the underlyingEventLoopGroup
.- Returns:
EventLoopGroup
used by thisEventLoopAwareNettyIoExecutor
.
-
next
Returns aEventLoopAwareNettyIoExecutor
that is tied to a singleEventLoop
and not aEventLoopGroup
.- Returns:
EventLoopAwareNettyIoExecutor
that is tied to a singleEventLoop
and not aEventLoopGroup
.
-