程序包 | 说明 |
---|---|
io.netty.channel |
The core channel API which is asynchronous and event-driven abstraction of
various transports such as a
NIO Channel.
|
io.netty.channel.epoll |
Optimized transport for linux which uses EPOLL Edge-Triggered Mode
for maximal performance.
|
io.netty.channel.group |
A channel registry which helps a user maintain the list of open
Channel s and perform bulk operations on them. |
io.netty.channel.local |
A virtual transport that enables the communication between the two
parties in the same virtual machine.
|
io.netty.channel.nio |
NIO-based channel
API implementation - recommended for a large number of connections (>= 1000).
|
io.netty.handler.traffic |
Implementation of a Traffic Shaping Handler and Dynamic Statistics.
|
io.netty.util.concurrent |
Utility classes for concurrent / async tasks.
|
限定符和类型 | 接口和说明 |
---|---|
interface |
EventLoop
Will handle all the I/O operations for a
Channel once registered. |
限定符和类型 | 类和说明 |
---|---|
class |
SingleThreadEventLoop
Abstract base class for
EventLoop 's that execute all its submitted tasks in a single thread. |
class |
ThreadPerChannelEventLoop
SingleThreadEventLoop which is used to handle OIO Channel 's. |
限定符和类型 | 方法和说明 |
---|---|
protected EventExecutor |
DefaultChannelPromise.executor() |
protected EventExecutor |
DefaultChannelProgressivePromise.executor() |
EventExecutor |
ChannelHandlerContext.executor()
The
EventExecutor that is used to dispatch the events. |
限定符和类型 | 方法和说明 |
---|---|
java.util.Iterator<EventExecutor> |
ThreadPerChannelEventLoopGroup.iterator() |
构造器和说明 |
---|
DefaultChannelProgressivePromise(Channel channel,
EventExecutor executor)
Creates a new instance.
|
DefaultChannelPromise(Channel channel,
EventExecutor executor)
Creates a new instance.
|
限定符和类型 | 方法和说明 |
---|---|
protected EventExecutor |
EpollEventLoopGroup.newChild(java.util.concurrent.ThreadFactory threadFactory,
java.lang.Object... args) |
构造器和说明 |
---|
DefaultChannelGroup(EventExecutor executor)
Creates a new group with a generated name and the provided
EventExecutor to notify the
ChannelGroupFuture s. |
DefaultChannelGroup(EventExecutor executor,
boolean stayClosed)
Creates a new group with a generated name and the provided
EventExecutor to notify the
ChannelGroupFuture s. |
DefaultChannelGroup(java.lang.String name,
EventExecutor executor)
|
DefaultChannelGroup(java.lang.String name,
EventExecutor executor,
boolean stayClosed)
|
限定符和类型 | 方法和说明 |
---|---|
protected EventExecutor |
LocalEventLoopGroup.newChild(java.util.concurrent.ThreadFactory threadFactory,
java.lang.Object... args) |
限定符和类型 | 类和说明 |
---|---|
class |
NioEventLoop
SingleThreadEventLoop implementation which register the Channel 's to a
Selector and so does the multi-plexing of these in the event loop. |
限定符和类型 | 方法和说明 |
---|---|
protected EventExecutor |
NioEventLoopGroup.newChild(java.util.concurrent.ThreadFactory threadFactory,
java.lang.Object... args) |
构造器和说明 |
---|
GlobalTrafficShapingHandler(EventExecutor executor)
Create a new instance using default Check Interval value of 1000 ms and
default max time as delay allowed value of 15000 ms and no limit.
|
限定符和类型 | 接口和说明 |
---|---|
interface |
OrderedEventExecutor
Marker interface for
EventExecutor s that will process all submitted tasks in an ordered / serial fashion. |
限定符和类型 | 类和说明 |
---|---|
class |
AbstractEventExecutor
Abstract base class for
EventExecutor implementations. |
class |
AbstractScheduledEventExecutor
Abstract base class for
EventExecutor s that want to support scheduling. |
class |
GlobalEventExecutor
Single-thread singleton
EventExecutor . |
class |
ImmediateEventExecutor
Executes
Runnable objects in the caller's thread. |
class |
SingleThreadEventExecutor
Abstract base class for
OrderedEventExecutor 's that execute all its submitted tasks in a single thread. |
class |
UnorderedThreadPoolEventExecutor
EventExecutor implementation which makes no guarantees about the ordering of task execution that
are submitted because there may be multiple threads executing these tasks. |
限定符和类型 | 方法和说明 |
---|---|
protected EventExecutor |
DefaultPromise.executor()
Get the executor used to notify listeners when this promise is complete.
|
protected EventExecutor |
CompleteFuture.executor()
Return the
EventExecutor which is used by this CompleteFuture . |
protected abstract EventExecutor |
MultithreadEventExecutorGroup.newChild(java.util.concurrent.ThreadFactory threadFactory,
java.lang.Object... args)
Create a new EventExecutor which will later then accessible via the
MultithreadEventExecutorGroup.next() method. |
protected EventExecutor |
DefaultEventExecutorGroup.newChild(java.util.concurrent.ThreadFactory threadFactory,
java.lang.Object... args) |
EventExecutor |
UnorderedThreadPoolEventExecutor.next() |
EventExecutor |
MultithreadEventExecutorGroup.next() |
EventExecutor |
EventExecutorGroup.next()
Returns one of the
EventExecutor s that belong to this group. |
EventExecutor |
EventExecutor.next()
Returns a reference to itself.
|
EventExecutor |
AbstractEventExecutor.next() |
限定符和类型 | 方法和说明 |
---|---|
protected java.util.Set<EventExecutor> |
MultithreadEventExecutorGroup.children()
Return a safe-copy of all of the children of this group.
|
java.util.Iterator<EventExecutor> |
UnorderedThreadPoolEventExecutor.iterator() |
java.util.Iterator<EventExecutor> |
MultithreadEventExecutorGroup.iterator() |
java.util.Iterator<EventExecutor> |
EventExecutorGroup.iterator()
Returns a read-only
Iterator over all EventExecutor , which are handled by this
EventExecutorGroup at the time of invoke this method. |
java.util.Iterator<EventExecutor> |
AbstractEventExecutor.iterator() |
限定符和类型 | 方法和说明 |
---|---|
protected static void |
DefaultPromise.notifyListener(EventExecutor eventExecutor,
Future<?> future,
GenericFutureListener<?> listener)
Notify a listener that a future has completed.
|
构造器和说明 |
---|
CompleteFuture(EventExecutor executor)
Creates a new instance.
|
DefaultProgressivePromise(EventExecutor executor)
Creates a new instance.
|
DefaultPromise(EventExecutor executor)
Creates a new instance.
|
FailedFuture(EventExecutor executor,
java.lang.Throwable cause)
Creates a new instance.
|
SucceededFuture(EventExecutor executor,
V result)
Creates a new instance.
|