UnorderedThreadPoolEventExecutor (Netty API Reference (4.1.22.Final))

java.lang.Object
- java.util.concurrent.AbstractExecutorService
- - java.util.concurrent.ThreadPoolExecutor
  - - java.util.concurrent.ScheduledThreadPoolExecutor
    - - io.netty.util.concurrent.UnorderedThreadPoolEventExecutor

All Implemented Interfaces:

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实现，因为可能有多个线程正在执行这些任务，所以对提交的任务执行的排序没有任何保证。该实现对于不需要严格排序的协议非常有用。 因为它提供了使用它时不应该注意的顺序。

Nested Class Summary
- Nested classes/interfaces inherited from class java.util.concurrent.ThreadPoolExecutor
  java.util.concurrent.ThreadPoolExecutor.AbortPolicy, java.util.concurrent.ThreadPoolExecutor.CallerRunsPolicy, java.util.concurrent.ThreadPoolExecutor.DiscardOldestPolicy, java.util.concurrent.ThreadPoolExecutor.DiscardPolicy

构造方法摘要

构造方法
Constructor and Description
`UnorderedThreadPoolEventExecutor(int corePoolSize)` 致电`UnorderedThreadPoolEventExecutor(int, ThreadFactory)`使用`DefaultThreadFactory` 。
`UnorderedThreadPoolEventExecutor(int corePoolSize, java.util.concurrent.RejectedExecutionHandler handler)` 致电`UnorderedThreadPoolEventExecutor(int, ThreadFactory, java.util.concurrent.RejectedExecutionHandler)`使用`DefaultThreadFactory` 。
`UnorderedThreadPoolEventExecutor(int corePoolSize, java.util.concurrent.ThreadFactory threadFactory)` 见 `ScheduledThreadPoolExecutor.ScheduledThreadPoolExecutor(int, ThreadFactory)`
`UnorderedThreadPoolEventExecutor(int corePoolSize, java.util.concurrent.ThreadFactory threadFactory, java.util.concurrent.RejectedExecutionHandler handler)` 见 `ScheduledThreadPoolExecutor.ScheduledThreadPoolExecutor(int, ThreadFactory, RejectedExecutionHandler)`

方法摘要

所有方法接口方法具体的方法
Modifier and Type	Method and Description
`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()` 以 `Thread.currentThread()`作为参数调用 `EventExecutor.inEventLoop(Thread)`
`boolean`	`inEventLoop(java.lang.Thread thread)` 返回 `true`如果给定 `Thread`在事件循环中执行， `false`其他。
`boolean`	`isShuttingDown()` 返回`true`当且仅当所有`EventExecutor`由该被管小号`EventExecutorGroup`正在shut down gracefully或者被关闭。
`java.util.Iterator<EventExecutor>`	`iterator()`
`<V> Future<V>`	`newFailedFuture(java.lang.Throwable cause)` 创建一个新的已被标记为失败的`Future` 。
`<V> ProgressivePromise<V>`	`newProgressivePromise()` 创建一个新的`ProgressivePromise` 。
`<V> Promise<V>`	`newPromise()` 返回一个新的`Promise` 。
`<V> Future<V>`	`newSucceededFuture(V result)` 创建一个新的已被标记为已成功的`Future` 。
`EventExecutor`	`next()` 返回对自身的引用。
`EventExecutorGroup`	`parent()` 返回此`EventExecutor`的父级`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()` 具有合理默认值的 `EventExecutorGroup.shutdownGracefully(long, long, TimeUnit)`的快捷方法。
`Future<?>`	`shutdownGracefully(long quietPeriod, long timeout, java.util.concurrent.TimeUnit unit)` 该执行者表示该调用者希望执行者被关闭。
`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()` 返回`Future` ，当由`EventExecutorGroup`管理的所有`EventExecutor`已终止时，通知`Future` 。

Methods inherited from class java.util.concurrent.ScheduledThreadPoolExecutor
getContinueExistingPeriodicTasksAfterShutdownPolicy, getExecuteExistingDelayedTasksAfterShutdownPolicy, getQueue, getRemoveOnCancelPolicy, setContinueExistingPeriodicTasksAfterShutdownPolicy, setExecuteExistingDelayedTasksAfterShutdownPolicy, setRemoveOnCancelPolicy

Methods inherited from class 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

Methods inherited from class java.util.concurrent.AbstractExecutorService
invokeAll, invokeAll, invokeAny, invokeAny, newTaskFor, newTaskFor

Methods inherited from class java.lang.Object
clone, equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface java.util.concurrent.ExecutorService
awaitTermination, invokeAll, invokeAll, invokeAny, invokeAny, isShutdown, isTerminated

Methods inherited from interface java.lang.Iterable
forEach, spliterator

- 构造方法详细信息
  - UnorderedThreadPoolEventExecutor
