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

直接已知子类:

AbstractScheduledEventExecutor, ImmediateEventExecutor

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

Abstract base class for EventExecutor implementations.

构造器概要

构造器

构造器和说明
AbstractEventExecutor()

方法概要

方法

限定符和类型	方法和说明
boolean	inEventLoop() Calls EventExecutor.inEventLoop(Thread) with Thread.currentThread() as argument
java.util.Iterator<EventExecutor>	iterator() Returns a read-only Iterator over all EventExecutor, which are handled by this EventExecutorGroup at the time of invoke this method.
<V> Future<V>	newFailedFuture(java.lang.Throwable cause) Create a new Future which is marked as fakued 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 successes 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.
<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, parent

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

isShuttingDown, shutdownGracefully, terminationFuture

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

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

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

execute

构造器详细资料

AbstractEventExecutor

public AbstractEventExecutor()

方法详细资料

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()

从接口复制的说明: EventExecutorGroup

Returns a read-only Iterator over all EventExecutor, which are handled by this EventExecutorGroup at the time of invoke this method.

指定者:

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 successes 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 fakued 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