public class HelloWorldMain {     Log log = LogFactory.getLog(HelloWorldMain.class);           public void run() {         try {             //取得Schedule对象             SchedulerFactory sf = new StdSchedulerFactory();             Scheduler sch = sf.getScheduler();                            JobDetail jd = new JobDetail("HelloWorldJobDetail",Scheduler.DEFAULT_GROUP,HelloWorldJob.class);             Trigger tg = TriggerUtils.makeMinutelyTrigger(1);             tg.setName("HelloWorldTrigger");                           sch.scheduleJob(jd, tg);             sch.start();         } catch ( Exception e ) {             e.printStackTrace();                       }     }     public static void main(String[] args) {         HelloWorldMain hw = new HelloWorldMain();         hw.run();     } }

public Scheduler getScheduler() throws SchedulerException {         if (cfg == null) {             initialize();         }         SchedulerRepository schedRep = SchedulerRepository.getInstance();         //从"调度器仓库"中根据properties的SchedulerName配置获取一个调度器实例         Scheduler sched = schedRep.lookup(getSchedulerName());         if (sched != null) {             if (sched.isShutdown()) {                 schedRep.remove(getSchedulerName());             } else {                 return sched;             }         }         //初始化调度器         sched = instantiate();         return sched;     }

public void initialize(ClassLoadHelper loadHelper,             SchedulerSignaler signaler) throws SchedulerConfigException {         if (dsName == null) {             throw new SchedulerConfigException("DataSource name not set.");         }         classLoadHelper = loadHelper;         if(isThreadsInheritInitializersClassLoadContext()) {             log.info("JDBCJobStore threads will inherit ContextClassLoader of thread: " + Thread.currentThread().getName());             initializersLoader = Thread.currentThread().getContextClassLoader();         }                   this.schedSignaler = signaler;         // If the user hasn't specified an explicit lock handler, then         // choose one based on CMT/Clustered/UseDBLocks.         if (getLockHandler() == null) {                           // If the user hasn't specified an explicit lock handler,             // then we *must* use DB locks with clustering             if (isClustered()) {                 setUseDBLocks(true);             }                           if (getUseDBLocks()) {                 if(getDriverDelegateClass() != null && getDriverDelegateClass().equals(MSSQLDelegate.class.getName())) {                     if(getSelectWithLockSQL() == null) {                         //读取数据库LOCKS表中对应当前调度器的锁信息                         String msSqlDflt = "SELECT * FROM {0}LOCKS WITH (UPDLOCK,ROWLOCK) WHERE " + COL_SCHEDULER_NAME + " = {1} AND LOCK_NAME = ?";                         getLog().info("Detected usage of MSSQLDelegate class - defaulting 'selectWithLockSQL' to '" + msSqlDflt + "'.");                         setSelectWithLockSQL(msSqlDflt);                     }                 }                 getLog().info("Using db table-based data access locking (synchronization).");                 setLockHandler(new StdRowLockSemaphore(getTablePrefix(), getInstanceName(), getSelectWithLockSQL()));             } else {                 getLog().info(                     "Using thread monitor-based data access locking (synchronization).");                 setLockHandler(new SimpleSemaphore());             }         }     }

public void start() throws SchedulerException {         if (shuttingDown|| closed) {             throw new SchedulerException(                     "The Scheduler cannot be restarted after shutdown() has been called.");         }         // QTZ-212 : calling new schedulerStarting() method on the listeners         // right after entering start()         //通知该调度器的listener启动开始         notifySchedulerListenersStarting();         if (initialStart == null) {             initialStart = new Date();             //启动调度器的线程             this.resources.getJobStore().schedulerStarted();                         //启动plugins             startPlugins();         } else {             resources.getJobStore().schedulerResumed();         }         schedThread.togglePause(false);         getLog().info(                 "Scheduler " + resources.getUniqueIdentifier() + " started.");         //通知该调度器的listener启动完成         notifySchedulerListenersStarted();     }

public List<OperableTrigger> acquireNextTriggers(final long noLaterThan, final int maxCount, final long timeWindow)         throws JobPersistenceException {                   String lockName;         if(isAcquireTriggersWithinLock() || maxCount > 1) {             lockName = LOCK_TRIGGER_ACCESS;         } else {             lockName = null;         }         return executeInNonManagedTXLock(lockName,                 new TransactionCallback<List<OperableTrigger>>() {                     public List<OperableTrigger> execute(Connection conn) throws JobPersistenceException {                         return acquireNextTrigger(conn, noLaterThan, maxCount, timeWindow);                     }                 },                 new TransactionValidator<List<OperableTrigger>>() {                     public Boolean validate(Connection conn, List<OperableTrigger> result) throws JobPersistenceException {                         //...异常处理回调方法                     }                 });     }

public List<TriggerFiredResult> triggersFired(final List<OperableTrigger> triggers) throws JobPersistenceException {         return executeInNonManagedTXLock(LOCK_TRIGGER_ACCESS,                 new TransactionCallback<List<TriggerFiredResult>>() {                     public List<TriggerFiredResult> execute(Connection conn) throws JobPersistenceException {                         List<TriggerFiredResult> results = new ArrayList<TriggerFiredResult>();                         TriggerFiredResult result;                         for (OperableTrigger trigger : triggers) {                             try {                               TriggerFiredBundle bundle = triggerFired(conn, trigger);                               result = new TriggerFiredResult(bundle);                             } catch (JobPersistenceException jpe) {                                 result = new TriggerFiredResult(jpe);                             } catch(RuntimeException re) {                                 result = new TriggerFiredResult(re);                             }                             results.add(result);                         }                         return results;                     }                 },                 new TransactionValidator<List<TriggerFiredResult>>() {                     @Override                     public Boolean validate(Connection conn, List<TriggerFiredResult> result) throws JobPersistenceException {                         //...异常处理回调方法                     }                 });     }

protected TriggerFiredBundle triggerFired(Connection conn,             OperableTrigger trigger)         throws JobPersistenceException {         JobDetail job;         Calendar cal = null;         // Make sure trigger wasn't deleted, paused, or completed...         try { // if trigger was deleted, state will be STATE_DELETED             String state = getDelegate().selectTriggerState(conn,                     trigger.getKey());             if (!state.equals(STATE_ACQUIRED)) {                 return null;             }         } catch (SQLException e) {             throw new JobPersistenceException("Couldn't select trigger state: "                     + e.getMessage(), e);         }         try {             job = retrieveJob(conn, trigger.getJobKey());             if (job == null) { return null; }         } catch (JobPersistenceException jpe) {             try {                 getLog().error("Error retrieving job, setting trigger state to ERROR.", jpe);                 getDelegate().updateTriggerState(conn, trigger.getKey(),                         STATE_ERROR);             } catch (SQLException sqle) {                 getLog().error("Unable to set trigger state to ERROR.", sqle);             }             throw jpe;         }         if (trigger.getCalendarName() != null) {             cal = retrieveCalendar(conn, trigger.getCalendarName());             if (cal == null) { return null; }         }         try {             getDelegate().updateFiredTrigger(conn, trigger, STATE_EXECUTING, job);         } catch (SQLException e) {             throw new JobPersistenceException("Couldn't insert fired trigger: "                     + e.getMessage(), e);         }         Date prevFireTime = trigger.getPreviousFireTime();         // call triggered - to update the trigger's next-fire-time state...         trigger.triggered(cal);         String state = STATE_WAITING;         boolean force = true;                   if (job.isConcurrentExectionDisallowed()) {             state = STATE_BLOCKED;             force = false;             try {                 getDelegate().updateTriggerStatesForJobFromOtherState(conn, job.getKey(),                         STATE_BLOCKED, STATE_WAITING);                 getDelegate().updateTriggerStatesForJobFromOtherState(conn, job.getKey(),                         STATE_BLOCKED, STATE_ACQUIRED);                 getDelegate().updateTriggerStatesForJobFromOtherState(conn, job.getKey(),                         STATE_PAUSED_BLOCKED, STATE_PAUSED);             } catch (SQLException e) {                 throw new JobPersistenceException(                         "Couldn't update states of blocked triggers: "                                 + e.getMessage(), e);             }         }                       if (trigger.getNextFireTime() == null) {             state = STATE_COMPLETE;             force = true;         }         storeTrigger(conn, trigger, job, true, state, force, false);         job.getJobDataMap().clearDirtyFlag();         return new TriggerFiredBundle(job, trigger, cal, trigger.getKey().getGroup()                 .equals(Scheduler.DEFAULT_RECOVERY_GROUP), new Date(), trigger                 .getPreviousFireTime(), prevFireTime, trigger.getNextFireTime());     }

3. select TRIGGER_ACCESS from QRTZ2_LOCKS for update 4. SELECT TRIGGER_NAME, TRIGGER_GROUP, NEXT_FIRE_TIME, PRIORITY FROM QRTZ2_TRIGGERS WHERE SCHEDULER_NAME = 'CRMscheduler' AND TRIGGER_STATE = 'ACQUIRED' AND NEXT_FIRE_TIME <= '{timekey 30s latter}' AND ( MISFIRE_INSTR = -1 OR ( MISFIRE_INSTR != -1 AND NEXT_FIRE_TIME >= '{timekey now}' ) ) ORDER BY NEXT_FIRE_TIME ASC, PRIORITY DESC; 5. SELECT * FROM QRTZ2_JOB_DETAILS WHERE SCHEDULER_NAME = CRMscheduler AND JOB_NAME = ? AND JOB_GROUP = ?; 6. UPDATE TQRTZ2_TRIGGERS SET TRIGGER_STATE = 'ACQUIRED' WHERE SCHED_NAME = 'CRMscheduler' AND TRIGGER_NAME = '{triggerName}' AND TRIGGER_GROUP = '{triggerGroup}' AND TRIGGER_STATE = 'waiting'; 7. INSERT INTO QRTZ2_FIRED_TRIGGERS (SCHEDULER_NAME, ENTRY_ID, TRIGGER_NAME, TRIGGER_GROUP, INSTANCE_NAME, FIRED_TIME, SCHED_TIME, STATE, JOB_NAME, JOB_GROUP, IS_NONCONCURRENT, REQUESTS_RECOVERY, PRIORITY) VALUES( 'CRMscheduler', ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?); 8. commit; 12. select STAT_ACCESS from QRTZ2_LOCKS for update 13. SELECT TRIGGER_STATE FROM QRTZ2_TRIGGERS WHERE SCHEDULER_NAME = 'CRMscheduler' AND TRIGGER_NAME = ? AND TRIGGER_GROUP = ?; 14. SELECT TRIGGER_STATE FROM QRTZ2_TRIGGERS WHERE SCHEDULER_NAME = 'CRMscheduler' AND TRIGGER_NAME = ? AND TRIGGER_GROUP = ?; 14. SELECT * FROM QRTZ2_JOB_DETAILS WHERE SCHEDULER_NAME = CRMscheduler AND JOB_NAME = ? AND JOB_GROUP = ?; 15. SELECT * FROM QRTZ2_CALENDARS WHERE SCHEDULER_NAME = 'CRMscheduler' AND CALENDAR_NAME = ?; 16. UPDATE QRTZ2_FIRED_TRIGGERS SET INSTANCE_NAME = ?, FIRED_TIME = ?, SCHED_TIME = ?, ENTRY_STATE = ?, JOB_NAME = ?, JOB_GROUP = ?, IS_NONCONCURRENT = ?, REQUESTS_RECOVERY = ? WHERE SCHEDULER_NAME = 'CRMscheduler' AND ENTRY_ID = ?; 17. UPDATE TQRTZ2_TRIGGERS SET TRIGGER_STATE = ? WHERE SCHED_NAME = 'CRMscheduler' AND TRIGGER_NAME = '{triggerName}' AND TRIGGER_GROUP = '{triggerGroup}' AND TRIGGER_STATE = ？; 18. UPDATE QRTZ2_TRIGGERS SET JOB_NAME = ?, JOB_GROUP = ?, DESCRIPTION = ?, NEXT_FIRE_TIME = ?, PREV_FIRE_TIME = ?, TRIGGER_STATE = ?, TRIGGER_TYPE = ?, START_TIME = ?, END_TIME = ?, CALENDAR_NAME = ?, MISFIRE_INSTRUCTION = ?, PRIORITY = ?, JOB_DATAMAP = ? WHERE SCHEDULER_NAME = SCHED_NAME_SUBST AND TRIGGER_NAME = ? AND TRIGGER_GROUP = ?; 19. commit;