org.quartz.core.QuartzScheduler.notifySchedulerThread()方法的使用及代码示例

x33g5p2x  于2022-01-28 转载在 其他  
字(9.0k)|赞(0)|评价(0)|浏览(85)

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

QuartzScheduler.notifySchedulerThread介绍

暂无

代码示例

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

public boolean unscheduleJobs(List<TriggerKey> triggerKeys) throws SchedulerException  {
  validateState();
  boolean result = false;
  
  result = resources.getJobStore().removeTriggers(triggerKeys);
  notifySchedulerThread(0L);
  for(TriggerKey key: triggerKeys)
    notifySchedulerListenersUnscheduled(key);
  return result;
}

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

public boolean unscheduleJobs(List<TriggerKey> triggerKeys) throws SchedulerException  {
  validateState();
  boolean result = false;
  
  result = resources.getJobStore().removeTriggers(triggerKeys);
  notifySchedulerThread(0L);
  for(TriggerKey key: triggerKeys)
    notifySchedulerListenersUnscheduled(key);
  return result;
}

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

/**
 * <p>
 * Pause the <code>{@link Trigger}</code> with the given name.
 * </p>
 *  
 */
public void pauseTrigger(TriggerKey triggerKey) throws SchedulerException {
  validateState();
  resources.getJobStore().pauseTrigger(triggerKey);
  notifySchedulerThread(0L);
  notifySchedulerListenersPausedTrigger(triggerKey);
}

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

public boolean deleteJobs(List<JobKey> jobKeys)  throws SchedulerException {
  validateState();
  boolean result = false;
  
  result = resources.getJobStore().removeJobs(jobKeys);
  notifySchedulerThread(0L);
  for(JobKey key: jobKeys)
    notifySchedulerListenersJobDeleted(key);
  return result;
}

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

public boolean deleteJobs(List<JobKey> jobKeys)  throws SchedulerException {
  validateState();
  boolean result = false;
  
  result = resources.getJobStore().removeJobs(jobKeys);
  notifySchedulerThread(0L);
  for(JobKey key: jobKeys)
    notifySchedulerListenersJobDeleted(key);
  return result;
}

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

/**
 * <p>
 * Pause the <code>{@link Trigger}</code> with the given name.
 * </p>
 *  
 */
public void pauseTrigger(TriggerKey triggerKey) throws SchedulerException {
  validateState();
  resources.getJobStore().pauseTrigger(triggerKey);
  notifySchedulerThread(0L);
  notifySchedulerListenersPausedTrigger(triggerKey);
}

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

/**
 * <p>
 * Pause the <code>{@link org.quartz.JobDetail}</code> with the given
 * name - by pausing all of its current <code>Trigger</code>s.
 * </p>
 *  
 */
public void pauseJob(JobKey jobKey) throws SchedulerException {
  validateState();
  resources.getJobStore().pauseJob(jobKey);
  notifySchedulerThread(0L);
  notifySchedulerListenersPausedJob(jobKey);
}

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

/**
 * <p>
 * Pause the <code>{@link org.quartz.JobDetail}</code> with the given
 * name - by pausing all of its current <code>Trigger</code>s.
 * </p>
 *  
 */
public void pauseJob(JobKey jobKey) throws SchedulerException {
  validateState();
  resources.getJobStore().pauseJob(jobKey);
  notifySchedulerThread(0L);
  notifySchedulerListenersPausedJob(jobKey);
}

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

/**
 * <p>
 * Remove the indicated <code>{@link org.quartz.Trigger}</code> from the
 * scheduler.
 * </p>
 */
public boolean unscheduleJob(TriggerKey triggerKey) throws SchedulerException {
  validateState();
  if (resources.getJobStore().removeTrigger(triggerKey)) {
    notifySchedulerThread(0L);
    notifySchedulerListenersUnscheduled(triggerKey);
  } else {
    return false;
  }
  return true;
}

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

/**
 * <p>
 * Remove the indicated <code>{@link org.quartz.Trigger}</code> from the
 * scheduler.
 * </p>
 */
public boolean unscheduleJob(TriggerKey triggerKey) throws SchedulerException {
  validateState();
  if (resources.getJobStore().removeTrigger(triggerKey)) {
    notifySchedulerThread(0L);
    notifySchedulerListenersUnscheduled(triggerKey);
  } else {
    return false;
  }
  return true;
}

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

/**
 * <p>
 * Resume (un-pause) the <code>{@link Trigger}</code> with the given
 * name.
 * </p>
 * 
 * <p>
 * If the <code>Trigger</code> missed one or more fire-times, then the
 * <code>Trigger</code>'s misfire instruction will be applied.
 * </p>
 *  
 */
public void resumeTrigger(TriggerKey triggerKey) throws SchedulerException {
  validateState();
  resources.getJobStore().resumeTrigger(triggerKey);
  notifySchedulerThread(0L);
  notifySchedulerListenersResumedTrigger(triggerKey);
}

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

/**
 * <p>
 * Resume (un-pause) the <code>{@link Trigger}</code> with the given
 * name.
 * </p>
 * 
 * <p>
 * If the <code>Trigger</code> missed one or more fire-times, then the
 * <code>Trigger</code>'s misfire instruction will be applied.
 * </p>
 *  
 */
