io.netty.util.concurrent

类 AbstractEventExecutor

java.lang.Object

java.util.concurrent.AbstractExecutorService

io.netty.util.concurrent.AbstractEventExecutor

所有已实现的接口:

EventExecutor, EventExecutorGroup, java.lang.Iterable<EventExecutor>, java.util.concurrent.Executor, java.util.concurrent.ExecutorService, java.util.concurrent.ScheduledExecutorService

直接已知子类:

AbstractEventLoop, AbstractScheduledEventExecutor, ImmediateEventExecutor

public abstract class AbstractEventExecutor
extends java.util.concurrent.AbstractExecutorService
implements EventExecutor

Abstract base class for EventExecutor implementations.

嵌套类概要

嵌套类

限定符和类型	类和说明
static interface	AbstractEventExecutor.LazyRunnable 已过时。 override SingleThreadEventExecutor.wakesUpForTask(java.lang.Runnable) to re-create this behaviour

构造器概要

构造器

限定符	构造器和说明
protected	AbstractEventExecutor()
protected	AbstractEventExecutor(EventExecutorGroup parent)

方法概要

限定符和类型	方法和说明
boolean	inEventLoop() Calls EventExecutor.inEventLoop(Thread) with Thread.currentThread() as argument
java.util.Iterator<EventExecutor>	iterator()
void	lazyExecute(java.lang.Runnable task) Like Executor.execute(Runnable) but does not guarantee the task will be run until either a non-lazy task is executed or the executor is shut down.
<V> Future<V>	newFailedFuture(java.lang.Throwable cause) Create a new Future which is marked as failed already.
<V> ProgressivePromise<V>	newProgressivePromise() Create a new ProgressivePromise.
<V> Promise<V>	newPromise() Return a new Promise.
<V> Future<V>	newSucceededFuture(V result) Create a new Future which is marked as succeeded already.
protected <T> java.util.concurrent.RunnableFuture<T>	newTaskFor(java.util.concurrent.Callable<T> callable)
protected <T> java.util.concurrent.RunnableFuture<T>	newTaskFor(java.lang.Runnable runnable, T value)
EventExecutor	next() Returns a reference to itself.
EventExecutorGroup	parent() Return the EventExecutorGroup which is the parent of this EventExecutor,
protected static void	runTask(java.lang.Runnable task)
protected static void	safeExecute(java.lang.Runnable task) Try to execute the given Runnable and just log if it throws a Throwable.
<V> ScheduledFuture<V>	schedule(java.util.concurrent.Callable<V> callable, long delay, java.util.concurrent.TimeUnit unit)
ScheduledFuture<?>	schedule(java.lang.Runnable command, long delay, java.util.concurrent.TimeUnit unit)
ScheduledFuture<?>	scheduleAtFixedRate(java.lang.Runnable command, long initialDelay, long period, java.util.concurrent.TimeUnit unit)
ScheduledFuture<?>	scheduleWithFixedDelay(java.lang.Runnable command, long initialDelay, long delay, java.util.concurrent.TimeUnit unit)
abstract void	shutdown() 已过时。 EventExecutorGroup.shutdownGracefully(long, long, TimeUnit) or shutdownGracefully() instead.
Future<?>	shutdownGracefully() Shortcut method for EventExecutorGroup.shutdownGracefully(long, long, TimeUnit) with sensible default values.
java.util.List<java.lang.Runnable>	shutdownNow() 已过时。 EventExecutorGroup.shutdownGracefully(long, long, TimeUnit) or shutdownGracefully() instead.
<T> Future<T>	submit(java.util.concurrent.Callable<T> task)
Future<?>	submit(java.lang.Runnable task)
<T> Future<T>	submit(java.lang.Runnable task, T result)

从类继承的方法 java.util.concurrent.AbstractExecutorService

invokeAll, invokeAll, invokeAny, invokeAny

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

从接口继承的方法 io.netty.util.concurrent.EventExecutor

inEventLoop

从接口继承的方法 io.netty.util.concurrent.EventExecutorGroup

isShuttingDown, shutdownGracefully, terminationFuture

从接口继承的方法 java.util.concurrent.ExecutorService

awaitTermination, invokeAll, invokeAll, invokeAny, invokeAny, isShutdown, isTerminated

从接口继承的方法 java.util.concurrent.Executor

execute

从接口继承的方法 java.lang.Iterable

forEach, spliterator

构造器详细资料

AbstractEventExecutor

protected AbstractEventExecutor()

AbstractEventExecutor

protected AbstractEventExecutor(EventExecutorGroup parent)

方法详细资料

parent

public EventExecutorGroup parent()

从接口复制的说明: EventExecutor

Return the EventExecutorGroup which is the parent of this EventExecutor,

指定者:

parent 在接口中 EventExecutor

next

public EventExecutor next()

从接口复制的说明: EventExecutor

Returns a reference to itself.

指定者:

next 在接口中 EventExecutor

指定者:

next 在接口中 EventExecutorGroup

inEventLoop

public boolean inEventLoop()

从接口复制的说明: EventExecutor

Calls EventExecutor.inEventLoop(Thread) with Thread.currentThread() as argument

指定者:

inEventLoop 在接口中 EventExecutor

iterator

