public abstract class AbstractEventExecutorGroup extends java.lang.Object implements EventExecutorGroup
EventExecutorGroup
实现的抽象基类。
Constructor and Description |
---|
AbstractEventExecutorGroup() |
Modifier and Type | Method and Description |
---|---|
void |
execute(java.lang.Runnable command) |
<T> java.util.List<java.util.concurrent.Future<T>> |
invokeAll(java.util.Collection<? extends java.util.concurrent.Callable<T>> tasks) |
<T> java.util.List<java.util.concurrent.Future<T>> |
invokeAll(java.util.Collection<? extends java.util.concurrent.Callable<T>> tasks, long timeout, java.util.concurrent.TimeUnit unit) |
<T> T |
invokeAny(java.util.Collection<? extends java.util.concurrent.Callable<T>> tasks) |
<T> T |
invokeAny(java.util.Collection<? extends java.util.concurrent.Callable<T>> tasks, long timeout, java.util.concurrent.TimeUnit unit) |
<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()
|
Future<?> |
shutdownGracefully()
|
java.util.List<java.lang.Runnable> |
shutdownNow()
|
<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) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
isShuttingDown, iterator, next, shutdownGracefully, terminationFuture
public Future<?> submit(java.lang.Runnable task)
submit
,界面
EventExecutorGroup
submit
在界面
java.util.concurrent.ExecutorService
public <T> Future<T> submit(java.lang.Runnable task, T result)
submit
在界面
EventExecutorGroup
submit
,界面
java.util.concurrent.ExecutorService
public <T> Future<T> submit(java.util.concurrent.Callable<T> task)
submit
,界面
EventExecutorGroup
submit
,界面
java.util.concurrent.ExecutorService
public ScheduledFuture<?> schedule(java.lang.Runnable command, long delay, java.util.concurrent.TimeUnit unit)
schedule
在界面
EventExecutorGroup
schedule
,界面
java.util.concurrent.ScheduledExecutorService
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
public ScheduledFuture<?> scheduleAtFixedRate(java.lang.Runnable command, long initialDelay, long period, java.util.concurrent.TimeUnit unit)
scheduleAtFixedRate
在界面
EventExecutorGroup
scheduleAtFixedRate
,界面
java.util.concurrent.ScheduledExecutorService
public ScheduledFuture<?> scheduleWithFixedDelay(java.lang.Runnable command, long initialDelay, long delay, java.util.concurrent.TimeUnit unit)
scheduleWithFixedDelay
,界面
EventExecutorGroup
scheduleWithFixedDelay
,界面
java.util.concurrent.ScheduledExecutorService
public Future<?> shutdownGracefully()
EventExecutorGroup
shutdownGracefully
在界面
EventExecutorGroup
EventExecutorGroup.terminationFuture()
@Deprecated public abstract void shutdown()
shutdown
,界面
EventExecutorGroup
shutdown
,界面
java.util.concurrent.ExecutorService
@Deprecated public java.util.List<java.lang.Runnable> shutdownNow()
shutdownNow
,界面
EventExecutorGroup
shutdownNow
,界面
java.util.concurrent.ExecutorService
public <T> java.util.List<java.util.concurrent.Future<T>> invokeAll(java.util.Collection<? extends java.util.concurrent.Callable<T>> tasks) throws java.lang.InterruptedException
invokeAll
接口
java.util.concurrent.ExecutorService
java.lang.InterruptedException
public <T> java.util.List<java.util.concurrent.Future<T>> invokeAll(java.util.Collection<? extends java.util.concurrent.Callable<T>> tasks, long timeout, java.util.concurrent.TimeUnit unit) throws java.lang.InterruptedException
invokeAll
,界面
java.util.concurrent.ExecutorService
java.lang.InterruptedException
public <T> T invokeAny(java.util.Collection<? extends java.util.concurrent.Callable<T>> tasks) throws java.lang.InterruptedException, java.util.concurrent.ExecutionException
invokeAny
,界面
java.util.concurrent.ExecutorService
java.lang.InterruptedException
java.util.concurrent.ExecutionException
public <T> T invokeAny(java.util.Collection<? extends java.util.concurrent.Callable<T>> tasks, long timeout, java.util.concurrent.TimeUnit unit) throws java.lang.InterruptedException, java.util.concurrent.ExecutionException, java.util.concurrent.TimeoutException
invokeAny
,界面
java.util.concurrent.ExecutorService
java.lang.InterruptedException
java.util.concurrent.ExecutionException
java.util.concurrent.TimeoutException
public void execute(java.lang.Runnable command)
execute
在界面
java.util.concurrent.Executor
Copyright © 2008–2018 The Netty Project. All rights reserved.