public abstract class DelegatingEventLoopGroup extends Object implements io.netty.channel.EventLoopGroup
EventLoopGroup that just delegates to another EventLoopGroup. Useful for extending or building decorators.| Modifier | Constructor and Description |
|---|---|
protected |
DelegatingEventLoopGroup(io.netty.channel.EventLoopGroup delegate) |
| Modifier and Type | Method and Description |
|---|---|
boolean |
awaitTermination(long timeout,
TimeUnit unit) |
void |
execute(Runnable command) |
io.netty.channel.EventLoopGroup |
getDelegate() |
<T> List<Future<T>> |
invokeAll(Collection<? extends Callable<T>> tasks) |
<T> List<Future<T>> |
invokeAll(Collection<? extends Callable<T>> tasks,
long timeout,
TimeUnit unit) |
<T> T |
invokeAny(Collection<? extends Callable<T>> tasks) |
<T> T |
invokeAny(Collection<? extends Callable<T>> tasks,
long timeout,
TimeUnit unit) |
boolean |
isShutdown() |
boolean |
isShuttingDown() |
boolean |
isTerminated() |
Iterator<io.netty.util.concurrent.EventExecutor> |
iterator() |
io.netty.channel.EventLoop |
next() |
io.netty.channel.ChannelFuture |
register(io.netty.channel.Channel channel) |
io.netty.channel.ChannelFuture |
register(io.netty.channel.Channel channel,
io.netty.channel.ChannelPromise promise) |
io.netty.channel.ChannelFuture |
register(io.netty.channel.ChannelPromise promise) |
<V> io.netty.util.concurrent.ScheduledFuture<V> |
schedule(Callable<V> callable,
long delay,
TimeUnit unit) |
io.netty.util.concurrent.ScheduledFuture<?> |
schedule(Runnable command,
long delay,
TimeUnit unit) |
io.netty.util.concurrent.ScheduledFuture<?> |
scheduleAtFixedRate(Runnable command,
long initialDelay,
long period,
TimeUnit unit) |
io.netty.util.concurrent.ScheduledFuture<?> |
scheduleWithFixedDelay(Runnable command,
long initialDelay,
long delay,
TimeUnit unit) |
void |
shutdown() |
io.netty.util.concurrent.Future<?> |
shutdownGracefully() |
io.netty.util.concurrent.Future<?> |
shutdownGracefully(long quietPeriod,
long timeout,
TimeUnit unit) |
List<Runnable> |
shutdownNow() |
<T> io.netty.util.concurrent.Future<T> |
submit(Callable<T> task) |
io.netty.util.concurrent.Future<?> |
submit(Runnable task) |
<T> io.netty.util.concurrent.Future<T> |
submit(Runnable task,
T result) |
io.netty.util.concurrent.Future<?> |
terminationFuture() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitforEach, spliteratorprotected DelegatingEventLoopGroup(io.netty.channel.EventLoopGroup delegate)
public io.netty.channel.EventLoopGroup getDelegate()
EventLoopGroup being delegated to.public boolean isShuttingDown()
isShuttingDown in interface io.netty.util.concurrent.EventExecutorGrouppublic io.netty.util.concurrent.Future<?> shutdownGracefully()
shutdownGracefully in interface io.netty.util.concurrent.EventExecutorGrouppublic io.netty.util.concurrent.Future<?> shutdownGracefully(long quietPeriod,
long timeout,
TimeUnit unit)
shutdownGracefully in interface io.netty.util.concurrent.EventExecutorGrouppublic io.netty.util.concurrent.Future<?> terminationFuture()
terminationFuture in interface io.netty.util.concurrent.EventExecutorGrouppublic void shutdown()
shutdown in interface io.netty.util.concurrent.EventExecutorGroupshutdown in interface ExecutorServicepublic List<Runnable> shutdownNow()
shutdownNow in interface io.netty.util.concurrent.EventExecutorGroupshutdownNow in interface ExecutorServicepublic boolean isShutdown()
isShutdown in interface ExecutorServicepublic boolean isTerminated()
isTerminated in interface ExecutorServicepublic boolean awaitTermination(long timeout,
TimeUnit unit)
throws InterruptedException
awaitTermination in interface ExecutorServiceInterruptedExceptionpublic io.netty.channel.EventLoop next()
next in interface io.netty.channel.EventLoopGroupnext in interface io.netty.util.concurrent.EventExecutorGrouppublic Iterator<io.netty.util.concurrent.EventExecutor> iterator()
public io.netty.util.concurrent.Future<?> submit(Runnable task)
submit in interface io.netty.util.concurrent.EventExecutorGroupsubmit in interface ExecutorServicepublic <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks) throws InterruptedException
invokeAll in interface ExecutorServiceInterruptedExceptionpublic <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) throws InterruptedException
invokeAll in interface ExecutorServiceInterruptedExceptionpublic <T> T invokeAny(Collection<? extends Callable<T>> tasks) throws InterruptedException, ExecutionException
invokeAny in interface ExecutorServiceInterruptedExceptionExecutionExceptionpublic <T> T invokeAny(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) throws InterruptedException, ExecutionException, TimeoutException
invokeAny in interface ExecutorServiceInterruptedExceptionExecutionExceptionTimeoutExceptionpublic <T> io.netty.util.concurrent.Future<T> submit(Runnable task, T result)
submit in interface io.netty.util.concurrent.EventExecutorGroupsubmit in interface ExecutorServicepublic <T> io.netty.util.concurrent.Future<T> submit(Callable<T> task)
submit in interface io.netty.util.concurrent.EventExecutorGroupsubmit in interface ExecutorServicepublic io.netty.util.concurrent.ScheduledFuture<?> schedule(Runnable command, long delay, TimeUnit unit)
schedule in interface io.netty.util.concurrent.EventExecutorGroupschedule in interface ScheduledExecutorServicepublic <V> io.netty.util.concurrent.ScheduledFuture<V> schedule(Callable<V> callable, long delay, TimeUnit unit)
schedule in interface io.netty.util.concurrent.EventExecutorGroupschedule in interface ScheduledExecutorServicepublic io.netty.util.concurrent.ScheduledFuture<?> scheduleAtFixedRate(Runnable command, long initialDelay, long period, TimeUnit unit)
scheduleAtFixedRate in interface io.netty.util.concurrent.EventExecutorGroupscheduleAtFixedRate in interface ScheduledExecutorServicepublic io.netty.util.concurrent.ScheduledFuture<?> scheduleWithFixedDelay(Runnable command, long initialDelay, long delay, TimeUnit unit)
scheduleWithFixedDelay in interface io.netty.util.concurrent.EventExecutorGroupscheduleWithFixedDelay in interface ScheduledExecutorServicepublic io.netty.channel.ChannelFuture register(io.netty.channel.Channel channel)
register in interface io.netty.channel.EventLoopGrouppublic io.netty.channel.ChannelFuture register(io.netty.channel.ChannelPromise promise)
register in interface io.netty.channel.EventLoopGrouppublic io.netty.channel.ChannelFuture register(io.netty.channel.Channel channel,
io.netty.channel.ChannelPromise promise)
register in interface io.netty.channel.EventLoopGroupCopyright © 2019. All rights reserved.