io.netty.util.concurrent

类 UnorderedThreadPoolEventExecutor

java.lang.Object

java.util.concurrent.AbstractExecutorService

java.util.concurrent.ThreadPoolExecutor

java.util.concurrent.ScheduledThreadPoolExecutor

io.netty.util.concurrent.UnorderedThreadPoolEventExecutor

所有已实现的接口:

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

public final class UnorderedThreadPoolEventExecutor
extends java.util.concurrent.ScheduledThreadPoolExecutor
implements EventExecutor

EventExecutor implementation which makes no guarantees about the ordering of task execution that are submitted because there may be multiple threads executing these tasks. This implementation is most useful for protocols that do not need strict ordering. Because it provides no ordering care should be taken when using it!

嵌套类概要

从类继承的嵌套类/接口 java.util.concurrent.ThreadPoolExecutor

java.util.concurrent.ThreadPoolExecutor.AbortPolicy, java.util.concurrent.ThreadPoolExecutor.CallerRunsPolicy, java.util.concurrent.ThreadPoolExecutor.DiscardOldestPolicy, java.util.concurrent.ThreadPoolExecutor.DiscardPolicy

构造器概要

构造器

构造器和说明
UnorderedThreadPoolEventExecutor(int corePoolSize) Calls UnorderedThreadPoolEventExecutor(int, ThreadFactory) using DefaultThreadFactory.
UnorderedThreadPoolEventExecutor(int corePoolSize, java.util.concurrent.RejectedExecutionHandler handler) Calls UnorderedThreadPoolEventExecutor(int, ThreadFactory, java.util.concurrent.RejectedExecutionHandler) using DefaultThreadFactory.
UnorderedThreadPoolEventExecutor(int corePoolSize, java.util.concurrent.ThreadFactory threadFactory) See ScheduledThreadPoolExecutor.ScheduledThreadPoolExecutor(int, ThreadFactory)
UnorderedThreadPoolEventExecutor(int corePoolSize, java.util.concurrent.ThreadFactory threadFactory, java.util.concurrent.RejectedExecutionHandler handler) See ScheduledThreadPoolExecutor.ScheduledThreadPoolExecutor(int, ThreadFactory, RejectedExecutionHandler)

方法概要

限定符和类型	方法和说明
protected <V> java.util.concurrent.RunnableScheduledFuture<V>	decorateTask(java.util.concurrent.Callable<V> callable, java.util.concurrent.RunnableScheduledFuture<V> task)
protected <V> java.util.concurrent.RunnableScheduledFuture<V>	decorateTask(java.lang.Runnable runnable, java.util.concurrent.RunnableScheduledFuture<V> task)
void	execute(java.lang.Runnable command)
boolean	inEventLoop() Calls EventExecutor.inEventLoop(Thread) with Thread.currentThread() as argument
boolean	inEventLoop(java.lang.Thread thread) Return true if the given Thread is executed in the event loop, false otherwise.
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()
<V> Future<V>	newFailedFuture(java.lang.Throwable cause) Create a new Future which is marked as failed already.
<V> ProgressivePromise<V>	newProgressivePromise() Create a new ProgressivePromise.
<V> Promise<V>	newPromise() Return a new Promise.
<V> Future<V>	newSucceededFuture(V result) Create a new Future which is marked as succeeded already.
EventExecutor	next() Returns a reference to itself.
EventExecutorGroup	parent() Return the EventExecutorGroup which is the parent of this EventExecutor,
<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.util.concurrent.ScheduledThreadPoolExecutor

getContinueExistingPeriodicTasksAfterShutdownPolicy, getExecuteExistingDelayedTasksAfterShutdownPolicy, getQueue, getRemoveOnCancelPolicy, setContinueExistingPeriodicTasksAfterShutdownPolicy, setExecuteExistingDelayedTasksAfterShutdownPolicy, setRemoveOnCancelPolicy

从类继承的方法 java.util.concurrent.ThreadPoolExecutor

afterExecute, allowCoreThreadTimeOut, allowsCoreThreadTimeOut, awaitTermination, beforeExecute, finalize, getActiveCount, getCompletedTaskCount, getCorePoolSize, getKeepAliveTime, getLargestPoolSize, getMaximumPoolSize, getPoolSize, getRejectedExecutionHandler, getTaskCount, getThreadFactory, isShutdown, isTerminated, isTerminating, prestartAllCoreThreads, prestartCoreThread, purge, remove, setCorePoolSize, setKeepAliveTime, setMaximumPoolSize, setRejectedExecutionHandler, setThreadFactory, terminated, toString

从类继承的方法 java.util.concurrent.AbstractExecutorService

invokeAll, invokeAll, invokeAny, invokeAny, newTaskFor, newTaskFor

从类继承的方法 java.lang.Object

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

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

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

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

forEach, spliterator

构造器详细资料

UnorderedThreadPoolEventExecutor

public UnorderedThreadPoolEventExecutor(int corePoolSize)

Calls UnorderedThreadPoolEventExecutor(int, ThreadFactory) using DefaultThreadFactory.

UnorderedThreadPoolEventExecutor

public UnorderedThreadPoolEventExecutor(int corePoolSize,
                                        java.util.concurrent.ThreadFactory threadFactory)

See ScheduledThreadPoolExecutor.ScheduledThreadPoolExecutor(int, ThreadFactory)

UnorderedThreadPoolEventExecutor

