当前位置: 首页 > news >正文

温州网站网站建设数据库

温州网站,网站建设数据库,企业域名邮箱,成app短视频源码下载文章目录 Quartz进行任务调度时通常会要求一个任务禁止并发执行,此时只需要在Job类上面添加一个注解DisallowConcurrentExecution即可。在保存到数据库里面时,对应QRTZ_JOB_DETAILS表中的IS_NONCONCURRENT字段的值为1(true)。那么…

文章目录

Quartz进行任务调度时通常会要求一个任务禁止并发执行,此时只需要在Job类上面添加一个注解@DisallowConcurrentExecution即可。在保存到数据库里面时,对应QRTZ_JOB_DETAILS表中的IS_NONCONCURRENT字段的值为1(true)。那么这里是怎么控制的呢?
在Quartz项目搭建与任务执行源码分析中详细介绍一个正常流程过程中涉及的表和状态的变化过程。总结的表格如下

表名scheduleJobacquireNextTriggerstriggersFiredtriggeredJobComplete
QRTZ_TRIGGERSWAITING(CAS)ACQUIREDWAITINGWAITING
QRTZ_FIRED_TRIGGERSACQUIREDEXECUTING

而对于禁止并发的任务,其状态则如下所示

表名scheduleJobacquireNextTriggerstriggersFiredtriggeredJobComplete
QRTZ_TRIGGERSWAITING(CAS)ACQUIREDBLOCKEDWAITING
QRTZ_FIRED_TRIGGERSACQUIREDEXECUTING
  1. 调度任务在查询待触发任务时,如果同时查出来一个任务对应的多个触发器,只有第一个有效(通过acquiredJobKeysForNoConcurrentExec集合保证唯一性)
    org.quartz.impl.jdbcjobstore.JobStoreSupport#acquireNextTrigger
Set<JobKey> acquiredJobKeysForNoConcurrentExec = new HashSet<JobKey>();
// ... 其他代码省略// If trigger's job is set as @DisallowConcurrentExecution, and it has already been added to result, then// put it back into the timeTriggers set and continue to search for next trigger.JobKey jobKey = nextTrigger.getJobKey();JobDetail job = getDelegate().selectJobDetail(conn, jobKey, getClassLoadHelper());if (job.isConcurrentExectionDisallowed()) {if (acquiredJobKeysForNoConcurrentExec.contains(jobKey)) {continue; // next trigger} else {acquiredJobKeysForNoConcurrentExec.add(jobKey);}}
  1. 任务触发时,将不支持并发机制的触发器的状态由 WAITING -> BLOCKED,这样调度线程查询待触发任务时便不会满足条件(调度任务只会查询WAITING状态的触发器)

org.quartz.impl.jdbcjobstore.JobStoreSupport#triggersFired

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);}
} 
  1. 任务执行完毕,会将触发器的状态修改回来 BLOCKED -> WAITING

org.quartz.core.QuartzScheduler#notifyJobStoreJobComplete
执行org.quartz.spi.JobStore#triggeredJobComplete方法

if (jobDetail.isConcurrentExectionDisallowed()) {getDelegate().updateTriggerStatesForJobFromOtherState(conn,jobDetail.getKey(), STATE_WAITING,STATE_BLOCKED);getDelegate().updateTriggerStatesForJobFromOtherState(conn,jobDetail.getKey(), STATE_PAUSED,STATE_PAUSED_BLOCKED);signalSchedulingChangeOnTxCompletion(0L);
}

除了以上地方,在Quartz启动时,org.quartz.impl.jdbcjobstore.JobStoreSupport#recoverJobs首先会将一些阻塞的任务都修改为WAITING,防止系统崩溃导致任务未执行完而来不及恢复禁止并发任务的状态。

// update inconsistent job states
int rows = getDelegate().updateTriggerStatesFromOtherStates(conn,STATE_WAITING, STATE_ACQUIRED, STATE_BLOCKED);rows += getDelegate().updateTriggerStatesFromOtherStates(conn,STATE_PAUSED, STATE_PAUSED_BLOCKED, STATE_PAUSED_BLOCKED);getLog().info("Freed " + rows+ " triggers from 'acquired' / 'blocked' state.");

