com.jfinal.kit

类 ScheduledKit

java.lang.Object

com.jfinal.kit.ScheduledKit

public class ScheduledKit
extends Object

调度工具类 1：scheduleWithFixedDelay 以上一次任务的 "结束时间" 为间隔调度任务 2：scheduleAtFixedRate 以上一次任务的 "开始时间" 为间隔调度任务。当本次调度来临时，如果上一次任务未执行完，则等待它执行完成后再立即调度 3：注意要在被调度的任务(Runnable/Callable)中捕获异常，否则调度将会停止

方法概要

限定符和类型	方法和说明
static ScheduledExecutorService	getExecutor()
static void	init(int corePoolSize) 初始化
static void	init(ScheduledExecutorService executor) 传递 ScheduledExecutorService 对象进行初始化，从而完全掌控线程池参数
static <V> ScheduledFuture<V>	schedule(Callable<V> task, long delay, TimeUnit unit) 创建一次性调度，在给定的 delay 时间后调度
static ScheduledFuture<?>	schedule(Runnable task, long delay, TimeUnit unit) 创建一次性调度，在给定的 delay 时间后调度
static ScheduledFuture<?>	scheduleAtFixedRate(Runnable task, long initialDelay, long period, TimeUnit unit) 以固定频率执行任务
static ScheduledFuture<?>	scheduleWithFixedDelay(Runnable task, long initialDelay, long delay, TimeUnit unit) 以固定延迟执行任务
static void	shutdown() 等待正在执行的线程执行完毕以后，关闭线程池
static void	shutdownNow() 停掉正在执行的线程，关闭线程池

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

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

方法详细资料

init

public static void init(int corePoolSize)

初始化

参数:

corePoolSize - the number of threads to keep in the pool, even if they are idle

init

public static void init(ScheduledExecutorService executor)

传递 ScheduledExecutorService 对象进行初始化，从而完全掌控线程池参数

getExecutor

public static ScheduledExecutorService getExecutor()

scheduleWithFixedDelay

public static ScheduledFuture<?> scheduleWithFixedDelay(Runnable task,
                                                        long initialDelay,
                                                        long delay,
                                                        TimeUnit unit)

以固定延迟执行任务

参数:

task - 被执行的任务

initialDelay - 第一次启动前的延迟

delay - 上次任务 "完成" 时间与本次任务 "开始" 时间的间隔

unit - 时间单位

scheduleAtFixedRate

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

以固定频率执行任务

参数:

task - 被执行的任务

initialDelay - 第一次启动前的延迟

period - 上次任务 "开始" 时间与本次任务 "开始" 时间的间隔，如果任务执行时长超出 period 值，则在任务执行完成后立即调度任务执行

unit - 时间单位

schedule

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

创建一次性调度，在给定的 delay 时间后调度

参数:

task - 被执行任务

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

unit - 时间单位

schedule

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

创建一次性调度，在给定的 delay 时间后调度

参数:

task - 被执行任务

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

unit - 时间单位

shutdown

public static void shutdown()

等待正在执行的线程执行完毕以后，关闭线程池

shutdownNow

public static void shutdownNow()

停掉正在执行的线程，关闭线程池