public void resumeTrigger(TriggerKey triggerKey) throws SchedulerException {
  validateState();
  resources.getJobStore().resumeTrigger(triggerKey);
  notifySchedulerThread(0L);
  notifySchedulerListenersResumedTrigger(triggerKey);
}

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

/**
 * <p>
 * Resume (un-pause) the <code>{@link org.quartz.JobDetail}</code> with
 * the given name.
 * </p>
 * 
 * <p>
 * If any of the <code>Job</code>'s<code>Trigger</code> s missed one
 * or more fire-times, then the <code>Trigger</code>'s misfire
 * instruction will be applied.
 * </p>
 *  
 */
public void resumeJob(JobKey jobKey) throws SchedulerException {
  validateState();
  resources.getJobStore().resumeJob(jobKey);
  notifySchedulerThread(0L);
  notifySchedulerListenersResumedJob(jobKey);
}

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

/**
 * <p>
 * Resume (un-pause) all triggers - equivalent of calling <code>resumeTriggerGroup(group)</code>
 * on every group.
 * </p>
 * 
 * <p>
 * If any <code>Trigger</code> missed one or more fire-times, then the
 * <code>Trigger</code>'s misfire instruction will be applied.
 * </p>
 * 
 * @see #pauseAll()
 */
public void resumeAll() throws SchedulerException {
  validateState();
  resources.getJobStore().resumeAll();
  notifySchedulerThread(0L);
  notifySchedulerListenersResumedTrigger(null);
}

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

/**
 * <p>
 * Resume (un-pause) all triggers - equivalent of calling <code>resumeTriggerGroup(group)</code>
 * on every group.
 * </p>
 * 
 * <p>
 * If any <code>Trigger</code> missed one or more fire-times, then the
 * <code>Trigger</code>'s misfire instruction will be applied.
 * </p>
 * 
 * @see #pauseAll()
 */
public void resumeAll() throws SchedulerException {
  validateState();
  resources.getJobStore().resumeAll();
  notifySchedulerThread(0L);
  notifySchedulerListenersResumedTrigger(null);
}

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

public void addJob(JobDetail jobDetail, boolean replace, boolean storeNonDurableWhileAwaitingScheduling) throws SchedulerException {
  validateState();
  if (!storeNonDurableWhileAwaitingScheduling && !jobDetail.isDurable()) {
    throw new SchedulerException(
        "Jobs added with no trigger must be durable.");
  }
  resources.getJobStore().storeJob(jobDetail, replace);
  notifySchedulerThread(0L);
  notifySchedulerListenersJobAdded(jobDetail);
}

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

public void addJob(JobDetail jobDetail, boolean replace, boolean storeNonDurableWhileAwaitingScheduling) throws SchedulerException {
  validateState();
  if (!storeNonDurableWhileAwaitingScheduling && !jobDetail.isDurable()) {
    throw new SchedulerException(
        "Jobs added with no trigger must be durable.");
  }
  resources.getJobStore().storeJob(jobDetail, replace);
  notifySchedulerThread(0L);
  notifySchedulerListenersJobAdded(jobDetail);
}

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

/**
 * <p>
 * Pause all of the <code>{@link Trigger}s</code> in the matching groups.
 * </p>
 *  
 */
public void pauseTriggers(GroupMatcher<TriggerKey> matcher)
  throws SchedulerException {
  validateState();
  if(matcher == null) {
    matcher = GroupMatcher.groupEquals(Scheduler.DEFAULT_GROUP);
  }
  Collection<String> pausedGroups = resources.getJobStore().pauseTriggers(matcher);
  notifySchedulerThread(0L);
  for (String pausedGroup : pausedGroups) {
    notifySchedulerListenersPausedTriggers(pausedGroup);
  }
}

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

/**
 * <p>
 * Pause all of the <code>{@link Trigger}s</code> in the matching groups.
 * </p>
 *  
 */
public void pauseTriggers(GroupMatcher<TriggerKey> matcher)
  throws SchedulerException {
  validateState();
  if(matcher == null) {
    matcher = GroupMatcher.groupEquals(Scheduler.DEFAULT_GROUP);
  }
  Collection<String> pausedGroups = resources.getJobStore().pauseTriggers(matcher);
  notifySchedulerThread(0L);
  for (String pausedGroup : pausedGroups) {
    notifySchedulerListenersPausedTriggers(pausedGroup);
  }
}

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

/**
 * <p>
 * Pause all of the <code>{@link org.quartz.JobDetail}s</code> in the
 * matching groups - by pausing all of their <code>Trigger</code>s.
 * </p>
 *  
 */
public void pauseJobs(GroupMatcher<JobKey> groupMatcher)
  throws SchedulerException {
  validateState();
  if(groupMatcher == null) {
    groupMatcher = GroupMatcher.groupEquals(Scheduler.DEFAULT_GROUP);
  }
  
  Collection<String> pausedGroups = resources.getJobStore().pauseJobs(groupMatcher);
  notifySchedulerThread(0L);
  for (String pausedGroup : pausedGroups) {
    notifySchedulerListenersPausedJobs(pausedGroup);
  }
}

相关文章

微信公众号

最新文章

更多

QuartzScheduler类方法