public java.util.Iterator<EventExecutor> iterator()

指定者:

iterator 在接口中 EventExecutorGroup

指定者:

iterator 在接口中 java.lang.Iterable<EventExecutor>

shutdownGracefully

public Future<?> shutdownGracefully()

从接口复制的说明: EventExecutorGroup

Shortcut method for EventExecutorGroup.shutdownGracefully(long, long, TimeUnit) with sensible default values.

指定者:

shutdownGracefully 在接口中 EventExecutorGroup

返回:

the EventExecutorGroup.terminationFuture()

shutdown

@Deprecated
public abstract void shutdown()

已过时。 EventExecutorGroup.shutdownGracefully(long, long, TimeUnit) or shutdownGracefully() instead.

指定者:

shutdown 在接口中 EventExecutorGroup

指定者:

shutdown 在接口中 java.util.concurrent.ExecutorService

shutdownNow

@Deprecated
public java.util.List<java.lang.Runnable> shutdownNow()

已过时。 EventExecutorGroup.shutdownGracefully(long, long, TimeUnit) or shutdownGracefully() instead.

指定者:

shutdownNow 在接口中 EventExecutorGroup

指定者:

shutdownNow 在接口中 java.util.concurrent.ExecutorService

newPromise

public <V> Promise<V> newPromise()

从接口复制的说明: EventExecutor

Return a new Promise.

指定者:

newPromise 在接口中 EventExecutor

newProgressivePromise

public <V> ProgressivePromise<V> newProgressivePromise()

从接口复制的说明: EventExecutor

Create a new ProgressivePromise.

指定者:

newProgressivePromise 在接口中 EventExecutor

newSucceededFuture

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

从接口复制的说明: EventExecutor

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.

指定者:

newSucceededFuture 在接口中 EventExecutor

newFailedFuture

public <V> Future<V> newFailedFuture(java.lang.Throwable cause)

从接口复制的说明: EventExecutor

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.

指定者:

newFailedFuture 在接口中 EventExecutor

submit

public Future<?> submit(java.lang.Runnable task)

指定者:

submit 在接口中 EventExecutorGroup

指定者:

submit 在接口中 java.util.concurrent.ExecutorService

覆盖:

submit 在类中 java.util.concurrent.AbstractExecutorService

submit

public <T> Future<T> submit(java.lang.Runnable task,
                            T result)

指定者:

submit 在接口中 EventExecutorGroup

指定者:

submit 在接口中 java.util.concurrent.ExecutorService

覆盖:

submit 在类中 java.util.concurrent.AbstractExecutorService

submit

public <T> Future<T> submit(java.util.concurrent.Callable<T> task)

指定者:

submit 在接口中 EventExecutorGroup

指定者:

submit 在接口中 java.util.concurrent.ExecutorService

覆盖:

submit 在类中 java.util.concurrent.AbstractExecutorService

newTaskFor

protected final <T> java.util.concurrent.RunnableFuture<T> newTaskFor(java.lang.Runnable runnable,
                                                                      T value)

覆盖:

newTaskFor 在类中 java.util.concurrent.AbstractExecutorService

newTaskFor

protected final <T> java.util.concurrent.RunnableFuture<T> newTaskFor(java.util.concurrent.Callable<T> callable)

覆盖:

newTaskFor 在类中 java.util.concurrent.AbstractExecutorService

schedule

public ScheduledFuture<?> schedule(java.lang.Runnable command,
                                   long delay,
                                   java.util.concurrent.TimeUnit unit)

指定者:

schedule 在接口中 EventExecutorGroup

指定者:

schedule 在接口中 java.util.concurrent.ScheduledExecutorService

schedule

public <V> ScheduledFuture<V> schedule(java.util.concurrent.Callable<V> callable,
                                       long delay,
                                       java.util.concurrent.TimeUnit unit)

指定者:

schedule 在接口中 EventExecutorGroup

指定者:

schedule 在接口中 java.util.concurrent.ScheduledExecutorService

scheduleAtFixedRate

public ScheduledFuture<?> scheduleAtFixedRate(java.lang.Runnable command,
                                              long initialDelay,
                                              long period,
                                              java.util.concurrent.TimeUnit unit)

指定者:

scheduleAtFixedRate 在接口中 EventExecutorGroup

指定者:

scheduleAtFixedRate 在接口中 java.util.concurrent.ScheduledExecutorService

scheduleWithFixedDelay

public ScheduledFuture<?> scheduleWithFixedDelay(java.lang.Runnable command,
                                                 long initialDelay,
                                                 long delay,
                                                 java.util.concurrent.TimeUnit unit)

指定者:

scheduleWithFixedDelay 在接口中 EventExecutorGroup

指定者:

scheduleWithFixedDelay 在接口中 java.util.concurrent.ScheduledExecutorService

safeExecute

protected static void safeExecute(java.lang.Runnable task)

Try to execute the given Runnable and just log if it throws a Throwable.

runTask

protected static void runTask(java.lang.Runnable task)

lazyExecute

@UnstableApi
public void lazyExecute(java.lang.Runnable task)

Like Executor.execute(Runnable) but does not guarantee the task will be run until either a non-lazy task is executed or the executor is shut down.

The default implementation just delegates to Executor.execute(Runnable).