Quartz 线程处理.doc

Quartz 线程处理Quartz定时任务默认都是并发执行的，不会等待上一次任务执行完毕，只要间隔时间到就会执行, 如果定时任执行太长，会长时间占用资源，导致其它任务堵塞。1.在Spring中这时需要设置concurrent的值为false, 禁止并发执行。12.当不使用spring的时候就需要在Job的实现类上加DisallowConcurrentExecution的注释DisallowConcurrentExecution 禁止并发执行多个相同定义的JobDetail, 这个注解是加在Job类上的, 但意思并不是不能同时执行多个Job, 而是不能并发执行同一个Job Definition(由JobDetail定义), 但是可以同时执行多个不同的JobDetail, 举例说明,我们有一个Job类,叫做SayHelloJob, 并在这个Job上加了这个注解, 然后在这个Job上定义了很多个JobDetail, 如sayHelloToJoeJobDetail, sayHelloToMikeJobDetail, 那么当scheduler启动时, 不会并发执行多个sayHelloToJoeJobDetail或者sayHelloToMikeJobDetail, 但可以同时执行sayHelloToJoeJobDetail跟sayHelloToMikeJobDetailPersistJobDataAfterExecution 同样, 也是加在Job上,表示当正常执行完Job后, JobDataMap中的数据应该被改动, 以被下一次调用时用。当使用PersistJobDataAfterExecution 注解时, 为了避免并发时, 存储数据造成混乱, 强烈建议把DisallowConcurrentExecution注解也加上。DisallowConcurrentExecution此标记用在实现Job的类上面,意思是不允许并发执行,按照我之前的理解是 不允许调度框架在同一时刻调用Job类，后来经过测试发现并不是这样，而是Job(任务)的执行时间比如需要10秒大于任务的时间间隔 Interval（5秒),那么默认情况下,调度框架为了能让 任务按照我们预定的时间间隔执行,会马上启用新的线程执行任务。否则的话会等待任务执行完毕以后 再重新执行！（这样会导致任务的执行不是按照我们预先定义的时间间隔执行）测试代码，这是官方提供的例子。设定的时间间隔为3秒,但job执行时间是5秒,设置DisallowConcurrentExecution以后程序会等任务执行完毕以后再去执行,否则会在3秒时再启用新的线程执行1org.quartz.threadPool.threadCount =5 这里配置框架的线程池中线程的数量,要多配置几个,否则DisallowConcurrentExecution不起作用?123org.quartz.scheduler.instanceName = MySchedulerorg.quartz.threadPool.threadCount =5org.quartz.jobStore.class =org.quartz.simpl.RAMJobStore?123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596/* Copyright 2005 - 2009 Terracotta, Inc.* Licensed under the Apache License, Version 2.0 (the License); you may not* use this file except in compliance with the License. You may obtain a copy* of the License at* /licenses/LICENSE-2.0* Unless required by applicable law or agreed to in writing, software* distributed under the License is distributed on an AS IS BASIS, WITHOUT* WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the* License for the specific language governing permissions and limitations* under the License.*/package org.quartz.examples.example5;import java.util.Date;import org.quartz.DisallowConcurrentExecution;import org.quartz.Job;import org.quartz.JobDataMap;import org.quartz.JobExecutionContext;import org.quartz.JobExecutionException;import org.quartz.PersistJobDataAfterExecution;/* A dumb implementation of Job, for unit testing purposes. * author James House*/PersistJobDataAfterExecutionDisallowConcurrentExecutionpublic class StatefulDumbJob implements Job /* * Constants.* */public static final String NUM_EXECUTIONS = NumExecutions;public static final String EXECUTION_DELAY = ExecutionDelay;/* * Constructors.* */public StatefulDumbJob() /* * Interface.* */* Called by the link org.quartz.Scheduler when a link org.quartz.Trigger fires that is associated with the Job. * throws JobExecutionException if there is an exception while executing the job.*/public void execute(JobExecutionContext context)throws JobExecutionException System.err.println(- + context.getJobDetail().getKey() + executing. +new Date() +);JobDataMap map = context.getJobDetail().getJobDataMap();int executeCount =0;if (map.containsKey(NUM_EXECUTIONS) executeCount = map.getInt(NUM_EXECUTIONS);executeCount+;map.put(NUM_EXECUTIONS, executeCount);long delay = 5000l;if (map.containsKey(EXECUTION_DELAY) delay = map.getLong(EXECUTION_DELAY);try Thread.sleep(delay);catch (Exception ignore) System.err.println( - + context.getJobDetail().getKey() + complete ( + executeCount +).);123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100/* Copyright 2005 - 2009 Terracotta, Inc.* Licensed under the Apache License, Version 2.0 (the License); you may not* use this file except in compliance with the License. You may obtain a copy* of the License at* /licenses/LICENSE-2.0* Unless required by applicable law or agreed to in writing, software* distributed under the License is distributed on an AS IS BASIS, WITHOUT* WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the* License for the specific language governing permissions and limitations* under the License.*/package org.quartz.examples.example5;import static org.quartz.JobBuilder.newJob;import static org.quartz.SimpleScheduleBuilder.simpleSchedule;import static org.quartz.TriggerBuilder.newTrigger;import static org.quartz.DateBuilder.*;import java.util.Date;import org.quartz.JobDetail;import org.quartz.Scheduler;import org.quartz.SchedulerFactory;import org.quartz.SchedulerMetaData;import org.quartz.SimpleTrigger;import org.quartz.impl.StdSchedulerFactory;import org.slf4j.Logger;import org.slf4j.LoggerFactory;/* Demonstrates the behavior of StatefulJobs, as well as how misfire instructions affect the firings of triggers of StatefulJob s - when the jobs take longer to execute that the frequency of the triggers repitition.* While the example is running, you should note that there are two triggers with identical schedules, firing identical jobs. The triggers want to fire every 3 seconds, but the jobs take 10 seconds to execute. Therefore, by the time the jobs complete their execution, the triggers have already misfired (unless the schedulers misfire threshold has been set to more than 7 seconds). You should see that one of the jobs has its misfire instruction set to SimpleTrigger.MISFIRE_INSTRUCTION_RESCHEDULE_NOW_WITH_EXISTING_REPEAT_COUNT, which causes it to fire immediately, when the misfire is detected. The other trigger uses the default smart policy misfire instruction, which causes the trigger to advance to its next fire time (skipping those that it has missed) - so that it does not refire immediately, but rather at the next scheduled time. * author Chris Bonham*/public class MisfireExample public void run()throws Exception Logger log = LoggerFactory.getLogger(MisfireExample.class);(- Initializing -);/ First we must get a reference to a schedulerSchedulerFactory sf =new StdSchedulerFactory();Scheduler sched = sf.getScheduler();(- Initialization Complete -);(- Scheduling Jobs -);/ jobs can be scheduled before start() has been called/ get a nice round time a few seconds in the future.Date startTime = nextGivenSecondDate(null,15);/ statefulJob1 will run every three seconds/ (but it will delay for ten seconds)JobDetail job = newJob(StatefulDumbJob.class).withIdentity(statefulJob1,group1).usingJobData(StatefulDumbJob.EXECUTION_DELAY, 10000L).build();SimpleTrigger trigger = newTrigger().withIdentity(trigger1,group1).startAt(startTime).withSchedule(simpleSchedule().withIntervalInSeconds(3).repeatForever().build();Date ft = sched.scheduleJob(job, trigger);(job.getKey() + will run at: + ft + and repeat: + trigger.getRepeatCount() + times, every + trigger.getRepeatInterval() /1000 + seconds);(- Starting Scheduler -);/ jobs dont start firing until start() has been called.sched.start();(- Started Scheduler -);try / sleep for ten minutes for triggers to file.Thread.sleep(600L * 1000L);catch (Exception e) (- Shutting Down -);sched.shutdown(true);(- Shutdown Complete -);SchedulerMetaData metaData = sched.getMetaData();(Executed + metaData.getNumberOfJobsExecuted() + jobs.);public static void main(String args)throws Exception MisfireExample example =new MisfireExample();example.run();PersistJobDataAfterExecution此标记说明在执行完Job的execution方法后保存JobDataMap当中固定数据,在默认情况下 也就是没有设置PersistJobDataAfterExecution的时候 每个job都拥有独立JobDataMap否则改任务在重复执行的时候具有相同的JobDataMap123456789101112131415161718192021222324252627282930313233343536373839404142434445464748/* Copyright 2005 - 2009 Terracotta, Inc.* Licensed under the Apache License, Version 2.0 (the License); you may not* use this file except in compliance with the License. You may obtain a copy* of the License at* /licenses/LICENSE-2.0* Unless required by applicable law or agreed to in writing, software* distributed under the License is distributed on an AS IS BASIS, WITHOUT* WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the* License for the specific language governing permissions and limitations* under the License.*/package com.quartz.demo.example6;import java.util.Date;import org.quartz.DisallowConcurrentExecution;import org.quartz.Job;import org.quartz.JobDataMap;import org.quartz.JobExecutionContext;import org.quartz.JobExecutionException;import org.quartz.JobKey;import org.quartz.PersistJobDataAfterExecution;PersistJobDataAfterExecutionDisallowConcurrentExecutionpublic class BadJob1implements Job public BadJob1() public void execute(JobExecutionContext context)throws JobExecutionException JobKey jobKey = context.getJobDetail().getKey();JobDataMap dataMap = context.getJobDetail().getJobDataMap();int denominator = dataMap.getInt(denominator);System.out.println(- + jobKey + executing at +new Date() + with denominator + denominator);denominator+;dataMap.put(denominator, denominator);1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980/* Copyright 2005 - 2009 Terracotta, Inc.* Licensed under the Apache License, Version 2.0 (the License); you may not* use this file except in compliance with the License. You may obtain a copy* of the License at* /licenses/LICENSE-2.0* Unless required by applicable law or agreed to in writing, software* distributed under the License is distributed on an AS IS BASIS, WITHOUT* WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the* License for the specific language governing permissions and limitations* under the License.*/package com.quartz.demo.example6;import static org.quartz.JobBuilder.newJob;import static org.quartz.SimpleScheduleBuilder.simpleSchedule;import static org.quartz.TriggerBuilder.newTrigger;import static org.quartz.DateBuilder.*;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 JobExceptionExample public void run()throws Exception / First we must get a reference to a schedulerSchedulerFactory sf =new StdSchedulerFactory();Scheduler sched = sf.g