com.jfinal.kit

类 ScheduledKit

java.lang.Object

com.jfinal.kit.ScheduledKit

public class ScheduledKit
extends Object

调度工具类

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

方法概要

限定符和类型	方法和说明
static boolean	awaitTermination(long timeout, TimeUnit unit) 在 shutdown 线程池之后，阻塞等待所有任务执行完，或发生超时，或当前线程中断，以先发生者为准
static ScheduledExecutorService	getExecutor()
static void	init(int corePoolSize) 初始化
static void	init(ScheduledExecutorService executor) 传递 ScheduledExecutorService 对象进行初始化，从而完全掌控线程池参数
static <V> ScheduledFuture<V>	schedule(long delay, TimeUnit unit, Callable<V> task) 创建一次性调度，在给定的 delay 时间后调度
static ScheduledFuture<?>	schedule(long delay, TimeUnit unit, Runnable task) 创建一次性调度，在给定的 delay 时间后调度
static ScheduledFuture<?>	scheduleAtFixedRate(long initialDelay, long period, TimeUnit unit, Runnable task) 以固定频率执行任务
static ScheduledFuture<?>	scheduleAtFixedRateWithTryCatch(long initialDelay, long period, TimeUnit unit, Runnable task) 任务添加 try catch ，避免 scheduleAtFixedRate 方法在调度任务出现异常后会终止调度
static ScheduledFuture<?>	scheduleWithFixedDelay(long initialDelay, long delay, TimeUnit unit, Runnable task) 以固定延迟执行任务
static ScheduledFuture<?>	scheduleWithFixedDelayWithTryCatch(long initialDelay, long delay, TimeUnit unit, Runnable task) 任务添加 try catch ，避免 scheduleWithFixedDelay 方法在调度任务出现异常后会终止调度
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(long initialDelay,
                                                        long delay,
                                                        TimeUnit unit,
                                                        Runnable task)

以固定延迟执行任务

参数:

initialDelay - 第一次启动前的延迟

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

unit - 时间单位

task - 被执行的任务

scheduleWithFixedDelayWithTryCatch

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

任务添加 try catch ，避免 scheduleWithFixedDelay 方法在调度任务出现异常后会终止调度

scheduleAtFixedRate

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

以固定频率执行任务

参数:

initialDelay - 第一次启动前的延迟

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

unit - 时间单位

task - 被执行的任务

scheduleAtFixedRateWithTryCatch

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

任务添加 try catch ，避免 scheduleAtFixedRate 方法在调度任务出现异常后会终止调度

schedule

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

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

参数:

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

unit - 时间单位

task - 被执行任务

schedule

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

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

参数:

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

unit - 时间单位

task - 被执行任务

shutdown

public static void shutdown()

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

shutdownNow

public static void shutdownNow()

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

awaitTermination

public static boolean awaitTermination(long timeout,
                                       TimeUnit unit)
                                throws InterruptedException

在 shutdown 线程池之后，阻塞等待所有任务执行完，或发生超时，或当前线程中断，以先发生者为准

抛出:

InterruptedException