本文整理了Java中org.quartz.core.QuartzScheduler类的一些代码示例，展示了QuartzScheduler类的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。QuartzScheduler类的具体详情如下：
包路径：org.quartz.core.QuartzScheduler
类名称：QuartzScheduler

QuartzScheduler介绍

[英]This is the heart of Quartz, an indirect implementation of the org.quartz.Scheduler interface, containing methods to schedule org.quartz.Jobs, register org.quartz.JobListener instances, etc.
[中]这是Quartz的核心，它是org.quartz.Scheduler接口的间接实现，包含调度org.quartz.Job实例、注册org.quartz.JobListener实例等方法。

代码示例

代码示例来源：origin: quartz-scheduler/quartz

/**
 * <p>
 * Returns the <code>SchedulerContext</code> of the <code>Scheduler</code>.
 * </p>
 */
public SchedulerContext getContext() throws SchedulerException {
  return sched.getSchedulerContext();
}

代码示例来源：origin: quartz-scheduler/quartz

/**
 * <p>
 * Calls the equivalent method on the 'proxied' <code>QuartzScheduler</code>.
 * </p>
 */
public void addCalendar(String calName, Calendar calendar, boolean replace, boolean updateTriggers)
  throws SchedulerException {
  sched.addCalendar(calName, calendar, replace, updateTriggers);
}

代码示例来源：origin: quartz-scheduler/quartz

/**
 * <p>
 * Calls the equivalent method on the 'proxied' <code>QuartzScheduler</code>.
 * </p>
 */
public void addJob(JobDetail jobDetail, boolean replace)
  throws SchedulerException {
  sched.addJob(jobDetail, replace);
}

代码示例来源：origin: quartz-scheduler/quartz

