Package org.infinispan.server.core.transport

Class NonRecursiveEventLoopGroup

java.lang.Object

org.infinispan.server.core.utils.DelegatingEventLoopGroup

org.infinispan.server.core.transport.NonRecursiveEventLoopGroup

All Implemented Interfaces:

io.netty.channel.EventLoopGroup, io.netty.util.concurrent.EventExecutorGroup, Iterable<io.netty.util.concurrent.EventExecutor>, Executor, ExecutorService, ScheduledExecutorService

public class NonRecursiveEventLoopGroup
extends DelegatingEventLoopGroup

This event loop group prevents any tasks submitted via the Executor.execute(Runnable)}, ExecutorService.submit(Runnable), ExecutorService.submit(Callable), ExecutorService.submit(Runnable, Object) API methods from being ran on the same event loop that submitted it. This is to prevent issues where some operations block on the result of another task (e.g. Cache creation).

Constructor Summary

Constructors

Constructor	Description
NonRecursiveEventLoopGroup(io.netty.channel.MultithreadEventLoopGroup eventLoopGroup)

Method Summary

Modifier and Type	Method	Description
protected io.netty.channel.EventLoopGroup	delegate()
void	execute(Runnable command)
void	shutdownGracefullyAndWait()
io.netty.util.concurrent.Future<?>	submit(Runnable task)
<T> io.netty.util.concurrent.Future<T>	submit(Runnable task, T result)
<T> io.netty.util.concurrent.Future<T>	submit(Callable<T> task)

Methods inherited from class org.infinispan.server.core.utils.DelegatingEventLoopGroup

awaitTermination, invokeAll, invokeAll, invokeAny, invokeAny, isShutdown, isShuttingDown, isTerminated, iterator, next, register, register, register, schedule, schedule, scheduleAtFixedRate, scheduleWithFixedDelay, shutdown, shutdownGracefully, shutdownGracefully, shutdownNow, terminationFuture

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Constructor Details

NonRecursiveEventLoopGroup

public NonRecursiveEventLoopGroup(io.netty.channel.MultithreadEventLoopGroup eventLoopGroup)

Method Details

delegate

protected io.netty.channel.EventLoopGroup delegate()

Specified by:

delegate in class DelegatingEventLoopGroup

execute

public void execute(Runnable command)

Specified by:

execute in interface Executor

Overrides:

execute in class DelegatingEventLoopGroup

submit

public io.netty.util.concurrent.Future<?> submit(Runnable task)

Specified by:

submit in interface io.netty.util.concurrent.EventExecutorGroup

Specified by:

submit in interface ExecutorService

Overrides:

submit in class DelegatingEventLoopGroup

submit

public <T> io.netty.util.concurrent.Future<T> submit(Callable<T> task)

Specified by:

submit in interface io.netty.util.concurrent.EventExecutorGroup

Specified by:

submit in interface ExecutorService

Overrides:

submit in class DelegatingEventLoopGroup

submit

public <T> io.netty.util.concurrent.Future<T> submit(Runnable task,
 T result)

Specified by:

submit in interface io.netty.util.concurrent.EventExecutorGroup

Specified by:

submit in interface ExecutorService

Overrides:

submit in class DelegatingEventLoopGroup

shutdownGracefullyAndWait

public void shutdownGracefullyAndWait()