Package | Description |
---|---|
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.group |
A channel registry which helps a user maintain the list of open
Channel s and perform bulk operations on them. |
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.resolver |
Resolves an arbitrary string that represents the name of an endpoint into a
SocketAddress . |
io.netty.resolver.dns |
An alternative to Java's built-in domain name lookup mechanism that resolves a domain name asynchronously,
which supports the queries of an arbitrary DNS record type as well.
|
io.netty.util.concurrent |
Utility classes for concurrent / async tasks.
|
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 |
AbstractEventLoop
Skeletal implementation of
EventLoop . |
class |
DefaultEventLoop |
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 | Method and Description |
---|---|
<E extends EventExecutor> |
ThreadPerChannelEventLoopGroup.children() |
Modifier and Type | Method and Description |
---|---|
EventExecutor |
ChannelHandlerInvoker.executor()
Returns the
EventExecutor which is used to execute an arbitrary task. |
protected EventExecutor |
DefaultChannelProgressivePromise.executor() |
EventExecutor |
ChannelHandlerContext.executor()
Returns the
EventExecutor which is used to execute an arbitrary task. |
protected EventExecutor |
DefaultChannelPromise.executor() |
EventExecutor |
DefaultChannelHandlerInvoker.executor() |
Constructor and Description |
---|
DefaultChannelHandlerInvoker(EventExecutor executor) |
DefaultChannelProgressivePromise(Channel channel,
EventExecutor executor)
Creates a new instance.
|
DefaultChannelPromise(Channel channel,
EventExecutor executor)
Creates a new instance.
|
Constructor and Description |
---|
DefaultChannelGroup(EventExecutor executor)
Creates a new group with a generated name and the provided
EventExecutor to notify the
ChannelGroupFuture s. |
DefaultChannelGroup(String name,
EventExecutor executor)
|
Modifier and Type | Class and Description |
---|---|
class |
NioEventLoop
A
SingleThreadEventLoop implementation which registers each Channel with a
NIO Selector and performs the multiplexing of these in the event loop. |
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 | Method and Description |
---|---|
protected EventExecutor |
SimpleNameResolver.executor()
Returns the
EventExecutor which is used to notify the listeners of the Future returned
by SimpleNameResolver.resolve(SocketAddress) . |
Modifier and Type | Method and Description |
---|---|
NameResolver<T> |
NameResolverGroup.getResolver(EventExecutor executor)
Returns the
NameResolver associated with the specified EventExecutor . |
protected abstract NameResolver<T> |
NameResolverGroup.newResolver(EventExecutor executor)
Invoked by
NameResolverGroup.getResolver(EventExecutor) to create a new NameResolver . |
protected NameResolver<InetSocketAddress> |
DefaultNameResolverGroup.newResolver(EventExecutor executor) |
protected NameResolver<SocketAddress> |
NoopNameResolverGroup.newResolver(EventExecutor executor) |
Constructor and Description |
---|
DefaultNameResolver(EventExecutor executor) |
NoopNameResolver(EventExecutor executor) |
SimpleNameResolver(EventExecutor executor) |
SimpleNameResolver(EventExecutor executor,
Class<? extends T> addressType) |
Modifier and Type | Method and Description |
---|---|
protected NameResolver<InetSocketAddress> |
DnsNameResolverGroup.newResolver(EventExecutor executor) |
Modifier and Type | Interface and Description |
---|---|
interface |
PausableEventExecutor
Implement this interface if you need your
EventExecutor implementation to be able
to reject new work. |
interface |
WrappedEventExecutor
A marker interface indicating that the
EventExecutor is a wrapper around
another EventExecutor implementation. |
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. |
class |
DefaultEventExecutor
Default
SingleThreadEventExecutor implementation which just execute all submitted task in a
serial fashion. |
class |
GlobalEventExecutor
Single-thread singleton
EventExecutor . |
class |
ImmediateEventExecutor
AbstractEventExecutor which execute tasks in the callers thread. |
class |
SingleThreadEventExecutor
Abstract base class for
EventExecutor 's that execute all its submitted tasks in a single thread. |
Modifier and Type | Method and Description |
---|---|
<E extends EventExecutor> |
EventExecutor.children()
Returns an unmodifiable singleton set which contains itself.
|
<E extends EventExecutor> |
MultithreadEventExecutorGroup.children() |
<E extends EventExecutor> |
AbstractEventExecutor.children() |
<E extends EventExecutor> |
EventExecutorGroup.children()
Returns the unmodifiable set of
EventExecutor s managed by this EventExecutorGroup . |
Modifier and Type | Method and Description |
---|---|
protected EventExecutor |
CompleteFuture.executor()
Return the
EventExecutor which is used by this CompleteFuture . |
protected EventExecutor |
DefaultPromise.executor() |
protected EventExecutor |
DefaultEventExecutorGroup.newChild(Executor executor,
Object... args) |
protected abstract EventExecutor |
MultithreadEventExecutorGroup.newChild(Executor executor,
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 |
MultithreadEventExecutorGroup.next() |
EventExecutor |
AbstractEventExecutor.next() |
EventExecutor |
EventExecutorGroup.next()
Returns one of the
EventExecutor s managed by this EventExecutorGroup . |
EventExecutor |
EventExecutor.unwrap()
Returns an
EventExecutor that is not a WrappedEventExecutor . |
EventExecutor |
AbstractEventExecutor.unwrap() |
Modifier and Type | Method and Description |
---|---|
protected static void |
DefaultPromise.notifyListener(EventExecutor eventExecutor,
Future<?> future,
GenericFutureListener<?> l) |
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,
Throwable cause)
Creates a new instance.
|
SucceededFuture(EventExecutor executor,
V result)
Creates a new instance.
|
Copyright © 2008–2015 The Netty Project. All rights reserved.