io.netty.util.concurrent

类 NonStickyEventExecutorGroup

java.lang.Object

io.netty.util.concurrent.NonStickyEventExecutorGroup

所有已实现的接口:

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

@UnstableApi
public final class NonStickyEventExecutorGroup
extends java.lang.Object
implements EventExecutorGroup

EventExecutorGroup which will preserve Runnable execution order but makes no guarantees about what EventExecutor (and therefore Thread) will be used to execute the Runnables.

The EventExecutorGroup.next() for the wrapped EventExecutorGroup must NOT return executors of type OrderedEventExecutor.

构造器概要

构造器

构造器和说明
NonStickyEventExecutorGroup(EventExecutorGroup group) Creates a new instance.
NonStickyEventExecutorGroup(EventExecutorGroup group, int maxTaskExecutePerRun) Creates a new instance.

方法概要

限定符和类型	方法和说明
boolean	awaitTermination(long timeout, java.util.concurrent.TimeUnit unit)
void	execute(java.lang.Runnable command)
<T> java.util.List<java.util.concurrent.Future<T>>	invokeAll(java.util.Collection<? extends java.util.concurrent.Callable<T>> tasks)
<T> java.util.List<java.util.concurrent.Future<T>>	invokeAll(java.util.Collection<? extends java.util.concurrent.Callable<T>> tasks, long timeout, java.util.concurrent.TimeUnit unit)
<T> T	invokeAny(java.util.Collection<? extends java.util.concurrent.Callable<T>> tasks)
<T> T	invokeAny(java.util.Collection<? extends java.util.concurrent.Callable<T>> tasks, long timeout, java.util.concurrent.TimeUnit unit)
boolean	isShutdown()
boolean	isShuttingDown() Returns true if and only if all EventExecutors managed by this EventExecutorGroup are being shut down gracefully or was shut down.
boolean	isTerminated()
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()
Future<?>	shutdownGracefully() Shortcut method for EventExecutorGroup.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()
<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.lang.Object

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

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

forEach, spliterator

构造器详细资料

NonStickyEventExecutorGroup

public NonStickyEventExecutorGroup(EventExecutorGroup group)

Creates a new instance. Be aware that the given EventExecutorGroup MUST NOT contain any OrderedEventExecutors.

NonStickyEventExecutorGroup

public NonStickyEventExecutorGroup(EventExecutorGroup group,
                                   int maxTaskExecutePerRun)

Creates a new instance. Be aware that the given EventExecutorGroup MUST NOT contain any OrderedEventExecutors.

方法详细资料

isShuttingDown

public boolean isShuttingDown()

从接口复制的说明: EventExecutorGroup

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

指定者:

isShuttingDown 在接口中 EventExecutorGroup

shutdownGracefully

public Future<?> shutdownGracefully()

从接口复制的说明: EventExecutorGroup

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

指定者:

shutdownGracefully 在接口中 EventExecutorGroup

返回:

the EventExecutorGroup.terminationFuture()

shutdownGracefully

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

从接口复制的说明: EventExecutorGroup

Signals this executor that the caller wants the executor to be shut down. Once this method is called, EventExecutorGroup.isShuttingDown() starts to return true, and the executor prepares to shut itself down. Unlike EventExecutorGroup.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.

指定者:

shutdownGracefully 在接口中 EventExecutorGroup

参数:

quietPeriod - the quiet period as described in the documentation

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

unit - the unit of quietPeriod and timeout

返回:

the EventExecutorGroup.terminationFuture()

terminationFuture

public Future<?> terminationFuture()

从接口复制的说明: EventExecutorGroup

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

指定者:

terminationFuture 在接口中 EventExecutorGroup

shutdown

public void shutdown()

指定者:

shutdown 在接口中 EventExecutorGroup

指定者:

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

shutdownNow

public java.util.List<java.lang.Runnable> shutdownNow()

指定者:

shutdownNow 在接口中 EventExecutorGroup

指定者:

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

next

public EventExecutor next()

从接口复制的说明: EventExecutorGroup

Returns one of the EventExecutors managed by this EventExecutorGroup.

指定者:

next 在接口中 EventExecutorGroup

iterator

public java.util.Iterator<EventExecutor> iterator()

指定者:

iterator 在接口中 EventExecutorGroup

指定者:

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

submit

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

指定者:

submit 在接口中 EventExecutorGroup

指定者:

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

submit

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

指定者:

submit 在接口中 EventExecutorGroup

指定者:

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

submit

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

指定者:

submit 在接口中 EventExecutorGroup

指定者:

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

schedule

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

指定者:

schedule 在接口中 EventExecutorGroup

指定者:

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

schedule

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

指定者:

schedule 在接口中 EventExecutorGroup

指定者:

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

scheduleAtFixedRate

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

指定者:

scheduleAtFixedRate 在接口中 EventExecutorGroup

指定者:

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

scheduleWithFixedDelay

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

指定者:

scheduleWithFixedDelay 在接口中 EventExecutorGroup

指定者:

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

isShutdown

public boolean isShutdown()

指定者:

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

isTerminated

public boolean isTerminated()

指定者:

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

awaitTermination

public boolean awaitTermination(long timeout,
                                java.util.concurrent.TimeUnit unit)
                         throws java.lang.InterruptedException

指定者:

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

抛出:

java.lang.InterruptedException

invokeAll

public <T> java.util.List<java.util.concurrent.Future<T>> invokeAll(java.util.Collection<? extends java.util.concurrent.Callable<T>> tasks)
                                                             throws java.lang.InterruptedException

指定者:

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

抛出:

java.lang.InterruptedException

invokeAll

public <T> java.util.List<java.util.concurrent.Future<T>> invokeAll(java.util.Collection<? extends java.util.concurrent.Callable<T>> tasks,
                                                                    long timeout,
                                                                    java.util.concurrent.TimeUnit unit)
                                                             throws java.lang.InterruptedException

指定者:

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

抛出:

java.lang.InterruptedException

invokeAny

public <T> T invokeAny(java.util.Collection<? extends java.util.concurrent.Callable<T>> tasks)
                throws java.lang.InterruptedException,
                       java.util.concurrent.ExecutionException

指定者:

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

抛出:

java.lang.InterruptedException

java.util.concurrent.ExecutionException

invokeAny

public <T> T invokeAny(java.util.Collection<? extends java.util.concurrent.Callable<T>> tasks,
                       long timeout,
                       java.util.concurrent.TimeUnit unit)
                throws java.lang.InterruptedException,
                       java.util.concurrent.ExecutionException,
                       java.util.concurrent.TimeoutException

指定者:

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

抛出:

java.lang.InterruptedException

java.util.concurrent.ExecutionException

java.util.concurrent.TimeoutException

execute

public void execute(java.lang.Runnable command)

指定者:

execute 在接口中 java.util.concurrent.Executor