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.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.channel.pool |
Implementations and API for
Channel pools. |
io.netty.handler.codec.http2 |
Handlers for sending and receiving HTTP/2 frames.
|
io.netty.handler.proxy |
Adds support for client connections via proxy protocols such as
SOCKS and
HTTP CONNECT tunneling
|
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.resolver |
Resolves an arbitrary string that represents the name of an endpoint into an address.
|
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 | 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 |
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 | 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) |
EventExecutor |
ChannelHandlerContext.executor()
Returns the
EventExecutor which is used to execute an arbitrary task. |
EventExecutor |
CombinedChannelDuplexHandler.DelegatingChannelHandlerContext.executor() |
EventExecutor |
AbstractChannelHandlerContext.executor() |
protected EventExecutor |
CompleteChannelFuture.executor() |
protected EventExecutor |
DefaultChannelProgressivePromise.executor() |
protected EventExecutor |
DefaultChannelPromise.executor() |
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 | 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 |
---|---|
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 | Field and Description |
---|---|
private EventExecutor |
FixedChannelPool.executor |
Modifier and Type | Method and Description |
---|---|
protected abstract EventExecutor |
AbstractHttp2StreamChannel.preferredEventExecutor()
The ideal thread for events like
AbstractHttp2StreamChannel.doWrite(ChannelOutboundBuffer) to be processed on. |
protected EventExecutor |
Http2MultiplexCodec.Http2StreamChannel.preferredEventExecutor() |
Constructor and Description |
---|
SimpleChannelPromiseAggregator(ChannelPromise promise,
Channel c,
EventExecutor e) |
Modifier and Type | Method and Description |
---|---|
protected EventExecutor |
ProxyHandler.LazyChannelPromise.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 | Field and Description |
---|---|
private EventExecutor |
AbstractAddressResolver.executor |
private EventExecutor |
SimpleNameResolver.executor |
Modifier and Type | Field and Description |
---|---|
private java.util.Map<EventExecutor,AddressResolver<T>> |
AddressResolverGroup.resolvers
Note that we do not use a
ConcurrentMap here because it is usually expensive to instantiate a resolver. |
Modifier and Type | Method and Description |
---|---|
protected EventExecutor |
AbstractAddressResolver.executor()
Returns the
EventExecutor which is used to notify the listeners of the Future returned
by AbstractAddressResolver.resolve(SocketAddress) . |
protected EventExecutor |
SimpleNameResolver.executor()
Returns the
EventExecutor which is used to notify the listeners of the Future returned
by SimpleNameResolver.resolve(String) . |
Modifier and Type | Method and Description |
---|---|
AddressResolver<T> |
AddressResolverGroup.getResolver(EventExecutor executor)
Returns the
AddressResolver associated with the specified EventExecutor . |
protected AddressResolver<java.net.InetSocketAddress> |
DefaultAddressResolverGroup.newResolver(EventExecutor executor) |
protected abstract AddressResolver<T> |
AddressResolverGroup.newResolver(EventExecutor executor)
Invoked by
AddressResolverGroup.getResolver(EventExecutor) to create a new AddressResolver . |
protected AddressResolver<java.net.SocketAddress> |
NoopAddressResolverGroup.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 | Field and Description |
---|---|
private EventExecutor |
InflightNameResolver.executor |
Modifier and Type | Method and Description |
---|---|
protected AddressResolver<java.net.InetSocketAddress> |
DnsAddressResolverGroup.newResolver(EventExecutor executor) |
Constructor and Description |
---|
InflightNameResolver(EventExecutor executor,
NameResolver<T> delegate,
java.util.concurrent.ConcurrentMap<java.lang.String,Promise<T>> resolvesInProgress,
java.util.concurrent.ConcurrentMap<java.lang.String,Promise<java.util.List<T>>> resolveAllsInProgress) |
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. |
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. |
private static class |
NonStickyEventExecutorGroup.NonStickyOrderedEventExecutor |
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 |
private EventExecutor |
NonStickyEventExecutorGroup.NonStickyOrderedEventExecutor.executor |
private EventExecutor[] |
DefaultEventExecutorChooserFactory.PowerOfTwoEventExecutorChooser.executors |
private EventExecutor[] |
DefaultEventExecutorChooserFactory.GenericEventExecutorChooser.executors |
Modifier and Type | Field and Description |
---|---|
private java.util.Set<EventExecutor> |
UnorderedThreadPoolEventExecutor.executorSet |
private java.util.Set<EventExecutor> |
MultithreadEventExecutorGroup.readonlyChildren |
private java.util.Collection<EventExecutor> |
AbstractEventExecutor.selfCollection |
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 abstract EventExecutor |
MultithreadEventExecutorGroup.newChild(java.util.concurrent.Executor executor,
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.Executor executor,
java.lang.Object... args) |
EventExecutor |
DefaultEventExecutorChooserFactory.PowerOfTwoEventExecutorChooser.next() |
EventExecutor |
DefaultEventExecutorChooserFactory.GenericEventExecutorChooser.next() |
EventExecutor |
AbstractEventExecutor.next() |
EventExecutor |
EventExecutor.next()
Returns a reference to itself.
|
EventExecutor |
EventExecutorChooserFactory.EventExecutorChooser.next()
Returns the new
EventExecutor to use. |
EventExecutor |
EventExecutorGroup.next()
Returns one of the
EventExecutor s managed by this EventExecutorGroup . |
EventExecutor |
UnorderedThreadPoolEventExecutor.next() |
EventExecutor |
MultithreadEventExecutorGroup.next() |
EventExecutor |
NonStickyEventExecutorGroup.next() |
Modifier and Type | Method and Description |
---|---|
java.util.Iterator<EventExecutor> |
AbstractEventExecutor.iterator() |
java.util.Iterator<EventExecutor> |
EventExecutorGroup.iterator() |
java.util.Iterator<EventExecutor> |
UnorderedThreadPoolEventExecutor.iterator() |
java.util.Iterator<EventExecutor> |
MultithreadEventExecutorGroup.iterator() |
java.util.Iterator<EventExecutor> |
NonStickyEventExecutorGroup.iterator() |
Modifier and Type | Method and Description |
---|---|
EventExecutorChooserFactory.EventExecutorChooser |
DefaultEventExecutorChooserFactory.newChooser(EventExecutor[] executors) |
EventExecutorChooserFactory.EventExecutorChooser |
EventExecutorChooserFactory.newChooser(EventExecutor[] executors)
Returns a new
EventExecutorChooserFactory.EventExecutorChooser . |
private NonStickyEventExecutorGroup.NonStickyOrderedEventExecutor |
NonStickyEventExecutorGroup.newExecutor(EventExecutor executor) |
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.
|
GenericEventExecutorChooser(EventExecutor[] executors) |
ImmediateProgressivePromise(EventExecutor executor) |
ImmediatePromise(EventExecutor executor) |
NonStickyOrderedEventExecutor(EventExecutor executor,
int maxTaskExecutePerRun) |
PowerOfTwoEventExecutorChooser(EventExecutor[] executors) |
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.
|