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.epoll Optimized transport for linux which uses EPOLL Edge-Triggered Mode for maximal performance.io.netty.channel.kqueue BSD specific transport.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, boolean supportSuspension, int maxPendingTasks, RejectedExecutionHandler rejectedExecutionHandler)
SingleThreadEventLoop(EventLoopGroup parent, java.util.concurrent.Executor executor, boolean addTaskWakesUp, boolean supportSuspension, java.util.Queue<java.lang.Runnable> taskQueue, java.util.Queue<java.lang.Runnable> tailTaskQueue, RejectedExecutionHandler rejectedExecutionHandler)
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, boolean supportSuspension, int maxPendingTasks, RejectedExecutionHandler rejectedExecutionHandler)
SingleThreadEventLoop(EventLoopGroup parent, java.util.concurrent.ThreadFactory threadFactory, boolean addTaskWakesUp, int maxPendingTasks, RejectedExecutionHandler rejectedExecutionHandler)
SingleThreadIoEventLoop(IoEventLoopGroup parent, java.util.concurrent.Executor executor, IoHandlerFactory ioHandlerFactory, int maxPendingTasks, RejectedExecutionHandler rejectedExecutionHandler, long maxTaskProcessingQuantumMs)
Creates a new instanceSingleThreadIoEventLoop(IoEventLoopGroup parent, java.util.concurrent.Executor executor, IoHandlerFactory ioHandlerFactory, java.util.Queue<java.lang.Runnable> taskQueue, java.util.Queue<java.lang.Runnable> tailTaskQueue, RejectedExecutionHandler rejectedExecutionHandler)
Creates a new instanceSingleThreadIoEventLoop(IoEventLoopGroup parent, java.util.concurrent.ThreadFactory threadFactory, IoHandlerFactory ioHandlerFactory, int maxPendingTasks, RejectedExecutionHandler rejectedExecutionHandler, long maxTaskProcessingQuantumMs)
Creates a new instance -
Uses of RejectedExecutionHandler in io.netty.channel.epoll
Constructors in io.netty.channel.epoll with parameters of type RejectedExecutionHandler Constructor Description EpollEventLoopGroup(int nThreads, java.util.concurrent.Executor executor, EventExecutorChooserFactory chooserFactory, SelectStrategyFactory selectStrategyFactory, RejectedExecutionHandler rejectedExecutionHandler)
Deprecated.EpollEventLoopGroup(int nThreads, java.util.concurrent.Executor executor, EventExecutorChooserFactory chooserFactory, SelectStrategyFactory selectStrategyFactory, RejectedExecutionHandler rejectedExecutionHandler, EventLoopTaskQueueFactory queueFactory)
Deprecated.EpollEventLoopGroup(int nThreads, java.util.concurrent.Executor executor, EventExecutorChooserFactory chooserFactory, SelectStrategyFactory selectStrategyFactory, RejectedExecutionHandler rejectedExecutionHandler, EventLoopTaskQueueFactory taskQueueFactory, EventLoopTaskQueueFactory tailTaskQueueFactory)
Deprecated. -
Uses of RejectedExecutionHandler in io.netty.channel.kqueue
Constructors in io.netty.channel.kqueue with parameters of type RejectedExecutionHandler Constructor Description KQueueEventLoopGroup(int nThreads, java.util.concurrent.Executor executor, EventExecutorChooserFactory chooserFactory, SelectStrategyFactory selectStrategyFactory, RejectedExecutionHandler rejectedExecutionHandler)
Deprecated.KQueueEventLoopGroup(int nThreads, java.util.concurrent.Executor executor, EventExecutorChooserFactory chooserFactory, SelectStrategyFactory selectStrategyFactory, RejectedExecutionHandler rejectedExecutionHandler, EventLoopTaskQueueFactory queueFactory)
Deprecated.KQueueEventLoopGroup(int nThreads, java.util.concurrent.Executor executor, EventExecutorChooserFactory chooserFactory, SelectStrategyFactory selectStrategyFactory, RejectedExecutionHandler rejectedExecutionHandler, EventLoopTaskQueueFactory taskQueueFactory, EventLoopTaskQueueFactory tailTaskQueueFactory)
Deprecated. -
Uses of RejectedExecutionHandler in io.netty.channel.nio
Constructors in io.netty.channel.nio with parameters of type RejectedExecutionHandler Constructor Description NioEventLoopGroup(int nThreads, java.util.concurrent.Executor executor, EventExecutorChooserFactory chooserFactory, java.nio.channels.spi.SelectorProvider selectorProvider, SelectStrategyFactory selectStrategyFactory, RejectedExecutionHandler rejectedExecutionHandler)
Deprecated.NioEventLoopGroup(int nThreads, java.util.concurrent.Executor executor, EventExecutorChooserFactory chooserFactory, java.nio.channels.spi.SelectorProvider selectorProvider, SelectStrategyFactory selectStrategyFactory, RejectedExecutionHandler rejectedExecutionHandler, EventLoopTaskQueueFactory taskQueueFactory)
Deprecated.NioEventLoopGroup(int nThreads, java.util.concurrent.Executor executor, EventExecutorChooserFactory chooserFactory, java.nio.channels.spi.SelectorProvider selectorProvider, SelectStrategyFactory selectStrategyFactory, RejectedExecutionHandler rejectedExecutionHandler, EventLoopTaskQueueFactory taskQueueFactory, EventLoopTaskQueueFactory tailTaskQueueFactory)
Deprecated. -
Uses of RejectedExecutionHandler in io.netty.util.concurrent
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, boolean supportSuspension, int maxPendingTasks, RejectedExecutionHandler rejectedHandler)
Create a new instanceSingleThreadEventExecutor(EventExecutorGroup parent, java.util.concurrent.Executor executor, boolean addTaskWakesUp, boolean supportSuspension, java.util.Queue<java.lang.Runnable> taskQueue, RejectedExecutionHandler rejectedHandler)
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, boolean supportSuspension, int maxPendingTasks, RejectedExecutionHandler rejectedHandler)
Create a new instanceSingleThreadEventExecutor(EventExecutorGroup parent, java.util.concurrent.ThreadFactory threadFactory, boolean addTaskWakesUp, int maxPendingTasks, RejectedExecutionHandler rejectedHandler)
Create a new instance
-