public void initialize() throws SchedulerException {
    bind();
  } catch (Exception re) {
    throw new SchedulerException(
      registerJMX();
    } catch (Exception e) {
      throw new SchedulerException(
  getLog().info("Scheduler meta-data: " +
      (new SchedulerMetaData(getSchedulerName(),
          getSchedulerInstanceId(), getClass(), boundRemotely, runningSince() != null, 
          isInStandbyMode(), isShutdown(), runningSince(), 
          numJobsExecuted(), getJobStoreClass(), 
          supportsPersistence(), isClustered(), getThreadPoolClass(), 
          getThreadPoolSize(), getVersion())).toString());

代码示例来源：origin: quartz-scheduler/quartz

public void notifyJobListenersWasVetoed(JobExecutionContext jec)
  throws SchedulerException {
  // build a list of all job listeners that are to be notified...
  List<JobListener> jobListeners = buildJobListenerList();
  // notify all job listeners
  for(JobListener jl: jobListeners) {
    try {
      if(!matchJobListener(jl, jec.getJobDetail().getKey()))
        continue;
      jl.jobExecutionVetoed(jec);
    } catch (Exception e) {
      SchedulerException se = new SchedulerException(
          "JobListener '" + jl.getName() + "' threw exception: "
          + e.getMessage(), e);
      throw se;
    }
  }
}

代码示例来源：origin: quartz-scheduler/quartz

public void notifyTriggerListenersMisfired(Trigger trigger)
  throws SchedulerException {
  // build a list of all trigger listeners that are to be notified...
  List<TriggerListener> triggerListeners = buildTriggerListenerList();
  // notify all trigger listeners in the list
  for(TriggerListener tl: triggerListeners) {
    try {
      if(!matchTriggerListener(tl, trigger.getKey()))
        continue;
      tl.triggerMisfired(trigger);
    } catch (Exception e) {
      SchedulerException se = new SchedulerException(
          "TriggerListener '" + tl.getName()
              + "' threw exception: " + e.getMessage(), e);
      throw se;
    }
  }
}

代码示例来源：origin: quartz-scheduler/quartz

QuartzScheduler qs = new QuartzScheduler(qrs, idleWaitTime, dbFailureRetryInterval);
jobStore.initialize(cch, qs.getSchedulerSignaler());
qs.initialize();
getLog().info("Quartz scheduler version: " + qs.getVersion());
qs.addNoGCObject(schedRep); // prevents the repository from being

代码示例来源：origin: quartz-scheduler/quartz

qs = new QuartzScheduler(rsrcs, idleWaitTime, dbFailureRetry);
qsInited = true;
  qs.setJobFactory(jobFactory);
  qs.getListenerManager().addJobListener(jobListeners[i], EverythingMatcher.allJobs());
  qs.getListenerManager().addTriggerListener(triggerListeners[i], EverythingMatcher.allTriggers());
js.setInstanceName(schedName);
js.setThreadPoolSize(tp.getPoolSize());
js.initialize(loadHelper, qs.getSchedulerSignaler());
qs.initialize();
        + "' initialized from " + propSrc);
getLog().info("Quartz scheduler version: " + qs.getVersion());
qs.addNoGCObject(schedRep);
  qs.addNoGCObject(dbMgr);

代码示例来源：origin: quartz/quartz-all

schedCtxt.setInstanceId(rsrcs.getInstanceId());
qs = new QuartzScheduler(rsrcs, schedCtxt, idleWaitTime, dbFailureRetry);
  qs.setJobFactory(jobFactory);
  qs.addGlobalJobListener(jobListeners[i]);
  qs.addGlobalTriggerListener(triggerListeners[i]);
js.initialize(loadHelper, qs.getSchedulerSignaler());
        + "' initialized from " + propSrc);
getLog().info("Quartz scheduler version: " + qs.getVersion());
qs.addNoGCObject(schedRep);
  qs.addNoGCObject(dbMgr);

代码示例来源：origin: quartz/quartz-all

this.resources = resources;
try {
  bind();
} catch (Exception re) {
  throw new SchedulerException(
    registerJMX();
  } catch (Exception e) {
    throw new SchedulerException(
addGlobalJobListener(jobMgr);
errLogger = new ErrorLogger();
addSchedulerListener(errLogger);
getLog().info("Quartz Scheduler v." + getVersion() + " created.");

代码示例来源：origin: cdapio/cdap

qrs.setJobStore(store);
qrs.setRunUpdateCheck(false);
QuartzScheduler qs = new QuartzScheduler(qrs, -1, -1);
store.initialize(cch, qs.getSchedulerSignaler());
org.quartz.Scheduler scheduler = new StdScheduler(qs);
qs.initialize();

代码示例来源：origin: bonitasoft/bonita-engine

@Override
  public void afterCompletion(final TransactionState txState) {
    if (TransactionState.COMMITTED.equals(txState)) {
      if (quartzScheduler != null) {
        quartzScheduler.getSchedulerSignaler().signalSchedulingChange(time);
      }
    }
  }
}

代码示例来源：origin: quartz-scheduler/quartz

/**
 * <p>
 * Calls the equivalent method on the 'proxied' <code>QuartzScheduler</code>.
 * </p>
 */
public boolean deleteCalendar(String calName) throws SchedulerException {
  return sched.deleteCalendar(calName);
}

代码示例来源：origin: com.opensymphony.quartz/com.springsource.org.quartz

public void notifyTriggerListenersMisfired(Trigger trigger)
  throws SchedulerException {
  // build a list of all trigger listeners that are to be notified...
  List triggerListeners = buildTriggerListenerList(trigger
      .getTriggerListenerNames());
  // notify all trigger listeners in the list
  java.util.Iterator itr = triggerListeners.iterator();
  while (itr.hasNext()) {
    TriggerListener tl = (TriggerListener) itr.next();
    try {
      tl.triggerMisfired(trigger);
    } catch (Exception e) {
      SchedulerException se = new SchedulerException(
          "TriggerListener '" + tl.getName()
              + "' threw exception: " + e.getMessage(), e);
      se.setErrorCode(SchedulerException.ERR_TRIGGER_LISTENER);
      throw se;
    }
  }
}

代码示例来源：origin: quartz/quartz-all

public void notifyJobListenersWasExecuted(JobExecutionContext jec,
    JobExecutionException je) throws SchedulerException {
  // build a list of all job listeners that are to be notified...
  List jobListeners = buildJobListenerList(jec.getJobDetail()
      .getJobListenerNames());
  // notify all job listeners
  java.util.Iterator itr = jobListeners.iterator();
  while (itr.hasNext()) {
    JobListener jl = (JobListener) itr.next();
    try {
      jl.jobWasExecuted(jec, je);
    } catch (Exception e) {
      SchedulerException se = new SchedulerException(
          "JobListener '" + jl.getName() + "' threw exception: "
              + e.getMessage(), e);
      se.setErrorCode(SchedulerException.ERR_JOB_LISTENER);
      throw se;
    }
  }
}

代码示例来源：origin: quartz-scheduler/quartz

public void initialize() throws SchedulerException {
    bind();
  } catch (Exception re) {
    throw new SchedulerException(
      registerJMX();
    } catch (Exception e) {
      throw new SchedulerException(
  getLog().info("Scheduler meta-data: " +
      (new SchedulerMetaData(getSchedulerName(),
          getSchedulerInstanceId(), getClass(), boundRemotely, runningSince() != null, 
          isInStandbyMode(), isShutdown(), runningSince(), 
          numJobsExecuted(), getJobStoreClass(), 
          supportsPersistence(), isClustered(), getThreadPoolClass(), 
          getThreadPoolSize(), getVersion())).toString());

代码示例来源：origin: quartz-scheduler/quartz

QuartzScheduler qs = new QuartzScheduler(qrs, idleWaitTime, dbFailureRetryInterval);
jobStore.initialize(cch, qs.getSchedulerSignaler());
qs.initialize();
getLog().info("Quartz scheduler version: " + qs.getVersion());
qs.addNoGCObject(schedRep); // prevents the repository from being

代码示例来源：origin: quartz-scheduler/quartz

qs = new QuartzScheduler(rsrcs, idleWaitTime, dbFailureRetry);
qsInited = true;
  qs.setJobFactory(jobFactory);
  qs.getListenerManager().addJobListener(jobListeners[i], EverythingMatcher.allJobs());
  qs.getListenerManager().addTriggerListener(triggerListeners[i], EverythingMatcher.allTriggers());
js.setInstanceName(schedName);
js.setThreadPoolSize(tp.getPoolSize());
js.initialize(loadHelper, qs.getSchedulerSignaler());
qs.initialize();
        + "' initialized from " + propSrc);
getLog().info("Quartz scheduler version: " + qs.getVersion());
qs.addNoGCObject(schedRep);
  qs.addNoGCObject(dbMgr);

代码示例来源：origin: com.opensymphony.quartz/com.springsource.org.quartz

schedCtxt.setInstanceId(rsrcs.getInstanceId());
qs = new QuartzScheduler(rsrcs, schedCtxt, idleWaitTime, dbFailureRetry);
  qs.setJobFactory(jobFactory);
  qs.addGlobalJobListener(jobListeners[i]);
  qs.addGlobalTriggerListener(triggerListeners[i]);
js.initialize(loadHelper, qs.getSchedulerSignaler());
        + "' initialized from " + propSrc);
getLog().info("Quartz scheduler version: " + qs.getVersion());
qs.addNoGCObject(schedRep);
  qs.addNoGCObject(dbMgr);

代码示例来源：origin: com.opensymphony.quartz/com.springsource.org.quartz

this.resources = resources;
try {
  bind();
} catch (Exception re) {
  throw new SchedulerException(
    registerJMX();
  } catch (Exception e) {
    throw new SchedulerException(
addGlobalJobListener(jobMgr);
errLogger = new ErrorLogger();
addSchedulerListener(errLogger);
getLog().info("Quartz Scheduler v." + getVersion() + " created.");