Package | Description |
---|---|
io.netty.bootstrap |
The helper classes with fluent API which enable an easy implementation of
typical client side and server side channel initialization.
|
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.embedded |
A virtual
Channel that helps wrapping a series of handlers to
unit test the handlers or use them in non-I/O context. |
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.channel.pool |
Implementations and API for
Channel pools. |
io.netty.handler.ssl |
SSL ·
TLS implementation based on
SSLEngine |
io.netty.handler.traffic |
Implementation of a Traffic Shaping Handler and Dynamic Statistics.
|
io.netty.util.concurrent |
Utility classes for concurrent / async tasks.
|
Modifier and Type | Field and Description |
---|---|
private EventExecutor |
AbstractBootstrap.PendingRegistrationPromise.executor |
Modifier and Type | Method and Description |
---|---|
protected EventExecutor |
AbstractBootstrap.PendingRegistrationPromise.executor() |
Modifier and Type | Interface and Description |
---|---|
interface |
EventLoop
Will handle all the I/O operations for a
Channel once registered. |
Modifier and Type | Class and Description |
---|---|
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. |
Modifier and Type | Field and Description |
---|---|
(package private) EventExecutor |
AbstractChannelHandlerContext.executor |
Modifier and Type | Field and Description |
---|---|
private java.util.Map<EventExecutorGroup,EventExecutor> |
DefaultChannelPipeline.childExecutors |
Modifier and Type | Method and Description |
---|---|
private EventExecutor |
DefaultChannelPipeline.childExecutor(EventExecutorGroup group) |
protected EventExecutor |
DefaultChannelProgressivePromise.executor() |
protected EventExecutor |
CompleteChannelFuture.executor() |
EventExecutor |
AbstractChannelHandlerContext.executor() |
protected EventExecutor |
DefaultChannelPromise.executor() |
EventExecutor |
CombinedChannelDuplexHandler.DelegatingChannelHandlerContext.executor() |
EventExecutor |
ChannelHandlerContext.executor()
The
EventExecutor that is used to dispatch the events. |
Modifier and Type | Method and Description |
---|---|
java.util.Iterator<EventExecutor> |
ThreadPerChannelEventLoopGroup.iterator() |
Modifier and Type | Method and Description |
---|---|
private static void |
AbstractChannelHandlerContext.safeExecute(EventExecutor executor,
java.lang.Runnable runnable,
ChannelPromise promise,
java.lang.Object msg) |
Constructor and Description |
---|
AbstractChannelHandlerContext(DefaultChannelPipeline pipeline,
EventExecutor executor,
java.lang.String name,
boolean inbound,
boolean outbound) |
CompleteChannelFuture(Channel channel,
EventExecutor executor)
Creates a new instance.
|
DefaultChannelHandlerContext(DefaultChannelPipeline pipeline,
EventExecutor executor,
java.lang.String name,
ChannelHandler handler) |
DefaultChannelProgressivePromise(Channel channel,
EventExecutor executor)
Creates a new instance.
|
DefaultChannelPromise(Channel channel,
EventExecutor executor)
Creates a new instance.
|
FailedChannelFuture(Channel channel,
EventExecutor executor,
java.lang.Throwable cause)
Creates a new instance.
|
SucceededChannelFuture(Channel channel,
EventExecutor executor)
Creates a new instance.
|
Modifier and Type | Class and Description |
---|---|
(package private) class |
EmbeddedEventLoop |
Modifier and Type | Class and Description |
---|---|
(package private) class |
EpollEventLoop
EventLoop which uses epoll under the covers. |
Modifier and Type | Method and Description |
---|---|
protected EventExecutor |
EpollEventLoopGroup.newChild(java.util.concurrent.ThreadFactory threadFactory,
java.lang.Object... args) |
Modifier and Type | Field and Description |
---|---|
private EventExecutor |
DefaultChannelGroup.executor |
Constructor and Description |
---|
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)
|
DefaultChannelGroupFuture(ChannelGroup group,
java.util.Collection<ChannelFuture> futures,
EventExecutor executor)
Creates a new instance.
|
DefaultChannelGroupFuture(ChannelGroup group,
java.util.Map<Channel,ChannelFuture> futures,
EventExecutor executor) |
Modifier and Type | Class and Description |
---|---|
(package private) class |
LocalEventLoop |
Modifier and Type | Method and Description |
---|---|
protected EventExecutor |
LocalEventLoopGroup.newChild(java.util.concurrent.ThreadFactory threadFactory,
java.lang.Object... args) |
Modifier and Type | Class and Description |
---|---|
class |
NioEventLoop
SingleThreadEventLoop implementation which register the Channel 's to a
Selector and so does the multi-plexing of these in the event loop. |
Modifier and Type | Method and Description |
---|---|
protected EventExecutor |
NioEventLoopGroup.newChild(java.util.concurrent.ThreadFactory threadFactory,
java.lang.Object... args) |
Modifier and Type | Field and Description |
---|---|
private EventExecutor |
FixedChannelPool.executor |
Modifier and Type | Method and Description |
---|---|
protected EventExecutor |
SslHandler.LazyChannelPromise.executor() |
Constructor and Description |
---|
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.
|
Modifier and Type | Interface and Description |
---|---|
interface |
OrderedEventExecutor
Marker interface for
EventExecutor s that will process all submitted tasks in an ordered / serial fashion. |
Modifier and Type | Class and Description |
---|---|
class |
AbstractEventExecutor
Abstract base class for
EventExecutor implementations. |
class |
AbstractScheduledEventExecutor
Abstract base class for
EventExecutor s that want to support scheduling. |
(package private) class |
DefaultEventExecutor
Default
SingleThreadEventExecutor implementation which just execute all submitted task in a
serial fashion |
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. |
Modifier and Type | Field and Description |
---|---|
private EventExecutor[] |
MultithreadEventExecutorGroup.children |
private EventExecutor |
DefaultPromise.executor |
private EventExecutor |
CompleteFuture.executor |
Modifier and Type | Field and Description |
---|---|
private java.util.Set<EventExecutor> |
AbstractEventExecutor.executorSet |
private java.util.Set<EventExecutor> |
UnorderedThreadPoolEventExecutor.executorSet |
Modifier and Type | Method and Description |
---|---|
protected EventExecutor |
DefaultPromise.executor()
Get the executor used to notify listeners when this promise is complete.
|
protected EventExecutor |
ScheduledFutureTask.executor() |
protected EventExecutor |
CompleteFuture.executor()
Return the
EventExecutor which is used by this CompleteFuture . |
protected EventExecutor |
DefaultEventExecutorGroup.newChild(java.util.concurrent.ThreadFactory threadFactory,
java.lang.Object... args) |
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. |
EventExecutor |
EventExecutor.next()
Returns a reference to itself.
|
EventExecutor |
EventExecutorGroup.next()
Returns one of the
EventExecutor s that belong to this group. |
EventExecutor |
AbstractEventExecutor.next() |
EventExecutor |
UnorderedThreadPoolEventExecutor.next() |
EventExecutor |
MultithreadEventExecutorGroup.next() |
EventExecutor |
MultithreadEventExecutorGroup.EventExecutorChooser.next() |
EventExecutor |
MultithreadEventExecutorGroup.PowerOfTwoEventExecutorChooser.next() |
EventExecutor |
MultithreadEventExecutorGroup.GenericEventExecutorChooser.next() |
Modifier and Type | Method and Description |
---|---|
protected java.util.Set<EventExecutor> |
MultithreadEventExecutorGroup.children()
Return a safe-copy of all of the children of this group.
|
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() |
java.util.Iterator<EventExecutor> |
UnorderedThreadPoolEventExecutor.iterator() |
java.util.Iterator<EventExecutor> |
MultithreadEventExecutorGroup.iterator() |
Modifier and Type | Method and Description |
---|---|
protected static void |
DefaultPromise.notifyListener(EventExecutor eventExecutor,
Future<?> future,
GenericFutureListener<?> listener)
Notify a listener that a future has completed.
|
private static void |
DefaultPromise.notifyListenerWithStackOverFlowProtection(EventExecutor executor,
Future<?> future,
GenericFutureListener<?> listener)
The logic in this method should be identical to
DefaultPromise.notifyListeners() but
cannot share code because the listener(s) cannot be cached for an instance of DefaultPromise since the
listener(s) may be changed and is protected by a synchronized operation. |
private static void |
DefaultPromise.safeExecute(EventExecutor executor,
java.lang.Runnable task) |
Constructor and Description |
---|
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.
|
ImmediateProgressivePromise(EventExecutor executor) |
ImmediatePromise(EventExecutor executor) |
PromiseTask(EventExecutor executor,
java.util.concurrent.Callable<V> callable) |
PromiseTask(EventExecutor executor,
java.lang.Runnable runnable,
V result) |
RunnableScheduledFutureTask(EventExecutor executor,
java.util.concurrent.Callable<V> callable,
java.util.concurrent.RunnableScheduledFuture<V> future) |
RunnableScheduledFutureTask(EventExecutor executor,
java.lang.Runnable runnable,
java.util.concurrent.RunnableScheduledFuture<V> future) |
SucceededFuture(EventExecutor executor,
V result)
Creates a new instance.
|