Uses of Interface
io.netty.util.concurrent.RejectedExecutionHandler
-
Packages that use RejectedExecutionHandler Package Description io.netty.channel The core channel API which is asynchronous and event-driven abstraction of various transports such as a NIO Channel.io.netty.channel.nio NIO-based channel API implementation - recommended for a large number of connections (>= 1000).io.netty.util.concurrent Utility classes for concurrent / async tasks. -
-
Uses of RejectedExecutionHandler in io.netty.channel
Constructors in io.netty.channel with parameters of type RejectedExecutionHandler Constructor Description SingleThreadEventLoop(EventLoopGroup parent, java.util.concurrent.Executor executor, boolean addTaskWakesUp, int maxPendingTasks, RejectedExecutionHandler rejectedExecutionHandler)
SingleThreadEventLoop(EventLoopGroup parent, java.util.concurrent.Executor executor, boolean addTaskWakesUp, java.util.Queue<java.lang.Runnable> taskQueue, java.util.Queue<java.lang.Runnable> tailTaskQueue, RejectedExecutionHandler rejectedExecutionHandler)
SingleThreadEventLoop(EventLoopGroup parent, java.util.concurrent.ThreadFactory threadFactory, boolean addTaskWakesUp, int maxPendingTasks, RejectedExecutionHandler rejectedExecutionHandler)
-
Uses of RejectedExecutionHandler in io.netty.channel.nio
Constructors in io.netty.channel.nio with parameters of type RejectedExecutionHandler Constructor Description NioEventLoop(NioEventLoopGroup parent, java.util.concurrent.Executor executor, java.nio.channels.spi.SelectorProvider selectorProvider, SelectStrategy strategy, RejectedExecutionHandler rejectedExecutionHandler, EventLoopTaskQueueFactory queueFactory)
NioEventLoopGroup(int nThreads, java.util.concurrent.Executor executor, EventExecutorChooserFactory chooserFactory, java.nio.channels.spi.SelectorProvider selectorProvider, SelectStrategyFactory selectStrategyFactory, RejectedExecutionHandler rejectedExecutionHandler)
NioEventLoopGroup(int nThreads, java.util.concurrent.Executor executor, EventExecutorChooserFactory chooserFactory, java.nio.channels.spi.SelectorProvider selectorProvider, SelectStrategyFactory selectStrategyFactory, RejectedExecutionHandler rejectedExecutionHandler, EventLoopTaskQueueFactory taskQueueFactory)
-
Uses of RejectedExecutionHandler in io.netty.util.concurrent
Fields in io.netty.util.concurrent declared as RejectedExecutionHandler Modifier and Type Field Description private static RejectedExecutionHandler
RejectedExecutionHandlers. REJECT
private RejectedExecutionHandler
SingleThreadEventExecutor. rejectedExecutionHandler
Methods in io.netty.util.concurrent that return RejectedExecutionHandler Modifier and Type Method Description static RejectedExecutionHandler
RejectedExecutionHandlers. backoff(int retries, long backoffAmount, java.util.concurrent.TimeUnit unit)
Tries to backoff when the task can not be added due restrictions for an configured amount of time.static RejectedExecutionHandler
RejectedExecutionHandlers. reject()
Returns aRejectedExecutionHandler
that will always just throw aRejectedExecutionException
.Constructors in io.netty.util.concurrent with parameters of type RejectedExecutionHandler Constructor Description DefaultEventExecutor(EventExecutorGroup parent, java.util.concurrent.Executor executor, int maxPendingTasks, RejectedExecutionHandler rejectedExecutionHandler)
DefaultEventExecutor(EventExecutorGroup parent, java.util.concurrent.ThreadFactory threadFactory, int maxPendingTasks, RejectedExecutionHandler rejectedExecutionHandler)
DefaultEventExecutorGroup(int nThreads, java.util.concurrent.ThreadFactory threadFactory, int maxPendingTasks, RejectedExecutionHandler rejectedHandler)
Create a new instance.SingleThreadEventExecutor(EventExecutorGroup parent, java.util.concurrent.Executor executor, boolean addTaskWakesUp, int maxPendingTasks, RejectedExecutionHandler rejectedHandler)
Create a new instanceSingleThreadEventExecutor(EventExecutorGroup parent, java.util.concurrent.Executor executor, boolean addTaskWakesUp, java.util.Queue<java.lang.Runnable> taskQueue, RejectedExecutionHandler rejectedHandler)
SingleThreadEventExecutor(EventExecutorGroup parent, java.util.concurrent.ThreadFactory threadFactory, boolean addTaskWakesUp, int maxPendingTasks, RejectedExecutionHandler rejectedHandler)
Create a new instance
-