org.nutz.lang

类 Tasks

java.lang.Object

org.nutz.lang.Tasks

public abstract class Tasks
extends java.lang.Object

定时任务服务的友好封装

构造器概要

构造器

构造器和说明
Tasks()

方法概要

限定符和类型	方法和说明
static void	depose() 关闭定时任务服务 系统关闭时可调用此方法终止正在执行的定时任务，一旦关闭后不允许再向线程池中添加任务，否则会报RejectedExecutionException异常
static java.util.concurrent.ScheduledThreadPoolExecutor	getTaskScheduler() 返回定时任务线程池，可做更高级的应用
static void	reset() 重启动定时任务服务
static void	resizeThreadPool(int threadPoolSize) 调整线程池大小
static void	scheduleAtFixedRate(java.lang.Runnable task, java.util.Date startTime, long period, java.util.concurrent.TimeUnit unit) 在指定的时间点开始以固定的频率运行任务。
static java.util.concurrent.ScheduledFuture<?>	scheduleAtFixedRate(java.lang.Runnable task, long periodSeconds) 立即启动，并以固定的频率来运行任务。
static java.util.concurrent.ScheduledFuture<?>	scheduleAtFixedRate(java.lang.Runnable task, long initialDelay, long periodSeconds, java.util.concurrent.TimeUnit unit) 在指定的延时之后开始以固定的频率来运行任务。
static void	scheduleAtFixedRate(java.lang.Runnable task, java.lang.String startTime, long period, java.util.concurrent.TimeUnit unit) 在指定的时间点开始以固定的频率运行任务。
static void	scheduleAtFixedTime(java.lang.Runnable task, java.util.Date startTime) 在指定的时间点启动任务只运行一次
static void	scheduleAtFixedTime(java.lang.Runnable task, java.lang.String expression) 在符合条件的时间点启动任务
static void	scheduleWithFixedDelay(java.lang.Runnable task, java.util.Date startTime, long period, java.util.concurrent.TimeUnit unit) 在指定的时间点启动，两次任务间保持固定的时间间隔
static java.util.concurrent.ScheduledFuture<?>	scheduleWithFixedDelay(java.lang.Runnable task, long periodSeconds) 立即启动，两次任务间保持固定的时间间隔
static java.util.concurrent.ScheduledFuture<?>	scheduleWithFixedDelay(java.lang.Runnable task, long initialDelay, long period, java.util.concurrent.TimeUnit unit) 在指定的延时之后启动，两次任务间保持固定的时间间隔
static void	scheduleWithFixedDelay(java.lang.Runnable task, java.lang.String startTime, long period, java.util.concurrent.TimeUnit unit) 在指定的时间点启动，两次任务间保持固定的时间间隔

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

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

构造器详细资料

Tasks

public Tasks()

方法详细资料

scheduleAtFixedRate

public static java.util.concurrent.ScheduledFuture<?> scheduleAtFixedRate(java.lang.Runnable task,
                                                                          long periodSeconds)

立即启动，并以固定的频率来运行任务。后续任务的启动时间不受前次任务延时影响。

参数:

task - 具体待执行的任务

periodSeconds - 每次执行任务的间隔时间(单位秒)

scheduleAtFixedRate

public static java.util.concurrent.ScheduledFuture<?> scheduleAtFixedRate(java.lang.Runnable task,
                                                                          long initialDelay,
                                                                          long periodSeconds,
                                                                          java.util.concurrent.TimeUnit unit)

在指定的延时之后开始以固定的频率来运行任务。后续任务的启动时间不受前次任务延时影响。

参数:

task - 具体待执行的任务

initialDelay - 首次执行任务的延时时间

periodSeconds - 每次执行任务的间隔时间(单位秒)

unit - 时间单位

scheduleAtFixedRate

public static void scheduleAtFixedRate(java.lang.Runnable task,
                                       java.lang.String startTime,
                                       long period,
                                       java.util.concurrent.TimeUnit unit)
                                throws java.text.ParseException

在指定的时间点开始以固定的频率运行任务。后续任务的启动时间不受前次任务延时影响。

参数:

task - 具体待执行的任务

startTime - 首次运行的时间点,支持 "yyyy-MM-dd HH:mm:ss" 格式

period - 每次执行任务的间隔时间

unit - 时间单位

抛出:

java.text.ParseException

scheduleAtFixedRate

public static void scheduleAtFixedRate(java.lang.Runnable task,
                                       java.util.Date startTime,
                                       long period,
                                       java.util.concurrent.TimeUnit unit)

在指定的时间点开始以固定的频率运行任务。后续任务的启动时间不受前次任务延时影响。

参数:

task - 具体待执行的任务

startTime - 首次运行的时间点

period - 每次执行任务的间隔时间

unit - 时间单位

scheduleWithFixedDelay

public static java.util.concurrent.ScheduledFuture<?> scheduleWithFixedDelay(java.lang.Runnable task,
                                                                             long periodSeconds)

立即启动，两次任务间保持固定的时间间隔

参数:

task - 具体待执行的任务

periodSeconds - 两次任务的间隔时间(单位秒)

scheduleWithFixedDelay

public static java.util.concurrent.ScheduledFuture<?> scheduleWithFixedDelay(java.lang.Runnable task,
                                                                             long initialDelay,
                                                                             long period,
                                                                             java.util.concurrent.TimeUnit unit)

在指定的延时之后启动，两次任务间保持固定的时间间隔

参数:

task - 具体待执行的任务

initialDelay - 首次执行任务的延时时间

period - 两次任务的间隔时间(单位秒)

unit - 时间单位

scheduleWithFixedDelay

public static void scheduleWithFixedDelay(java.lang.Runnable task,
                                          java.lang.String startTime,
                                          long period,
                                          java.util.concurrent.TimeUnit unit)
                                   throws java.text.ParseException

在指定的时间点启动，两次任务间保持固定的时间间隔

参数:

task - 具体待执行的任务

startTime - 首次运行的时间点,支持 "yyyy-MM-dd HH:mm:ss" 格式

period - 两次任务的间隔时间

unit - 时间单位

抛出:

java.text.ParseException

scheduleWithFixedDelay

public static void scheduleWithFixedDelay(java.lang.Runnable task,
                                          java.util.Date startTime,
                                          long period,
                                          java.util.concurrent.TimeUnit unit)

在指定的时间点启动，两次任务间保持固定的时间间隔

参数:

task - 具体待执行的任务

startTime - 首次运行的时间点

period - 两次任务的间隔时间

unit - 时间单位

scheduleAtFixedTime

public static void scheduleAtFixedTime(java.lang.Runnable task,
                                       java.util.Date startTime)

在指定的时间点启动任务只运行一次

参数:

task - 具体待执行的任务

startTime - 运行的时间点

scheduleAtFixedTime

public static void scheduleAtFixedTime(java.lang.Runnable task,
                                       java.lang.String expression)

在符合条件的时间点启动任务

参数:

task - 具体待执行的任务

expression - 运行的时间点

resizeThreadPool

public static void resizeThreadPool(int threadPoolSize)

调整线程池大小

参数:

threadPoolSize - 线程池大小

getTaskScheduler

public static java.util.concurrent.ScheduledThreadPoolExecutor getTaskScheduler()

返回定时任务线程池，可做更高级的应用

返回:

当前的线程池

depose

public static void depose()

关闭定时任务服务

系统关闭时可调用此方法终止正在执行的定时任务，一旦关闭后不允许再向线程池中添加任务，否则会报RejectedExecutionException异常

reset

public static void reset()

重启动定时任务服务