本文整理了Java中org.quartz.core.QuartzScheduler.notifySchedulerThread
方法的一些代码示例,展示了QuartzScheduler.notifySchedulerThread
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。QuartzScheduler.notifySchedulerThread
方法的具体详情如下:
包路径:org.quartz.core.QuartzScheduler
类名称: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);
}
}
内容来源于网络,如有侵权,请联系作者删除!