zoukankan      html  css  js  c++  java
  • quartz 关联多个JobDetail和SimpleTrigger多任务调度

    import java.util.Date;
    
    import org.quartz.JobDetail;
    
    import org.quartz.Scheduler;
    
    import org.quartz.SchedulerFactory;
    
    import org.quartz.SimpleTrigger;
    
    import org.quartz.impl.StdSchedulerFactory;
    
    public class SimpleTriggerRunner {
    
    	public static void main(String args[]) {
    
    		try {
    
    			// ①创建一个JobDetail实例,指定SimpleJob
    
    			JobDetail jobDetail1 = new JobDetail("job1_1", "jGroup1",
    					SimpleJob.class);
    
    			// ②通过SimpleTrigger定义调度规则:马上启动,每2秒运行一次,共运行100次
    
    			SimpleTrigger simpleTrigger1 = new SimpleTrigger("trigger1_1",
    					"tgroup1");
    
    			simpleTrigger1.setStartTime(new Date());
    
    			simpleTrigger1.setRepeatInterval(1000);
    
    			simpleTrigger1.setRepeatCount(SimpleTrigger.REPEAT_INDEFINITELY);
    			
    			
    			// ①创建一个JobDetail实例,指定SimpleJob
    
    			JobDetail jobDetail2 = new JobDetail("job1_2", "jGroup2",
    					DemoJob.class);
    
    			// ②通过SimpleTrigger定义调度规则:马上启动,每2秒运行一次,共运行100次
    
    			SimpleTrigger simpleTrigger2 = new SimpleTrigger("trigger1_2",
    					"tgroup2");
    
    			simpleTrigger2.setStartTime(new Date());
    
    			simpleTrigger2.setRepeatInterval(3000);
    
    			simpleTrigger2.setRepeatCount(SimpleTrigger.REPEAT_INDEFINITELY);
    
    			// ③通过SchedulerFactory获取一个调度器实例
    
    			SchedulerFactory schedulerFactory = new StdSchedulerFactory();
    
    			Scheduler scheduler = schedulerFactory.getScheduler();
    
    			scheduler.scheduleJob(jobDetail1, simpleTrigger1);// ④ 注册并进行调度
    			scheduler.scheduleJob(jobDetail2, simpleTrigger2);// ④ 注册并进行调度
    
    			scheduler.start();// ⑤调度启动
    
    		} catch (Exception e) {
    
    			e.printStackTrace();
    
    		}
    
    	}
    
    }
    //===============================================
    import java.util.Date;
    
    import org.quartz.Job;
    
    import org.quartz.JobExecutionContext;
    
    import org.quartz.JobExecutionException;
    
    public class SimpleJob implements Job {
    
    	// ①实例Job接口方法
    
    	public void execute(JobExecutionContext jobCtx)
    			throws JobExecutionException {
    
    		System.out.println(jobCtx.getTrigger().getName()
    				+ " triggered. time is:" + (new Date()));
    
    	}
    
    }
  • 相关阅读:
    JAVA程序操作hbase的Maven配置pom.xml文件
    windows下部署icescrum
    第一次博客作业——简单介绍一下自己
    2019寒假训练营第三次作业
    网络空间安全概论第5单元笔记
    2019寒假训练营第二次作业
    网络空间安全概论1、4单元笔记
    2019寒假训练营第一次作业
    软工实践个人总结
    第4次作业-结对编程之实验室程序实现
  • 原文地址:https://www.cnblogs.com/vaer/p/4754000.html
Copyright © 2011-2022 走看看