public abstract class MultithreadEventExecutorGroup extends AbstractEventExecutorGroup
EventExecutorGroup
实现的抽象基类, 它们同时处理具有多个线程的任务。
Modifier | Constructor and Description |
---|---|
protected |
MultithreadEventExecutorGroup(int nThreads, java.util.concurrent.Executor executor, EventExecutorChooserFactory chooserFactory, java.lang.Object... args)
创建一个新的实例。
|
protected |
MultithreadEventExecutorGroup(int nThreads, java.util.concurrent.Executor executor, java.lang.Object... args)
创建一个新的实例。
|
protected |
MultithreadEventExecutorGroup(int nThreads, java.util.concurrent.ThreadFactory threadFactory, java.lang.Object... args)
创建一个新的实例。
|
Modifier and Type | Method and Description |
---|---|
boolean |
awaitTermination(long timeout, java.util.concurrent.TimeUnit unit) |
int |
executorCount()
返回此实现使用的数量 EventExecutor 。
|
boolean |
isShutdown() |
boolean |
isShuttingDown()
返回 true 当且仅当所有EventExecutor 由该被管小号EventExecutorGroup 正在shut down gracefully或者被关闭。
|
boolean |
isTerminated() |
java.util.Iterator<EventExecutor> |
iterator() |
protected abstract EventExecutor |
newChild(java.util.concurrent.Executor executor, java.lang.Object... args)
创建一个新的EventExecutor,然后通过
next() 方法访问。
|
protected java.util.concurrent.ThreadFactory |
newDefaultThreadFactory() |
EventExecutor |
next()
|
void |
shutdown()
已过时。
|
Future<?> |
shutdownGracefully(long quietPeriod, long timeout, java.util.concurrent.TimeUnit unit)
该执行者表示该调用者希望执行者被关闭。
|
Future<?> |
terminationFuture()
返回 Future ,当由EventExecutorGroup 管理的所有EventExecutor 都已终止时,会通知该Future 。
|
execute, invokeAll, invokeAll, invokeAny, invokeAny, schedule, schedule, scheduleAtFixedRate, scheduleWithFixedDelay, shutdownGracefully, shutdownNow, submit, submit, submit
protected MultithreadEventExecutorGroup(int nThreads, java.util.concurrent.ThreadFactory threadFactory, java.lang.Object... args)
nThreads
- 此实例将使用的线程数。
threadFactory
- 要使用的ThreadFactory,或
null
如果应使用默认值)。
args
- 将传递给每个
newChild(Executor, Object...)
调用的参数
protected MultithreadEventExecutorGroup(int nThreads, java.util.concurrent.Executor executor, java.lang.Object... args)
nThreads
- 此实例将使用的线程数。
executor
- 要使用的执行程序,或
null
如果应使用默认值)。
args
- 将传递给每个
newChild(Executor, Object...)
呼叫的参数
protected MultithreadEventExecutorGroup(int nThreads, java.util.concurrent.Executor executor, EventExecutorChooserFactory chooserFactory, java.lang.Object... args)
nThreads
- 此实例将使用的线程数。
executor
- 要使用的执行程序,或者
null
如果应该使用默认值)。
chooserFactory
- 使用EventExecutorChooserFactory
。
args
- 将传递给每个
newChild(Executor, Object...)
调用的参数
protected java.util.concurrent.ThreadFactory newDefaultThreadFactory()
public EventExecutor next()
EventExecutorGroup
复制的描述
public java.util.Iterator<EventExecutor> iterator()
public final int executorCount()
EventExecutor
。
这个数字是地图1:1到它使用的线程。
protected abstract EventExecutor newChild(java.util.concurrent.Executor executor, java.lang.Object... args) throws java.lang.Exception
next()
方法访问。
这个方法将被用于每个会服务于这个MultithreadEventExecutorGroup
的线程。
java.lang.Exception
public Future<?> shutdownGracefully(long quietPeriod, long timeout, java.util.concurrent.TimeUnit unit)
EventExecutorGroup
EventExecutorGroup.isShuttingDown()
开始返回true
,执行程序准备自行关闭。
与EventExecutorGroup.shutdown()
不同的是 ,优雅关机确保在关闭之前没有任何任务被提交'安静期' (通常是几秒钟)。
如果任务在安静期提交,则保证被接受,安静期将重新开始。
quietPeriod
- 文档中描述的安静期
timeout
- 无论任务是否在安静期间提交,等待执行程序为
EventExecutorGroup.shutdown()的最长时间
unit
- 单位
quietPeriod
和
timeout
EventExecutorGroup.terminationFuture()
public Future<?> terminationFuture()
EventExecutorGroup
Future
,当由此EventExecutorGroup
管理的所有EventExecutor
已终止时将通知该Future
。
@Deprecated public void shutdown()
shutdown
接口
EventExecutorGroup
shutdown
,界面
java.util.concurrent.ExecutorService
shutdown
在课程
AbstractEventExecutorGroup
public boolean isShuttingDown()
EventExecutorGroup
true
当且仅当所有EventExecutor
由该被管小号EventExecutorGroup
正在shut down gracefully或者被关闭。
public boolean isShutdown()
public boolean isTerminated()
public boolean awaitTermination(long timeout, java.util.concurrent.TimeUnit unit) throws java.lang.InterruptedException
java.lang.InterruptedException
Copyright © 2008–2018 The Netty Project. All rights reserved.