Quartz管理类
package com.sihuatech.project.task.manager;import java.text.parseexception;import org.quartz.crontrigger;import org.quartz.job;import org.quartz.jobdetail;import org.quartz.scheduler;import org.quartz.schedulerexception;import org.quartz.schedulerfactory;import org.quartz.trigger;import org.quartz.impl.stdschedulerfactory;/** * @title:quartz管理类 ** @description: ** @copyright: * @author lei 2008-10-8 14:19:01 * @version 1.00.000 **/public class quartzmanager {private static schedulerfactory sf = new stdschedulerfactory();private static string job_group_name = "group1";private static string trigger_group_name = "trigger1";private static quartzmanager quartzmanager;public static quartzmanager getinstance() {if (quartzmanager == null) {quartzmanager = new quartzmanager();}return quartzmanager;}private quartzmanager() {}/** * 添加一个定时任务，使用默认的任务组名，触发器名，触发器组名 ** @param jobname * 任务名 * @param job * 任务 * @param time * 时间设置，参考quartz说明文档 * @throws schedulerexception * @throws parseexception */public static void addjob(string jobname, job job, string time) throws schedulerexception, parseexception {scheduler sched = sf.getscheduler();jobdetail jobdetail = new jobdetail(jobname, job_group_name, job.getclass());// 任务名，任务组，任务执行类// 触发器crontrigger trigger = new crontrigger(jobname, trigger_group_name);// 触发器名,触发器组trigger.setcronexpression(time);// 触发器时间设定sched.schedulejob(jobdetail, trigger);// 启动if (!sched.isshutdown())sched.start();}/** * 添加一个定时任务 ** @param jobname * 任务名 * @param jobgroupname * 任务组名 * @param triggername * 触发器名 * @param triggergroupname * 触发器组名 * @param job * 任务 * @param time * 时间设置，参考quartz说明文档 * @throws schedulerexception * @throws parseexception */public static void addjob(string jobname, string jobgroupname, string triggername, string triggergroupname, job job, string time) throws schedulerexception, parseexception {scheduler sched = sf.getscheduler();jobdetail jobdetail = new jobdetail(jobname, jobgroupname, job.getclass());// 任务名，任务组，任务执行类// 触发器crontrigger trigger = new crontrigger(triggername, triggergroupname);// 触发器名,触发器组trigger.setcronexpression(time);// 触发器时间设定sched.schedulejob(jobdetail, trigger);if (!sched.isshutdown())sched.start();}/** * 修改一个任务的触发时间(使用默认的任务组名，触发器名，触发器组名) ** @param jobname * @param time * @throws schedulerexception * @throws parseexception */public static void modifyjobtime(string jobname, string time) throws schedulerexception, parseexception {scheduler sched = sf.getscheduler();trigger trigger = sched.gettrigger(jobname, trigger_group_name);if (trigger != null) {crontrigger ct = (crontrigger) trigger;ct.setcronexpression(time);sched.resumetrigger(jobname, trigger_group_name);}}/** * 修改一个任务的触发时间 ** @param triggername * @param triggergroupname * @param time * @throws schedulerexception * @throws parseexception */public static void modifyjobtime(string triggername, string triggergroupname, string time) throws schedulerexception, parseexception {scheduler sched = sf.getscheduler();trigger trigger = sched.gettrigger(triggername, triggergroupname);if (trigger != null) {crontrigger ct = (crontrigger) trigger;// 修改时间ct.setcronexpression(time);// 重启触发器sched.resumetrigger(triggername, triggergroupname);}}/** * 移除一个任务(使用默认的任务组名，触发器名，触发器组名) ** @param jobname * @throws schedulerexception */public static void removejob(string jobname) throws schedulerexception {scheduler sched = sf.getscheduler();sched.pausetrigger(jobname, trigger_group_name);// 停止触发器sched.unschedulejob(jobname, trigger_group_name);// 移除触发器sched.deletejob(jobname, job_group_name);// 删除任务}/** * 移除一个任务 ** @param jobname * @param jobgroupname * @param triggername * @param triggergroupname * @throws schedulerexception */public static void removejob(string jobname, string jobgroupname, string triggername, string triggergroupname) throws schedulerexception {scheduler sched = sf.getscheduler();sched.pausetrigger(triggername, triggergroupname);// 停止触发器sched.unschedulejob(triggername, triggergroupname);// 移除触发器sched.deletejob(jobname, jobgroupname);// 删除任务}}
页:
[1]