Package | Description |
---|---|
io.netty.util.concurrent |
Utility classes for concurrent / async tasks.
|
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. |
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 | Method and Description |
---|---|
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(Executor executor,
Object... args)
Create a new EventExecutor which will later then accessible via the
MultithreadEventExecutorGroup.next() method. |
protected EventExecutor |
DefaultEventExecutorGroup.newChild(Executor executor,
Object... args) |
EventExecutor |
EventExecutorChooserFactory.EventExecutorChooser.next()
Returns the new
EventExecutor to use. |
EventExecutor |
MultithreadEventExecutorGroup.next() |
EventExecutor |
AbstractEventExecutor.next() |
EventExecutor |
NonStickyEventExecutorGroup.next() |
EventExecutor |
UnorderedThreadPoolEventExecutor.next() |
EventExecutor |
EventExecutor.next()
Returns a reference to itself.
|
EventExecutor |
EventExecutorGroup.next()
Returns one of the
EventExecutor s managed by this EventExecutorGroup . |
Modifier and Type | Method and Description |
---|---|
Iterator<EventExecutor> |
MultithreadEventExecutorGroup.iterator() |
Iterator<EventExecutor> |
AbstractEventExecutor.iterator() |
Iterator<EventExecutor> |
NonStickyEventExecutorGroup.iterator() |
Iterator<EventExecutor> |
UnorderedThreadPoolEventExecutor.iterator() |
Iterator<EventExecutor> |
EventExecutorGroup.iterator() |
Modifier and Type | Method and Description |
---|---|
EventExecutorChooserFactory.EventExecutorChooser |
DefaultEventExecutorChooserFactory.newChooser(EventExecutor[] executors) |
EventExecutorChooserFactory.EventExecutorChooser |
EventExecutorChooserFactory.newChooser(EventExecutor[] executors)
Returns a new
EventExecutorChooserFactory.EventExecutorChooser . |
protected static void |
DefaultPromise.notifyListener(EventExecutor eventExecutor,
Future<?> future,
GenericFutureListener<?> listener)
Notify a listener that a future has completed.
|
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–2019 The Netty Project. All rights reserved.