public UnorderedThreadPoolEventExecutor(int corePoolSize,
                                        java.util.concurrent.RejectedExecutionHandler handler)

Calls UnorderedThreadPoolEventExecutor(int, ThreadFactory, java.util.concurrent.RejectedExecutionHandler) using DefaultThreadFactory.

UnorderedThreadPoolEventExecutor

public UnorderedThreadPoolEventExecutor(int corePoolSize,
                                        java.util.concurrent.ThreadFactory threadFactory,
                                        java.util.concurrent.RejectedExecutionHandler handler)

See ScheduledThreadPoolExecutor.ScheduledThreadPoolExecutor(int, ThreadFactory, RejectedExecutionHandler)

方法详细资料

next

public EventExecutor next()

从接口复制的说明: EventExecutor

Returns a reference to itself.

指定者:

next 在接口中 EventExecutor

指定者:

next 在接口中 EventExecutorGroup

parent

public EventExecutorGroup parent()

从接口复制的说明: EventExecutor

Return the EventExecutorGroup which is the parent of this EventExecutor,

指定者:

parent 在接口中 EventExecutor

inEventLoop

public boolean inEventLoop()

从接口复制的说明: EventExecutor

Calls EventExecutor.inEventLoop(Thread) with Thread.currentThread() as argument

指定者:

inEventLoop 在接口中 EventExecutor

inEventLoop

public boolean inEventLoop(java.lang.Thread thread)

从接口复制的说明: EventExecutor

Return true if the given Thread is executed in the event loop, false otherwise.

指定者:

inEventLoop 在接口中 EventExecutor

newPromise

public <V> Promise<V> newPromise()

从接口复制的说明: EventExecutor

Return a new Promise.

指定者:

newPromise 在接口中 EventExecutor

newProgressivePromise

public <V> ProgressivePromise<V> newProgressivePromise()

从接口复制的说明: EventExecutor

Create a new ProgressivePromise.

指定者:

newProgressivePromise 在接口中 EventExecutor

newSucceededFuture

public <V> Future<V> newSucceededFuture(V result)

从接口复制的说明: EventExecutor

Create a new Future which is marked as succeeded already. So Future.isSuccess() will return true. All FutureListener added to it will be notified directly. Also every call of blocking methods will just return without blocking.

指定者:

newSucceededFuture 在接口中 EventExecutor

newFailedFuture

public <V> Future<V> newFailedFuture(java.lang.Throwable cause)

从接口复制的说明: EventExecutor

Create a new Future which is marked as failed already. So Future.isSuccess() will return false. All FutureListener added to it will be notified directly. Also every call of blocking methods will just return without blocking.

指定者:

newFailedFuture 在接口中 EventExecutor

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

shutdownNow

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

指定者:

shutdownNow 在接口中 EventExecutorGroup

指定者:

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

覆盖:

shutdownNow 在类中 java.util.concurrent.ScheduledThreadPoolExecutor

shutdown

public void shutdown()

指定者:

shutdown 在接口中 EventExecutorGroup

指定者:

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

覆盖:

shutdown 在类中 java.util.concurrent.ScheduledThreadPoolExecutor

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

iterator

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

指定者:

iterator 在接口中 EventExecutorGroup

指定者:

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

decorateTask

protected <V> java.util.concurrent.RunnableScheduledFuture<V> decorateTask(java.lang.Runnable runnable,
                                                                           java.util.concurrent.RunnableScheduledFuture<V> task)

覆盖:

decorateTask 在类中 java.util.concurrent.ScheduledThreadPoolExecutor

decorateTask

protected <V> java.util.concurrent.RunnableScheduledFuture<V> decorateTask(java.util.concurrent.Callable<V> callable,
                                                                           java.util.concurrent.RunnableScheduledFuture<V> task)

覆盖:

decorateTask 在类中 java.util.concurrent.ScheduledThreadPoolExecutor

schedule

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

指定者:

schedule 在接口中 EventExecutorGroup

指定者:

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

覆盖:

schedule 在类中 java.util.concurrent.ScheduledThreadPoolExecutor

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

覆盖:

schedule 在类中 java.util.concurrent.ScheduledThreadPoolExecutor

scheduleAtFixedRate

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

指定者:

scheduleAtFixedRate 在接口中 EventExecutorGroup

指定者:

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

覆盖:

scheduleAtFixedRate 在类中 java.util.concurrent.ScheduledThreadPoolExecutor

scheduleWithFixedDelay

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

指定者:

scheduleWithFixedDelay 在接口中 EventExecutorGroup

指定者:

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

覆盖:

scheduleWithFixedDelay 在类中 java.util.concurrent.ScheduledThreadPoolExecutor

submit

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

指定者:

submit 在接口中 EventExecutorGroup

指定者:

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

覆盖:

submit 在类中 java.util.concurrent.ScheduledThreadPoolExecutor

submit

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

指定者:

submit 在接口中 EventExecutorGroup

指定者:

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

覆盖:

submit 在类中 java.util.concurrent.ScheduledThreadPoolExecutor

submit

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

指定者:

submit 在接口中 EventExecutorGroup

指定者:

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

覆盖:

submit 在类中 java.util.concurrent.ScheduledThreadPoolExecutor

execute

public void execute(java.lang.Runnable command)

指定者:

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

覆盖:

execute 在类中 java.util.concurrent.ScheduledThreadPoolExecutor