Java java.util.concurrent 类 ScheduledThreadPoolExecutor（JDK5）

所有类

java.util.concurrent
类 ScheduledThreadPoolExecutor

java.lang.Object
  java.util.concurrent.AbstractExecutorService
      java.util.concurrent.ThreadPoolExecutor
          java.util.concurrent.ScheduledThreadPoolExecutor

所有已实现的接口：

Executor, ExecutorService, ScheduledExecutorService

public class ScheduledThreadPoolExecutor
   
   
   
   
   
extends ThreadPoolExecutor
   
   
   
   
   
   
   
   
   
   
implements ScheduledExecutorService
   
   
   
   
   

ThreadPoolExecutor，它可另行安排在给定的延迟后运行命令，或者定期执行命令。需要多个辅助线程时，或者要求 ThreadPoolExecutor 具有额外的灵活性或功能时，此类要优于 Timer。

一旦启用已延迟的任务就执行它，但是有关何时启用，启用后何时执行则没有任何实时保证。按照提交的先进先出 (FIFO) 顺序来启用那些被安排在同一执行时间的任务。

虽然此类继承自 ThreadPoolExecutor，但是几个继承的调整方法对此类并无作用。特别是，因为它作为一个使用 corePoolSize 线程和一个无界队列的固定大小的池，所以调整 maximumPoolSize 没有什么效果。

从以下版本开始：

1.5

ScheduledThreadPoolExecutor

public ScheduledThreadPoolExecutor(int corePoolSize)

使用给定核心池大小创建一个新 ScheduledThreadPoolExecutor。

参数：

corePoolSize - 池中所保存的线程数（包括空闲线程）。

抛出：

IllegalArgumentException - 如果 corePoolSize 小于或等于 0。

ScheduledThreadPoolExecutor

public ScheduledThreadPoolExecutor(int corePoolSize,
                                   ThreadFactory threadFactory)

使用给定的初始参数创建一个新 ScheduledThreadPoolExecutor。

参数：

corePoolSize - 池中所保存的线程数（包括空闲线程）。

threadFactory - 执行程序创建新线程时使用的工厂。

抛出：

NullPointerException - 如果 threadFactory 为 null。

ScheduledThreadPoolExecutor

public ScheduledThreadPoolExecutor(int corePoolSize,
                                   RejectedExecutionHandler handler)

使用给定初始参数创建一个新 ScheduledThreadPoolExecutor。

参数：

corePoolSize - 池中所保存的线程数（包括空闲线程）。

handler - 由于超出线程范围和队列容量而使执行被阻塞时所使用的处理程序。

抛出：

NullPointerException - 如果处理程序为 null。

ScheduledThreadPoolExecutor

public ScheduledThreadPoolExecutor(int corePoolSize,
                                   ThreadFactory threadFactory,
                                   RejectedExecutionHandler handler)

使用给定初始参数创建一个新 ScheduledThreadPoolExecutor。

参数：

corePoolSize - 池中所保存的线程数（包括空闲线程）。

threadFactory - 执行程序创建新线程时使用的工厂。

handler - 由于超出线程范围和队列容量而使执行被阻塞时所使用的处理程序。

抛出：

NullPointerException - 如果 threadFactory 或处理程序为 null。

remove

public boolean remove(Runnable task)

从类 ThreadPoolExecutor 复制的描述

从执行程序的内部队列中移除此任务（如果出现），这样如果尚未开始，则其不再运行。

此方法可用作取消方案的一部分。如果任务在加入内部队列之前已经转换为其他形式，则移除这些任务时可能会失败。例如，使用 submit 输入的任务可能被转换为维护 Future 状态的形式。但是，在这些情况下，可以使用方法 ThreadPoolExecutor.purge() 来移除这些已经取消的 Future。

覆盖：

类 ThreadPoolExecutor 中的 remove

参数：

task - 要移除的任务

返回：

如果已经移除任务，则返回 true

schedule

public ScheduledFuture<?> schedule(Runnable command,
                                   long delay,
                                   TimeUnit unit)

从接口 ScheduledExecutorService 复制的描述

创建并执行在给定延迟后启用的一次性操作。

指定者：

接口 ScheduledExecutorService 中的 schedule

参数：

command - 要执行的任务。

delay - 从现在开始延迟执行的时间。

unit - 延迟参数的时间单位。

返回：

表示挂起任务完成的 Future，并且其 get() 方法在完成后将返回 null。

schedule

public <V> ScheduledFuture<V> schedule(Callable<V> callable,
                                       long delay,
                                       TimeUnit unit)

从接口 ScheduledExecutorService 复制的描述

创建并执行在给定延迟后启用的 ScheduledFuture。

指定者：

接口 ScheduledExecutorService 中的 schedule

参数：

callable - 要执行的功能。

delay - 从现在开始延迟执行的时间。

unit - 延迟参数的时间单位。

返回：

可用于提取结果或取消的 ScheduledFuture。

scheduleAtFixedRate

public ScheduledFuture<?> scheduleAtFixedRate(Runnable command,
                                              long initialDelay,
                                              long period,
                                              TimeUnit unit)

从接口 ScheduledExecutorService 复制的描述

创建并执行一个在给定初始延迟后首次启用的定期操作，后续操作具有给定的周期；也就是将在 initialDelay 后开始执行，然后在 initialDelay+period 后执行，接着在 initialDelay + 2 * period 后执行，依此类推。如果任务的任一执行遇到异常，都会取消后续执行。否则，只能通过执行程序的取消或终止方法来终止该任务。

指定者：

接口 ScheduledExecutorService 中的 scheduleAtFixedRate

参数：

command - 要执行的任务。

initialDelay - 首次执行的延迟时间。

period - 连续执行之间的周期。

unit - initialDelay 和 period 参数的时间单位。

返回：

表示挂起任务完成的 Future，并且其 get() 方法在取消后将抛出异常。