Top Description Methods
io.netty.util.concurrent

public Interface EventExecutor

extends EventExecutorGroup
Known Direct Subinterfaces
io.netty.util.concurrent.OrderedEventExecutor
Known Direct Implementers
io.netty.util.concurrent.UnorderedThreadPoolEventExecutor, io.netty.util.concurrent.AbstractEventExecutor
The EventExecutor is a special EventExecutorGroup which comes with some handy methods to see if a Thread is executed in a event loop. Besides this, it also extends the EventExecutorGroup to allow for a generic way to access methods.

Method Summary

Modifier and TypeMethod and Description
public boolean
inEventLoop()

Calls inEventLoop(Thread) with Thread#currentThread() as argument

public boolean
inEventLoop(Thread thread)

Return true if the given Thread is executed in the event loop, false otherwise.

public <V> Future<V>
newFailedFuture(Throwable cause)

Create a new Future which is marked as failed already.

public <V> ProgressivePromise<V>
newProgressivePromise()

Create a new ProgressivePromise.

public <V> Promise<V>
newPromise()

Return a new Promise.

public <V> Future<V>
newSucceededFuture(V result)

Create a new Future which is marked as succeeded already.

public EventExecutor
next()

Redeclares io.netty.util.concurrent.EventExecutorGroup.next.

Returns a reference to itself.
public EventExecutorGroup
parent()

Return the EventExecutorGroup which is the parent of this EventExecutor,

Inherited from io.netty.util.concurrent.EventExecutorGroup:
isShuttingDowniteratorscheduleschedulescheduleAtFixedRatescheduleWithFixedDelayshutdownshutdownGracefullyshutdownGracefullyshutdownNowsubmitsubmitsubmitterminationFuture

Method Detail

inEventLoopback to summary
public boolean inEventLoop()

Calls inEventLoop(Thread) with Thread#currentThread() as argument

inEventLoopback to summary
public boolean inEventLoop(Thread thread)

Return true if the given Thread is executed in the event loop, false otherwise.

newFailedFutureback to summary
public <V> Future<V> newFailedFuture(Throwable cause)

Create a new Future which is marked as failed already. So Future#isSuccess() will return false. All FutureListener added to it will be notified directly. Also every call of blocking methods will just return without blocking.

newProgressivePromiseback to summary
public <V> ProgressivePromise<V> newProgressivePromise()

Create a new ProgressivePromise.

newPromiseback to summary
public <V> Promise<V> newPromise()

Return a new Promise.

newSucceededFutureback to summary
public <V> Future<V> newSucceededFuture(V result)

Create a new Future which is marked as succeeded already. So Future#isSuccess() will return true. All FutureListener added to it will be notified directly. Also every call of blocking methods will just return without blocking.

nextback to summary
public EventExecutor next()

Redeclares io.netty.util.concurrent.EventExecutorGroup.next.

Returns a reference to itself.

Annotations
@Override
parentback to summary
public EventExecutorGroup parent()

Return the EventExecutorGroup which is the parent of this EventExecutor,