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, submitprotected 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.