程序包 | 说明 |
---|---|
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.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 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 |
Benchmarks for
io.netty.util.concurrent . |
io.netty.util.internal |
Internal-use-only utilities which is not allowed to be used
outside Netty.
|
限定符和类型 | 接口和说明 |
---|---|
interface |
EventLoop
Will handle all the I/O operations for a
Channel once registered. |
限定符和类型 | 类和说明 |
---|---|
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
已过时。
this will be remove in the next-major release.
|
限定符和类型 | 方法和说明 |
---|---|
protected EventExecutor |
DefaultChannelPromise.executor() |
protected EventExecutor |
DefaultChannelProgressivePromise.executor() |
EventExecutor |
ChannelHandlerContext.executor()
Returns the
EventExecutor which is used to execute an arbitrary task. |
限定符和类型 | 方法和说明 |
---|---|
java.util.Iterator<EventExecutor> |
ThreadPerChannelEventLoopGroup.iterator()
已过时。
|
构造器和说明 |
---|
DefaultChannelProgressivePromise(Channel channel,
EventExecutor executor)
Creates a new instance.
|
DefaultChannelPromise(Channel channel,
EventExecutor executor)
Creates a new instance.
|
限定符和类型 | 类和说明 |
---|---|
class |
EpollEventLoop
EventLoop which uses epoll under the covers. |
构造器和说明 |
---|
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)
|
限定符和类型 | 类和说明 |
---|---|
class |
NioEventLoop
SingleThreadEventLoop implementation which register the Channel 's to a
Selector and so does the multi-plexing of these in the event loop. |
构造器和说明 |
---|
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.
|
限定符和类型 | 方法和说明 |
---|---|
protected EventExecutor |
SimpleNameResolver.executor()
Returns the
EventExecutor which is used to notify the listeners of the Future returned
by SimpleNameResolver.resolve(String) . |
protected EventExecutor |
AbstractAddressResolver.executor()
Returns the
EventExecutor which is used to notify the listeners of the Future returned
by AbstractAddressResolver.resolve(SocketAddress) . |
限定符和类型 | 方法和说明 |
---|---|
AddressResolver<T> |
AddressResolverGroup.getResolver(EventExecutor executor)
Returns the
AddressResolver associated with the specified EventExecutor . |
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)
Invoked by
AddressResolverGroup.getResolver(EventExecutor) to create a new AddressResolver . |
构造器和说明 |
---|
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) |
限定符和类型 | 方法和说明 |
---|---|
protected AddressResolver<java.net.InetSocketAddress> |
DnsAddressResolverGroup.newResolver(EventExecutor executor) |
限定符和类型 | 接口和说明 |
---|---|
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 |
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. |
限定符和类型 | 方法和说明 |
---|---|
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.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 |
UnorderedThreadPoolEventExecutor.next() |
EventExecutor |
NonStickyEventExecutorGroup.next() |
EventExecutor |
MultithreadEventExecutorGroup.next() |
EventExecutor |
EventExecutorGroup.next()
Returns one of the
EventExecutor s managed by this EventExecutorGroup . |
EventExecutor |
EventExecutorChooserFactory.EventExecutorChooser.next()
Returns the new
EventExecutor to use. |
EventExecutor |
EventExecutor.next()
Returns a reference to itself.
|
EventExecutor |
AbstractEventExecutor.next() |
限定符和类型 | 方法和说明 |
---|---|
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() |
限定符和类型 | 方法和说明 |
---|---|
EventExecutorChooserFactory.EventExecutorChooser |
EventExecutorChooserFactory.newChooser(EventExecutor[] executors)
Returns a new
EventExecutorChooserFactory.EventExecutorChooser . |
EventExecutorChooserFactory.EventExecutorChooser |
DefaultEventExecutorChooserFactory.newChooser(EventExecutor[] executors) |
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.
|
PromiseCombiner(EventExecutor executor)
The
EventExecutor to use for notifications. |
SucceededFuture(EventExecutor executor,
V result)
Creates a new instance.
|
限定符和类型 | 方法和说明 |
---|---|
static EventExecutor |
ThreadExecutorMap.currentExecutor()
|
限定符和类型 | 方法和说明 |
---|---|
static java.util.concurrent.Executor |
ThreadExecutorMap.apply(java.util.concurrent.Executor executor,
EventExecutor eventExecutor)
Decorate the given
Executor and ensure ThreadExecutorMap.currentExecutor() will return eventExecutor
when called from within the Runnable during execution. |
static java.lang.Runnable |
ThreadExecutorMap.apply(java.lang.Runnable command,
EventExecutor eventExecutor)
Decorate the given
Runnable and ensure ThreadExecutorMap.currentExecutor() will return eventExecutor
when called from within the Runnable during execution. |
static java.util.concurrent.ThreadFactory |
ThreadExecutorMap.apply(java.util.concurrent.ThreadFactory threadFactory,
EventExecutor eventExecutor)
Decorate the given
ThreadFactory and ensure ThreadExecutorMap.currentExecutor() will return eventExecutor
when called from within the Runnable during execution. |