软件包 | 描述 |
---|---|
io.netty.channel |
核心通道API是异步和事件驱动的各种传输(如
NIO Channel)的抽象 。
|
io.netty.channel.group |
通道注册表,帮助用户维护打开的 Channel 列表并对其执行批量操作。
|
io.netty.channel.nio |
基于
NIO的通道API实现 - 推荐用于大量连接(> = 1000)。
|
io.netty.handler.traffic |
流量整形处理器和动态统计的实现。
|
io.netty.resolver |
将表示端点名称的任意字符串解析为地址。
|
io.netty.resolver.dns |
Java的内置域名查找机制的一种替代方法,可以异步解析域名,同样支持任意DNS记录类型的查询。
|
io.netty.util.concurrent |
并发/异步任务的实用程序类。
|
Modifier and Type | Interface and Description |
---|---|
interface |
EventLoop
一旦注册,将处理 Channel 的所有I / O操作。
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractEventLoop
骨架实现 EventLoop 。
|
class |
DefaultEventLoop |
class |
SingleThreadEventLoop
抽象基类,用于在单个线程中执行其所有提交的任务的 EventLoop 。
|
class |
ThreadPerChannelEventLoop
|
Modifier and Type | Method and Description |
---|---|
protected EventExecutor |
DefaultChannelPromise.executor() |
protected EventExecutor |
DefaultChannelProgressivePromise.executor() |
EventExecutor |
ChannelHandlerContext.executor()
返回用于执行任意任务的 EventExecutor 。
|
Modifier and Type | Method and Description |
---|---|
java.util.Iterator<EventExecutor> |
ThreadPerChannelEventLoopGroup.iterator() |
Constructor and Description |
---|
DefaultChannelProgressivePromise(Channel channel, EventExecutor executor)
创建一个新的实例。
|
DefaultChannelPromise(Channel channel, EventExecutor executor)
创建一个新的实例。
|
Constructor and Description |
---|
DefaultChannelGroup(EventExecutor executor)
使用生成的名称创建一个新组,并提供 EventExecutor 以通知ChannelGroupFuture 。
|
DefaultChannelGroup(EventExecutor executor, boolean stayClosed)
使用生成的名称创建一个新组,并提供 EventExecutor 以通知ChannelGroupFuture 。
|
DefaultChannelGroup(java.lang.String name, EventExecutor executor)
用指定的 name 和EventExecutor 创建一个新组,以通知ChannelGroupFuture 。
|
DefaultChannelGroup(java.lang.String name, EventExecutor executor, boolean stayClosed)
用指定的 name 和EventExecutor 创建一个新组以通知ChannelGroupFuture 。
|
Modifier and Type | Class and Description |
---|---|
class |
NioEventLoop
SingleThreadEventLoop 实现注册Channel 的Selector ,这些事件循环中的多重复合。
|
Constructor and Description |
---|
GlobalTrafficShapingHandler(EventExecutor executor)
使用默认的“检查时间间隔”值1000毫秒和默认最大时间作为延迟允许值15000毫秒并且没有限制来创建一个新实例。
|
Modifier and Type | Method and Description |
---|---|
protected EventExecutor |
SimpleNameResolver.executor()
|
protected EventExecutor |
AbstractAddressResolver.executor()
|
Modifier and Type | Method and Description |
---|---|
AddressResolver<T> |
AddressResolverGroup.getResolver(EventExecutor executor)
返回与指定的 EventExecutor 关联的AddressResolver 。
|
protected AddressResolver<java.net.SocketAddress> |
NoopAddressResolverGroup.newResolver(EventExecutor executor) |
protected AddressResolver<java.net.InetSocketAddress> |
DefaultAddressResolverGroup.newResolver(EventExecutor executor) |
protected abstract AddressResolver<T> |
AddressResolverGroup.newResolver(EventExecutor executor)
|
Constructor and Description |
---|
AbstractAddressResolver(EventExecutor executor) |
AbstractAddressResolver(EventExecutor executor, java.lang.Class<? extends T> addressType) |
CompositeNameResolver(EventExecutor executor, NameResolver<T>... resolvers) |
DefaultNameResolver(EventExecutor executor) |
InetNameResolver(EventExecutor executor) |
InetSocketAddressResolver(EventExecutor executor, NameResolver<java.net.InetAddress> nameResolver) |
NoopAddressResolver(EventExecutor executor) |
RoundRobinInetAddressResolver(EventExecutor executor, NameResolver<java.net.InetAddress> nameResolver) |
SimpleNameResolver(EventExecutor executor) |
Modifier and Type | Method and Description |
---|---|
protected AddressResolver<java.net.InetSocketAddress> |
DnsAddressResolverGroup.newResolver(EventExecutor executor) |
Modifier and Type | Interface and Description |
---|---|
interface |
OrderedEventExecutor
用于 EventExecutor 的标记接口,用于以有序/串行方式处理所有提交的任务。
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractEventExecutor
EventExecutor 实现的抽象基类。
|
class |
AbstractScheduledEventExecutor
希望支持调度的抽象基类 EventExecutor 。
|
class |
DefaultEventExecutor
默认 SingleThreadEventExecutor 实现, 它只是以串行方式执行所有提交的任务。
|
class |
GlobalEventExecutor
单线程单身人士 EventExecutor 。
|
class |
ImmediateEventExecutor
在调用者的线程中执行
Runnable 对象。
|
class |
SingleThreadEventExecutor
OrderedEventExecutor 的抽象基类,它在单个线程中执行所有提交的任务。
|
class |
UnorderedThreadPoolEventExecutor
EventExecutor 实现,因为可能有多个线程正在执行这些任务,所以不能保证提交的任务执行的顺序。
|
Modifier and Type | Method and Description |
---|---|
protected EventExecutor |
DefaultPromise.executor()
当这个承诺完成时,让执行者用来通知监听者。
|
protected EventExecutor |
CompleteFuture.executor()
返回 CompleteFuture 使用的EventExecutor 。
|
protected abstract EventExecutor |
MultithreadEventExecutorGroup.newChild(java.util.concurrent.Executor executor, java.lang.Object... args)
创建一个新的EventExecutor,然后通过
MultithreadEventExecutorGroup.next() 方法访问。
|
protected EventExecutor |
DefaultEventExecutorGroup.newChild(java.util.concurrent.Executor executor, java.lang.Object... args) |
EventExecutor |
UnorderedThreadPoolEventExecutor.next() |
EventExecutor |
NonStickyEventExecutorGroup.next() |
EventExecutor |
MultithreadEventExecutorGroup.next() |
EventExecutor |
EventExecutorGroup.next()
|
EventExecutor |
EventExecutorChooserFactory.EventExecutorChooser.next()
返回要使用的新的 EventExecutor 。
|
EventExecutor |
EventExecutor.next()
返回对自身的引用。
|
EventExecutor |
AbstractEventExecutor.next() |
Modifier and Type | Method and Description |
---|---|
java.util.Iterator<EventExecutor> |
UnorderedThreadPoolEventExecutor.iterator() |
java.util.Iterator<EventExecutor> |
NonStickyEventExecutorGroup.iterator() |
java.util.Iterator<EventExecutor> |
MultithreadEventExecutorGroup.iterator() |
java.util.Iterator<EventExecutor> |
EventExecutorGroup.iterator() |
java.util.Iterator<EventExecutor> |
AbstractEventExecutor.iterator() |
Modifier and Type | Method and Description |
---|---|
EventExecutorChooserFactory.EventExecutorChooser |
EventExecutorChooserFactory.newChooser(EventExecutor[] executors)
|
EventExecutorChooserFactory.EventExecutorChooser |
DefaultEventExecutorChooserFactory.newChooser(EventExecutor[] executors) |
protected static void |
DefaultPromise.notifyListener(EventExecutor eventExecutor, Future<?> future, GenericFutureListener<?> listener)
通知听众未来已完成。
|
Constructor and Description |
---|
CompleteFuture(EventExecutor executor)
创建一个新的实例。
|
DefaultProgressivePromise(EventExecutor executor)
创建一个新的实例。
|
DefaultPromise(EventExecutor executor)
创建一个新的实例。
|
FailedFuture(EventExecutor executor, java.lang.Throwable cause)
创建一个新的实例。
|
SucceededFuture(EventExecutor executor, V result)
创建一个新的实例。
|
Copyright © 2008–2018 The Netty Project. All rights reserved.