cn.dceast.platform.task.quartz

类 SchedulerUtil

java.lang.Object

cn.dceast.platform.task.quartz.SchedulerUtil

public class SchedulerUtil
extends Object

字段概要

字段

限定符和类型	字段和说明
static String	JOB_DATAMAP

构造器概要

构造器

构造器和说明
SchedulerUtil()

方法概要

限定符和类型	方法和说明
static org.quartz.JobDetail	addJob(JobEntity job) 新增job
static void	addJobListener(org.quartz.JobListener jobListener)
static void	addSchedulerListener(org.quartz.SchedulerListener schedulerListener)
static boolean	checkExists(String jobGroup, String jobName) 检查job是否存在
static void	clear() 删除所有job包括job的执行数据
static void	executeJobImmediatelyWithParams(String jobId, String jobParam) 代参数执行job
static JobExecutedEntity	getJob(String jobGroup, String jobName)
static List<JobExecutedEntity>	getJobs() 获取所有的job清单
static String	getSchedulerInstanceId()
static void	init() 初始化任务调度容器
static void	pauseAll() 暂停所有job执行
static void	pauseJob(String jobId) 暂停job执行
static void	removeJob(String jobId, String action) 根据jobId删除job
static void	removeJob(String groupName, String jobName, String action) 根据groupName和jobName删除job
static void	removeJobAfterAddJobFail(String jobGroup, String jobName) 删除job
static void	resumeAll() 恢复所有的job执行
static void	resumeJob(String jobId) 恢复job执行
static void	shutdown() 停止job容器。
static void	start() 启动job容器
static void	unSchedulerJob(String jobGroup, String jobName)
static void	updateJob(JobEntity job) 更新job 更新job将会删除旧的job，重新生成新的job

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

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

字段详细资料

JOB_DATAMAP

public static final String JOB_DATAMAP

另请参阅:

常量字段值

构造器详细资料

SchedulerUtil

public SchedulerUtil()

方法详细资料

init

public static void init()

初始化任务调度容器

start

public static void start()

启动job容器

shutdown

public static void shutdown()

停止job容器。此方法在所有job执行结束之前一直阻塞。

addJob

public static org.quartz.JobDetail addJob(JobEntity job)

新增job

参数:

job - job

返回:

JobDetail

updateJob

public static void updateJob(JobEntity job)

更新job 更新job将会删除旧的job，重新生成新的job

参数:

job - job

checkExists

public static boolean checkExists(String jobGroup,
                                  String jobName)

检查job是否存在

参数:

jobGroup - job分组

jobName - job名称

返回:

true-job存在；false-job不存在；

removeJob

public static void removeJob(String jobId,
                             String action)

根据jobId删除job

参数:

jobId - jobId

action - action

removeJob

public static void removeJob(String groupName,
                             String jobName,
                             String action)

根据groupName和jobName删除job

参数:

groupName - groupName

jobName - jobName

action - action

removeJobAfterAddJobFail

public static void removeJobAfterAddJobFail(String jobGroup,
                                            String jobName)

删除job

参数:

jobGroup - jobGroup

jobName - jobName

pauseJob

public static void pauseJob(String jobId)

暂停job执行

参数:

jobId - jobId

pauseAll

public static void pauseAll()

暂停所有job执行

resumeJob

public static void resumeJob(String jobId)

恢复job执行

参数:

jobId - jobId

resumeAll

public static void resumeAll()

恢复所有的job执行

executeJobImmediatelyWithParams

public static void executeJobImmediatelyWithParams(String jobId,
                                                   String jobParam)

代参数执行job

参数:

jobId - jobId

jobParam - jobParam

clear

public static void clear()

删除所有job包括job的执行数据

getJobs

public static List<JobExecutedEntity> getJobs()

获取所有的job清单

返回:

List

getJob

public static JobExecutedEntity getJob(String jobGroup,
                                       String jobName)

addSchedulerListener

public static void addSchedulerListener(org.quartz.SchedulerListener schedulerListener)

addJobListener

public static void addJobListener(org.quartz.JobListener jobListener)

unSchedulerJob

public static void unSchedulerJob(String jobGroup,
                                  String jobName)

getSchedulerInstanceId

public static String getSchedulerInstanceId()