|
JavaTM 2 Platform Standard Ed. 5.0 |
|||||||||
上一个类 下一个类 | 框架 无框架 | |||||||||
摘要: 嵌套 | 字段 | 构造方法 | 方法 | 详细信息: 字段 | 构造方法 | 方法 |
java.lang.Object java.util.concurrent.AbstractExecutorService java.util.concurrent.ThreadPoolExecutor java.util.concurrent.ScheduledThreadPoolExecutor
public class ScheduledThreadPoolExecutor
ThreadPoolExecutor
,它可另行安排在给定的延迟后运行命令,或者定期执行命令。需要多个辅助线程时,或者要求 ThreadPoolExecutor
具有额外的灵活性或功能时,此类要优于 Timer
。
一旦启用已延迟的任务就执行它,但是有关何时启用,启用后何时执行则没有任何实时保证。按照提交的先进先出 (FIFO) 顺序来启用那些被安排在同一执行时间的任务。
虽然此类继承自 ThreadPoolExecutor
,但是几个继承的调整方法对此类并无作用。特别是,因为它作为一个使用 corePoolSize 线程和一个无界队列的固定大小的池,所以调整 maximumPoolSize 没有什么效果。
嵌套类摘要 |
---|
从类 java.util.concurrent.ThreadPoolExecutor 继承的嵌套类/接口 |
---|
ThreadPoolExecutor.AbortPolicy, ThreadPoolExecutor.CallerRunsPolicy, ThreadPoolExecutor.DiscardOldestPolicy, ThreadPoolExecutor.DiscardPolicy |
构造方法摘要 | |
---|---|
ScheduledThreadPoolExecutor(int corePoolSize)
使用给定核心池大小创建一个新 ScheduledThreadPoolExecutor。 |
|
ScheduledThreadPoolExecutor(int corePoolSize,
RejectedExecutionHandler handler)
使用给定初始参数创建一个新 ScheduledThreadPoolExecutor。 |
|
ScheduledThreadPoolExecutor(int corePoolSize,
ThreadFactory threadFactory)
使用给定的初始参数创建一个新 ScheduledThreadPoolExecutor。 |
|
ScheduledThreadPoolExecutor(int corePoolSize,
ThreadFactory threadFactory,
RejectedExecutionHandler handler)
使用给定初始参数创建一个新 ScheduledThreadPoolExecutor。 |
方法摘要 | ||
---|---|---|
void |
execute(Runnable command)
使用所要求的零延迟执行命令。 |
|
boolean |
getContinueExistingPeriodicTasksAfterShutdownPolicy()
获得有关在此执行程序已 shutdown 的情况下、是否继续执行现有定期任务的策略。 |
|
boolean |
getExecuteExistingDelayedTasksAfterShutdownPolicy()
获得有关在此执行程序已 shutdown 的情况下是否继续执行现有延迟任务的策略。 |
|
BlockingQueue<Runnable> |
getQueue()
返回此执行程序使用的任务队列。 |
|
boolean |
remove(Runnable task)
从执行程序的内部队列中移除此任务(如果出现),这样如果尚未开始,则其不再运行。 |
|
|
schedule(Callable<V> callable,
long delay,
TimeUnit unit)
创建并执行在给定延迟后启用的 ScheduledFuture。 |
|
ScheduledFuture<?> |
schedule(Runnable command,
long delay,
TimeUnit unit)
创建并执行在给定延迟后启用的一次性操作。 |
|
ScheduledFuture<?> |
scheduleAtFixedRate(Runnable command,
long initialDelay,
long period,
TimeUnit unit)
创建并执行一个在给定初始延迟后首次启用的定期操作,后续操作具有给定的周期;也就是将在 initialDelay 后开始执行,然后在 initialDelay+period 后执行,接着在 initialDelay + 2 * period 后执行,依此类推。 |
|
ScheduledFuture<?> |
scheduleWithFixedDelay(Runnable command,
long initialDelay,
long delay,
TimeUnit unit)
创建并执行一个在给定初始延迟后首次启用的定期操作,随后,在每一次执行终止和下一次执行开始之间都存在给定的延迟。 |
|
void |
setContinueExistingPeriodicTasksAfterShutdownPolicy(boolean value)
设置有关在此执行程序已 shutdown 的情况下是否继续执行现有定期任务的策略。 |
|
void |
setExecuteExistingDelayedTasksAfterShutdownPolicy(boolean value)
设置有关在此执行程序已 shutdown 的情况下是否继续执行现有延迟任务的策略。 |
|
void |
shutdown()
在以前已提交任务的执行中发起一个有序的关闭,但是不接受新任务。 |
|
List<Runnable> |
shutdownNow()
尝试停止所有正在执行的任务、暂停等待任务的处理,并返回等待执行的任务列表。 |
|
|
submit(Callable<T> task)
提交一个返回值的任务用于执行,返回一个表示任务的未决结果的 Future。 |
|
Future<?> |
submit(Runnable task)
提交一个 Runnable 任务用于执行,并返回一个表示该任务的 Future。 |
|
|
submit(Runnable task,
T result)
提交一个 Runnable 任务用于执行,并返回一个 Future,该 Future 表示任务一旦完成后即返回给定的结果。 |
从类 java.util.concurrent.AbstractExecutorService 继承的方法 |
---|
invokeAll, invokeAll, invokeAny, invokeAny |
从类 java.lang.Object 继承的方法 |
---|
clone, equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
从接口 java.util.concurrent.ExecutorService 继承的方法 |
---|
awaitTermination, invokeAll, invokeAll, invokeAny, invokeAny, isShutdown, isTerminated |
构造方法详细信息 |
---|
public ScheduledThreadPoolExecutor(int corePoolSize)
corePoolSize
- 池中所保存的线程数(包括空闲线程)。
IllegalArgumentException
- 如果 corePoolSize 小于或等于 0。public ScheduledThreadPoolExecutor(int corePoolSize, ThreadFactory threadFactory)
corePoolSize
- 池中所保存的线程数(包括空闲线程)。threadFactory
- 执行程序创建新线程时使用的工厂。
NullPointerException
- 如果 threadFactory 为 null。public ScheduledThreadPoolExecutor(int corePoolSize, RejectedExecutionHandler handler)
corePoolSize
- 池中所保存的线程数(包括空闲线程)。handler
- 由于超出线程范围和队列容量而使执行被阻塞时所使用的处理程序。
NullPointerException
- 如果处理程序为 null。public ScheduledThreadPoolExecutor(int corePoolSize, ThreadFactory threadFactory, RejectedExecutionHandler handler)
corePoolSize
- 池中所保存的线程数(包括空闲线程)。threadFactory
- 执行程序创建新线程时使用的工厂。handler
- 由于超出线程范围和队列容量而使执行被阻塞时所使用的处理程序。
NullPointerException
- 如果 threadFactory 或处理程序为 null。方法详细信息 |
---|
public boolean remove(Runnable task)
ThreadPoolExecutor
复制的描述 此方法可用作取消方案的一部分。如果任务在加入内部队列之前已经转换为其他形式,则移除这些任务时可能会失败。例如,使用 submit 输入的任务可能被转换为维护 Future 状态的形式。但是,在这些情况下,可以使用方法 ThreadPoolExecutor.purge()
来移除这些已经取消的 Future。
ThreadPoolExecutor
中的 remove
task
- 要移除的任务
public ScheduledFuture<?> schedule(Runnable command, long delay, TimeUnit unit)
ScheduledExecutorService
复制的描述
ScheduledExecutorService
中的 schedule
command
- 要执行的任务。delay
- 从现在开始延迟执行的时间。unit
- 延迟参数的时间单位。
public <V> ScheduledFuture<V> schedule(Callable<V> callable, long delay, TimeUnit unit)
ScheduledExecutorService
复制的描述
ScheduledExecutorService
中的 schedule
callable
- 要执行的功能。delay
- 从现在开始延迟执行的时间。unit
- 延迟参数的时间单位。
public ScheduledFuture<?> scheduleAtFixedRate(Runnable command, long initialDelay, long period, TimeUnit unit)
ScheduledExecutorService
复制的描述
ScheduledExecutorService
中的 scheduleAtFixedRate
command
- 要执行的任务。initialDelay
- 首次执行的延迟时间。period
- 连续执行之间的周期。unit
- initialDelay 和 period 参数的时间单位。
public ScheduledFuture<?> scheduleWithFixedDelay(Runnable command, long initialDelay, long delay, TimeUnit unit)
ScheduledExecutorService
复制的描述
ScheduledExecutorService
中的 scheduleWithFixedDelay
command
- 要执行的任务。initialDelay
- 首次执行的延迟时间。delay
- 一次执行终止和下一次执行开始之间的延迟。unit
- initialDelay 和 delay 参数的时间单位。
public void execute(Runnable command)
ScheduledFuture
,而不是 command 本身。
Executor
中的 execute
ThreadPoolExecutor
中的 execute
command
- 要执行的任务。
由
- RejectedExecutionHandler 随意决定的 RejectedExecutionException,如果由于执行程序已关闭而无法接受要执行的任务 。
NullPointerException
- 如果 command 为 null。public Future<?> submit(Runnable task)
ExecutorService
复制的描述
ExecutorService
中的 submit
AbstractExecutorService
中的 submit
task
- 要提交的任务。
public <T> Future<T> submit(Runnable task, T result)
ExecutorService
复制的描述
ExecutorService
中的 submit
AbstractExecutorService
中的 submit
task
- 要提交的任务result
- 返回的结果
public <T> Future<T> submit(Callable<T> task)
ExecutorService
复制的描述如果想立即阻塞任务的等待,则可以使用 result = exec.submit(aCallable).get(); 形式的构造。
注:Executors
类包括了一组方法,可以转换某些其他常见的类似于闭包的对象,例如,将 PrivilegedAction
转换为 Callable
形式,这样就可以提交它们了。
ExecutorService
中的 submit
AbstractExecutorService
中的 submit
task
- 要提交的任务
public void setContinueExistingPeriodicTasksAfterShutdownPolicy(boolean value)
value
- 如果为 true,则在关闭后继续执行;否则不执行。getExecuteExistingDelayedTasksAfterShutdownPolicy()
public boolean getContinueExistingPeriodicTasksAfterShutdownPolicy()
setContinueExistingPeriodicTasksAfterShutdownPolicy(boolean)
public void setExecuteExistingDelayedTasksAfterShutdownPolicy(boolean value)
value
- 如果为 true,则在关闭后执行;否则不执行。getExecuteExistingDelayedTasksAfterShutdownPolicy()
public boolean getExecuteExistingDelayedTasksAfterShutdownPolicy()
setExecuteExistingDelayedTasksAfterShutdownPolicy(boolean)
public void shutdown()
ExecutorService
中的 shutdown
ThreadPoolExecutor
中的 shutdown
public List<Runnable> shutdownNow()
虽然尽最大努力,但并不保证可以停止处理正在执行的任务。此实现通过 Thread.interrupt()
取消任务,所以如果任何任务屏蔽或无法响应中断,则可能永远无法终止该任务。
ExecutorService
中的 shutdownNow
ThreadPoolExecutor
中的 shutdownNow
ScheduledFuture
,包括用 execute 所提交的那些任务,出于安排的目的,这些任务用作零延迟 ScheduledFuture 的基础。public BlockingQueue<Runnable> getQueue()
ScheduledFuture
,包括用 execute 所提交的那些任务,出于安排的目的,这些任务用作零延迟 ScheduledFuture 的基础。无法 保证对此队列进行迭代的迭代器会以任务执行的顺序遍历各任务。
ThreadPoolExecutor
中的 getQueue
|
JavaTM 2 Platform Standard Ed. 5.0 |
|||||||||
上一个类 下一个类 | 框架 无框架 | |||||||||
摘要: 嵌套 | 字段 | 构造方法 | 方法 | 详细信息: 字段 | 构造方法 | 方法 |
版权所有 2004 Sun Microsystems, Inc. 保留所有权利。 请遵守许可证条款。另请参阅文档重新分发政策。