io.netty.util.concurrent

接口 EventExecutorGroup

所有超级接口:

java.util.concurrent.Executor, java.util.concurrent.ExecutorService, java.lang.Iterable<EventExecutor>, java.util.concurrent.ScheduledExecutorService

所有已知子接口:

EventExecutor, EventLoop, EventLoopGroup, OrderedEventExecutor

所有已知实现类:

AbstractEventExecutor, AbstractEventExecutorGroup, AbstractEventLoop, AbstractEventLoopGroup, AbstractScheduledEventExecutor, DefaultEventExecutor, DefaultEventExecutorGroup, DefaultEventLoop, DefaultEventLoopGroup, EpollEventLoop, EpollEventLoopGroup, GlobalEventExecutor, ImmediateEventExecutor, KQueueEventLoopGroup, LocalEventLoopGroup, MultithreadEventExecutorGroup, MultithreadEventLoopGroup, NioEventLoop, NioEventLoopGroup, NonStickyEventExecutorGroup, OioEventLoopGroup, SingleThreadEventExecutor, SingleThreadEventLoop, ThreadPerChannelEventLoop, ThreadPerChannelEventLoopGroup, UnorderedThreadPoolEventExecutor

public interface EventExecutorGroup
extends java.util.concurrent.ScheduledExecutorService, java.lang.Iterable<EventExecutor>

The EventExecutorGroup is responsible for providing the EventExecutor's to use via its next() method. Besides this, it is also responsible for handling their life-cycle and allows shutting them down in a global fashion.

方法概要

限定符和类型	方法和说明
boolean	isShuttingDown() Returns true if and only if all EventExecutors managed by this EventExecutorGroup are being shut down gracefully or was shut down.
java.util.Iterator<EventExecutor>	iterator()
EventExecutor	next() Returns one of the EventExecutors managed by this EventExecutorGroup.
<V> ScheduledFuture<V>	schedule(java.util.concurrent.Callable<V> callable, long delay, java.util.concurrent.TimeUnit unit)
ScheduledFuture<?>	schedule(java.lang.Runnable command, long delay, java.util.concurrent.TimeUnit unit)
ScheduledFuture<?>	scheduleAtFixedRate(java.lang.Runnable command, long initialDelay, long period, java.util.concurrent.TimeUnit unit)
ScheduledFuture<?>	scheduleWithFixedDelay(java.lang.Runnable command, long initialDelay, long delay, java.util.concurrent.TimeUnit unit)
void	shutdown() 已过时。 shutdownGracefully(long, long, TimeUnit) or shutdownGracefully() instead.
Future<?>	shutdownGracefully() Shortcut method for shutdownGracefully(long, long, TimeUnit) with sensible default values.
Future<?>	shutdownGracefully(long quietPeriod, long timeout, java.util.concurrent.TimeUnit unit) Signals this executor that the caller wants the executor to be shut down.
java.util.List<java.lang.Runnable>	shutdownNow() 已过时。 shutdownGracefully(long, long, TimeUnit) or shutdownGracefully() instead.
<T> Future<T>	submit(java.util.concurrent.Callable<T> task)
Future<?>	submit(java.lang.Runnable task)
<T> Future<T>	submit(java.lang.Runnable task, T result)
Future<?>	terminationFuture() Returns the Future which is notified when all EventExecutors managed by this EventExecutorGroup have been terminated.

从接口继承的方法 java.util.concurrent.ExecutorService

awaitTermination, invokeAll, invokeAll, invokeAny, invokeAny, isShutdown, isTerminated

从接口继承的方法 java.util.concurrent.Executor

execute

从接口继承的方法 java.lang.Iterable

forEach, spliterator

方法详细资料

isShuttingDown

boolean isShuttingDown()

Returns true if and only if all EventExecutors managed by this EventExecutorGroup are being shut down gracefully or was shut down.

shutdownGracefully

Future<?> shutdownGracefully()

Shortcut method for shutdownGracefully(long, long, TimeUnit) with sensible default values.

返回:

the terminationFuture()

shutdownGracefully

Future<?> shutdownGracefully(long quietPeriod,
                             long timeout,
                             java.util.concurrent.TimeUnit unit)

Signals this executor that the caller wants the executor to be shut down. Once this method is called, isShuttingDown() starts to return true, and the executor prepares to shut itself down. Unlike shutdown(), graceful shutdown ensures that no tasks are submitted for 'the quiet period' (usually a couple seconds) before it shuts itself down. If a task is submitted during the quiet period, it is guaranteed to be accepted and the quiet period will start over.

参数:

quietPeriod - the quiet period as described in the documentation

timeout - the maximum amount of time to wait until the executor is shutdown() regardless if a task was submitted during the quiet period

unit - the unit of quietPeriod and timeout

返回:

the terminationFuture()

terminationFuture

Future<?> terminationFuture()

Returns the Future which is notified when all EventExecutors managed by this EventExecutorGroup have been terminated.

shutdown

@Deprecated
void shutdown()

已过时。 shutdownGracefully(long, long, TimeUnit) or shutdownGracefully() instead.

指定者:

shutdown 在接口中 java.util.concurrent.ExecutorService

shutdownNow

@Deprecated
java.util.List<java.lang.Runnable> shutdownNow()

已过时。 shutdownGracefully(long, long, TimeUnit) or shutdownGracefully() instead.

指定者:

shutdownNow 在接口中 java.util.concurrent.ExecutorService

next

EventExecutor next()

Returns one of the EventExecutors managed by this EventExecutorGroup.

iterator

java.util.Iterator<EventExecutor> iterator()

指定者:

iterator 在接口中 java.lang.Iterable<EventExecutor>

submit

Future<?> submit(java.lang.Runnable task)

指定者:

submit 在接口中 java.util.concurrent.ExecutorService

submit

<T> Future<T> submit(java.lang.Runnable task,
                     T result)

指定者:

submit 在接口中 java.util.concurrent.ExecutorService

submit

<T> Future<T> submit(java.util.concurrent.Callable<T> task)

指定者:

submit 在接口中 java.util.concurrent.ExecutorService

schedule

ScheduledFuture<?> schedule(java.lang.Runnable command,
                            long delay,
                            java.util.concurrent.TimeUnit unit)

指定者:

schedule 在接口中 java.util.concurrent.ScheduledExecutorService

schedule

<V> ScheduledFuture<V> schedule(java.util.concurrent.Callable<V> callable,
                                long delay,
                                java.util.concurrent.TimeUnit unit)

指定者:

schedule 在接口中 java.util.concurrent.ScheduledExecutorService

scheduleAtFixedRate

ScheduledFuture<?> scheduleAtFixedRate(java.lang.Runnable command,
                                       long initialDelay,
                                       long period,
                                       java.util.concurrent.TimeUnit unit)

指定者:

scheduleAtFixedRate 在接口中 java.util.concurrent.ScheduledExecutorService

scheduleWithFixedDelay

ScheduledFuture<?> scheduleWithFixedDelay(java.lang.Runnable command,
                                          long initialDelay,
                                          long delay,
                                          java.util.concurrent.TimeUnit unit)

指定者:

scheduleWithFixedDelay 在接口中 java.util.concurrent.ScheduledExecutorService