public class ThreadPerChannelEventLoopGroup extends AbstractEventExecutorGroup implements EventLoopGroup
EventLoopGroup
创建一个EventLoop
每Channel
。
Modifier | Constructor and Description |
---|---|
protected |
ThreadPerChannelEventLoopGroup()
创建一个没有限制的新的 ThreadPerChannelEventLoopGroup 。
|
protected |
ThreadPerChannelEventLoopGroup(int maxChannels)
创建一个新的 ThreadPerChannelEventLoopGroup 。
|
protected |
ThreadPerChannelEventLoopGroup(int maxChannels, java.util.concurrent.Executor executor, java.lang.Object... args)
创建一个新的 ThreadPerChannelEventLoopGroup 。
|
protected |
ThreadPerChannelEventLoopGroup(int maxChannels, java.util.concurrent.ThreadFactory threadFactory, java.lang.Object... args)
创建一个新的 ThreadPerChannelEventLoopGroup 。
|
Modifier and Type | Method and Description |
---|---|
boolean |
awaitTermination(long timeout, java.util.concurrent.TimeUnit unit) |
boolean |
isShutdown() |
boolean |
isShuttingDown()
当且仅当由此 EventExecutorGroup 管理的所有EventExecutor 都是shut down gracefully或被关闭时才返回true 。
|
boolean |
isTerminated() |
java.util.Iterator<EventExecutor> |
iterator() |
protected EventLoop |
newChild(java.lang.Object... args)
创建一个新的 EventLoop 。
|
EventLoop |
next()
返回下一个 EventLoop 以供使用
|
ChannelFuture |
register(Channel channel)
|
ChannelFuture |
register(Channel channel, ChannelPromise promise)
已过时。
|
ChannelFuture |
register(ChannelPromise promise)
使用 ChannelFuture 通过此EventLoop 注册一个Channel 。
|
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
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
schedule, schedule, scheduleAtFixedRate, scheduleWithFixedDelay, shutdownGracefully, shutdownNow, submit, submit, submit
protected ThreadPerChannelEventLoopGroup()
ThreadPerChannelEventLoopGroup
。
protected ThreadPerChannelEventLoopGroup(int maxChannels)
ThreadPerChannelEventLoopGroup
。
maxChannels
- 此实例处理的最大通道数。
一旦你尝试注册一个新的Channel
,最大值超过它将会抛出一个ChannelException
。
在register(Channel)
和register(ChannelPromise)
方法上。
使用0
不限制
protected ThreadPerChannelEventLoopGroup(int maxChannels, java.util.concurrent.ThreadFactory threadFactory, java.lang.Object... args)
ThreadPerChannelEventLoopGroup
。
maxChannels
- 此实例处理的最大通道数。
一旦你尝试注册一个新Channel
,最高为超过它会抛出一个ChannelException
对register(Channel)
和register(ChannelPromise)
方法。
使用0
不限制
threadFactory
- ThreadFactory
用于创建处理注册的Channel
的新的Thread
实例
args
- 将传递给每个
newChild(Object...)
调用的参数。
protected ThreadPerChannelEventLoopGroup(int maxChannels, java.util.concurrent.Executor executor, java.lang.Object... args)
ThreadPerChannelEventLoopGroup
。
maxChannels
- 此实例处理的最大通道数。
一旦你尝试注册一个新的Channel
,并且最大值超过,它将在register(Channel)
和register(ChannelPromise)
方法上抛出一个ChannelException
。
使用0
不限制
executor
- Executor
用于创建处理注册的Channel
的新的Thread
实例
args
- 将传递给每个
newChild(Object...)
调用的参数。
protected EventLoop newChild(java.lang.Object... args) throws java.lang.Exception
EventLoop
。
默认实现将创建一个新的ThreadPerChannelEventLoop
。
java.lang.Exception
public java.util.Iterator<EventExecutor> iterator()
iterator
在界面
EventExecutorGroup
iterator
,界面
java.lang.Iterable<EventExecutor>
public EventLoop next()
EventLoopGroup
EventLoop
以供使用
next
在界面
EventLoopGroup
next
在界面
EventExecutorGroup
public Future<?> shutdownGracefully(long quietPeriod, long timeout, java.util.concurrent.TimeUnit unit)
EventExecutorGroup
复制的描述
EventExecutorGroup.isShuttingDown()
开始返回true
,执行程序准备自行关闭。
与EventExecutorGroup.shutdown()
不同的是 ,正常关机可确保在关闭之前不会提交“安静期” (通常是几秒钟)的任务。
如果任务在安静期提交,则保证被接受,安静期将重新开始。
shutdownGracefully
在界面
EventExecutorGroup
quietPeriod
- 文档中描述的安静期
timeout
- 无论任务是否在安静期间提交,等待执行程序为
EventExecutorGroup.shutdown()的最长时间
unit
-
quietPeriod
和
timeout
的单位
EventExecutorGroup.terminationFuture()
public Future<?> terminationFuture()
EventExecutorGroup
复制的描述
Future
,当由此EventExecutorGroup
管理的所有EventExecutor
已终止时将通知该Future
。
terminationFuture
在界面
EventExecutorGroup
@Deprecated public void shutdown()
shutdown
,界面
EventExecutorGroup
shutdown
在界面
java.util.concurrent.ExecutorService
shutdown
在课堂上
AbstractEventExecutorGroup
public boolean isShuttingDown()
EventExecutorGroup
复制的描述
true
当且仅当所有EventExecutor
由该被管小号EventExecutorGroup
正在shut down gracefully或者被关闭。
isShuttingDown
接口
EventExecutorGroup
public boolean isShutdown()
isShutdown
在界面
java.util.concurrent.ExecutorService
public boolean isTerminated()
isTerminated
在界面
java.util.concurrent.ExecutorService
public boolean awaitTermination(long timeout, java.util.concurrent.TimeUnit unit) throws java.lang.InterruptedException
awaitTermination
,界面
java.util.concurrent.ExecutorService
java.lang.InterruptedException
public ChannelFuture register(Channel channel)
EventLoopGroup
Channel
这个EventLoop
。
一旦注册完成,返回的ChannelFuture
将会收到通知。
register
,界面
EventLoopGroup
public ChannelFuture register(ChannelPromise promise)
EventLoopGroup
复制的描述
ChannelFuture
通过此EventLoop
注册Channel
。
一旦注册完成,通过的ChannelFuture
将会收到通知,并且会被退回。
register
在界面
EventLoopGroup
@Deprecated public ChannelFuture register(Channel channel, ChannelPromise promise)
EventLoopGroup
Channel
这个EventLoop
。
一旦注册完成,通过的ChannelFuture
将会收到通知,并且会返回。
register
在界面
EventLoopGroup
Copyright © 2008–2018 The Netty Project. All rights reserved.