另外在项目启动、新增触发器、定时任务补偿等所有涉及数据库操作Trigger中都会执行org.quartz.impl.jdbcjobstore.JobStoreSupport#storeTrigger操作,而其中都会检查状态,checkBlockedState.

if (job.isConcurrentExectionDisallowed() && !recovering) { state = checkBlockedState(conn, job.getKey(), state);
}if (existingTrigger) {getDelegate().updateTrigger(conn, newTrigger, state, job);
} else {getDelegate().insertTrigger(conn, newTrigger, state, job);
}

checkBlockedState中,就会根据是否禁止并发并判断是否任务已经执行(通过selectFiredTriggerRecordsByJob查询QRTZ_FIRED_TRIGGERS表中是否有数据)返回BLOCKED状态,org.quartz.impl.jdbcjobstore.JobStoreSupport#checkBlockedState

/*** Determines if a Trigger for the given job should be blocked.  * State can only transition to STATE_PAUSED_BLOCKED/BLOCKED from * PAUSED/STATE_WAITING respectively.* * @return STATE_PAUSED_BLOCKED, BLOCKED, or the currentState. */
protected String checkBlockedState(Connection conn, JobKey jobKey, String currentState)throws JobPersistenceException {// State can only transition to BLOCKED from PAUSED or WAITING.if ((!currentState.equals(STATE_WAITING)) &&(!currentState.equals(STATE_PAUSED))) {return currentState;}try {List<FiredTriggerRecord> lst = getDelegate().selectFiredTriggerRecordsByJob(conn,jobKey.getName(), jobKey.getGroup());if (lst.size() > 0) {FiredTriggerRecord rec = lst.get(0);if (rec.isJobDisallowsConcurrentExecution()) { // OLD_TODO: worry about failed/recovering/volatile job  states?return (STATE_PAUSED.equals(currentState)) ? STATE_PAUSED_BLOCKED : STATE_BLOCKED;}}return currentState;} catch (SQLException e) {throw new JobPersistenceException("Couldn't determine if trigger should be in a blocked state '"+ jobKey + "': "+ e.getMessage(), e);}}

从上面可以看到,基本上在整个操作触发器的生命周期,都会考虑当前任务是否禁止并发操作,通过QRTZ_FIRED_TRIGGERS表是否有数据判断任务是否执行、不支持并发机制的任务在执行时将QRTZ_TRIGGERS中的状态改为BLOCKED以避免再次被触发。

http://www.sczhlp.com/news/85162/

相关文章:

  • 网站建设工作室简介wordpress函数调用
  • 四川省建设工程质量安全协会网站网站生鲜建设市场分析
  • 异地备案 网站个性化定制网站有哪些
  • 青岛做网站费用汕头网站建设浩森宇特
  • 北京做网站的价格企业网站源码排行
  • 9.9日总结
  • 202205_宁波市赛_Cr4ck2
  • GitHub Copilot代码审查大升级!路径级指令+组织级规范,开发者效率再提升!
  • 网站提示宏吴忠门户网站建设
  • 青岛网站建设软件下载中交路桥建设有限公司网站
  • 免费的网站软件二级域名搜索
  • 在线做生存曲线的网站有哪些推广网络怎么做
  • 网站推广的基本手段论网站建设情况
  • 做调查可以赚钱的网站青岛网站快速备案
  • 做外贸网站要注意什么如何建立网站链接
  • 网站做任务挣钱网站建设接单源码
  • 郑州市建设厅网站做网站的一个黑点符号
  • 20250909 GOJ 模拟赛
  • 做网站页面用什么校园网站开发背景
  • 公司网站制作苏州好看的模板网站建设
  • 建设部网站官网证书查询网站搭建h5是什么
  • asp网站怎么打开商务互联 网站
  • 订阅号做流量 那些电影如何链接网站淘宝seo是什么意思啊
  • 四川网站建设培训学校北京广告公司聚集地
  • 在AI技术唾手可得的时代,挖掘新需求成为制胜关键——某知名语音识别框架需求洞察
  • SOS dp(高维前缀dp)
  • 英语_阅读_raise awareness about water conservation_待读
  • 自我介绍
  • MQ
  • 凡科网站建设步骤怎么推广网站