```
public UnorderedThreadPoolEventExecutor(int corePoolSize)
```
    致电UnorderedThreadPoolEventExecutor(int, ThreadFactory)使用DefaultThreadFactory 。
  - UnorderedThreadPoolEventExecutor
```
public UnorderedThreadPoolEventExecutor(int corePoolSize,
                                        java.util.concurrent.ThreadFactory threadFactory)
```
    见 ScheduledThreadPoolExecutor.ScheduledThreadPoolExecutor(int, ThreadFactory)
  - UnorderedThreadPoolEventExecutor
```
public UnorderedThreadPoolEventExecutor(int corePoolSize,
                                        java.util.concurrent.RejectedExecutionHandler handler)
```
    致电UnorderedThreadPoolEventExecutor(int, ThreadFactory, java.util.concurrent.RejectedExecutionHandler)使用DefaultThreadFactory 。
  - UnorderedThreadPoolEventExecutor
```
public UnorderedThreadPoolEventExecutor(int corePoolSize,
                                        java.util.concurrent.ThreadFactory threadFactory,
                                        java.util.concurrent.RejectedExecutionHandler handler)
```
    见 ScheduledThreadPoolExecutor.ScheduledThreadPoolExecutor(int, ThreadFactory, RejectedExecutionHandler)
- 方法详细信息
  - next
```
public EventExecutor next()
```
    从界面： EventExecutor复制的描述
    
    返回对自身的引用。
    
    Specified by:
    
    next ，界面 EventExecutor
    
    Specified by:
    
    next ，界面 EventExecutorGroup
  - parent
```
public EventExecutorGroup parent()
```
    从接口EventExecutor复制的描述
    
    返回此EventExecutor的父级EventExecutorGroup ，
    
    Specified by:
    
    parent接口 EventExecutor
  - inEventLoop
```
public boolean inEventLoop()
```
    从界面复制的描述： EventExecutor
    
    以 Thread.currentThread()作为参数调用 EventExecutor.inEventLoop(Thread)
    
    Specified by:
    
    inEventLoop接口 EventExecutor
  - inEventLoop
```
public boolean inEventLoop(java.lang.Thread thread)
```
    从界面： EventExecutor复制的描述
    
    返回 true如果给定 Thread在事件循环中执行， false其他。
    
    Specified by:
    
    inEventLoop ，界面 EventExecutor
  - newPromise
```
public <V> Promise<V> newPromise()
```
    从接口EventExecutor复制的描述
    
    返回一个新的Promise 。
    
    Specified by:
    
    newPromise接口 EventExecutor
  - newProgressivePromise
```
public <V> ProgressivePromise<V> newProgressivePromise()
```
    从接口EventExecutor复制的描述
    
    创建一个新的ProgressivePromise 。
    
    Specified by:
    
    newProgressivePromise ，界面 EventExecutor
  - newSucceededFuture
```
public <V> Future<V> newSucceededFuture(V result)
```
    从界面： EventExecutor复制的描述
    
    创建一个新的已被标记为已成功的Future 。所以Future.isSuccess()将返回true 。所有添加到它的FutureListener将直接通知。同样，每个阻塞方法的调用都会返回而不会阻塞。
    
    Specified by:
    
    newSucceededFuture接口 EventExecutor
  - newFailedFuture
```
public <V> Future<V> newFailedFuture(java.lang.Throwable cause)
```
    从界面复制的描述： EventExecutor
    
    创建一个新的已被标记为失败的Future 。所以Future.isSuccess()将返回false 。所有添加到它的FutureListener将直接通知。同样，每个阻塞方法的调用都会返回而不会阻塞。
    
    Specified by:
    
    newFailedFuture ，界面 EventExecutor
  - isShuttingDown
```
public boolean isShuttingDown()
```
    从界面： EventExecutorGroup复制的描述
    
    退货true当且仅当EventExecutorGroup管理的所有EventExecutor都是shut down gracefully或被关闭。
    
    Specified by:
    
    isShuttingDown接口 EventExecutorGroup
  - shutdownNow
```
public java.util.List<java.lang.Runnable> shutdownNow()
```
    Specified by:
    
    shutdownNow在界面 EventExecutorGroup
    
    Specified by:
    
    shutdownNow ，界面 java.util.concurrent.ExecutorService
    
    重写：
    
    shutdownNow ，课时 java.util.concurrent.ScheduledThreadPoolExecutor
  - shutdown
```
public void shutdown()
```
    Specified by:
    
    shutdown ，界面 EventExecutorGroup
    
    Specified by:
    
    shutdown ，界面 java.util.concurrent.ExecutorService
    
    重写：
    
    shutdown在课堂上 java.util.concurrent.ScheduledThreadPoolExecutor
  - shutdownGracefully
```
public Future<?> shutdownGracefully()
```
    从界面复制的描述： EventExecutorGroup
    
    具有合理默认值的 EventExecutorGroup.shutdownGracefully(long, long, TimeUnit)的快捷方式。
    
    Specified by:
    
    shutdownGracefully ，界面 EventExecutorGroup
    
    结果
    
    EventExecutorGroup.terminationFuture()
  - shutdownGracefully
```
public Future<?> shutdownGracefully(long quietPeriod,
                                    long timeout,
                                    java.util.concurrent.TimeUnit unit)
```
    从界面： EventExecutorGroup复制的描述
    
    该执行者表示该调用者希望执行者被关闭。一旦调用此方法， EventExecutorGroup.isShuttingDown()开始返回true ，并且执行程序准备关闭它。与EventExecutorGroup.shutdown()不同，正常关机可确保在关闭之前没有任何任务被提交“安静期” （通常是几秒钟）。如果任务在安静期提交，则保证被接受，安静期将重新开始。
    
    Specified by:
    
    shutdownGracefully ，界面 EventExecutorGroup
    
    参数
    
    quietPeriod - 文档中描述的安静期
    
    timeout - 无论任务是否在静默期间提交，等待执行程序为 EventExecutorGroup.shutdown()的最长时间
    
    unit - quietPeriod和 timeout的单位
    
    结果
    
    EventExecutorGroup.terminationFuture()
  - terminationFuture
```
public Future<?> terminationFuture()
```
    从界面复制的描述： EventExecutorGroup
    
    返回Future ，当此EventExecutorGroup管理的所有EventExecutor已终止时将通知该Future 。
    
    Specified by:
    
    terminationFuture ，界面 EventExecutorGroup
  - iterator
```
public java.util.Iterator<EventExecutor> iterator()
```
    Specified by:
    
    iterator接口 EventExecutorGroup
    
    Specified by:
    
    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)
```
    Specified by:
    
    schedule ，界面 EventExecutorGroup
    
    Specified by:
    
    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)
```
    Specified by:
    
    schedule ，界面 EventExecutorGroup
    
    Specified by:
    
    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)
```
    Specified by:
    
    scheduleAtFixedRate ，界面 EventExecutorGroup
    
    Specified by:
    
    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)
```
    Specified by:
    
    scheduleWithFixedDelay接口 EventExecutorGroup
    
    Specified by:
    
    scheduleWithFixedDelay接口 java.util.concurrent.ScheduledExecutorService
    
    重写：
    
    scheduleWithFixedDelay在课堂 java.util.concurrent.ScheduledThreadPoolExecutor
  - submit
```
public Future<?> submit(java.lang.Runnable task)
```
    Specified by:
    
    submit在界面 EventExecutorGroup
    
    Specified by:
    
    submit ，界面 java.util.concurrent.ExecutorService
    
    重写：
    
    submit在课程 java.util.concurrent.ScheduledThreadPoolExecutor
  - submit
```
public <T> Future<T> submit(java.lang.Runnable task,
                            T result)
```
    Specified by:
    
    submit ，界面 EventExecutorGroup
    
    Specified by:
    
    submit在界面 java.util.concurrent.ExecutorService
    
    重写：
    
    submit ，课时 java.util.concurrent.ScheduledThreadPoolExecutor
  - submit
```
public <T> Future<T> submit(java.util.concurrent.Callable<T> task)
```
    Specified by:
    
    submit ，界面 EventExecutorGroup
    
    Specified by:
    
    submit ，界面 java.util.concurrent.ExecutorService
    
    重写：
    
    submit在课堂 java.util.concurrent.ScheduledThreadPoolExecutor
  - execute
```
public void execute(java.lang.Runnable command)
```
    Specified by:
    
    execute ，界面 java.util.concurrent.Executor
    
    重写：
    
    execute in class java.util.concurrent.ScheduledThreadPoolExecutor

Class UnorderedThreadPoolEventExecutor

Nested Class Summary

Nested classes/interfaces inherited from class java.util.concurrent.ThreadPoolExecutor

构造方法摘要

方法摘要

Methods inherited from class java.util.concurrent.ScheduledThreadPoolExecutor

Methods inherited from class java.util.concurrent.ThreadPoolExecutor

Methods inherited from class java.util.concurrent.AbstractExecutorService

Methods inherited from class java.lang.Object

Methods inherited from interface java.util.concurrent.ExecutorService

Methods inherited from interface java.lang.Iterable

构造方法详细信息

UnorderedThreadPoolEventExecutor

UnorderedThreadPoolEventExecutor

UnorderedThreadPoolEventExecutor

UnorderedThreadPoolEventExecutor

方法详细信息

next

parent

inEventLoop

inEventLoop

newPromise

newProgressivePromise

newSucceededFuture

newFailedFuture

isShuttingDown

shutdownNow

shutdown

shutdownGracefully

shutdownGracefully

terminationFuture

iterator

decorateTask

decorateTask

schedule

schedule

scheduleAtFixedRate

scheduleWithFixedDelay

submit

submit

submit

execute