[發(fā)明專利]一種任務(wù)調(diào)度系統(tǒng)、方法、設(shè)備及存儲(chǔ)介質(zhì)

在審

• 申請(qǐng)?zhí)枺?/td>: 202011034859.6
• 申請(qǐng)日: 2020-09-27
• 公開（公告）號(hào): CN112181621A
• 公開（公告）日: 2021-01-05
• 發(fā)明（設(shè)計(jì)）人: 史振華
• 申請(qǐng)（專利權(quán)）人: 中國(guó)建設(shè)銀行股份有限公司
• 主分類號(hào): G06F9/48
• 分類號(hào): G06F9/48
• 代理公司: 北京品源專利代理有限公司 11332
• 代理人: 孟金喆

本發(fā)明實(shí)施例公開了一種任務(wù)調(diào)度系統(tǒng)、方法、設(shè)備及存儲(chǔ)介質(zhì)。該系統(tǒng)包括：定時(shí)調(diào)度模塊、任務(wù)掃描分發(fā)模塊、任務(wù)預(yù)處理模塊、任務(wù)執(zhí)行模塊以及任務(wù)隊(duì)列；定時(shí)調(diào)度模塊，用于將滿足定時(shí)調(diào)度條件的未處理任務(wù)，加入至任務(wù)隊(duì)列；任務(wù)掃描分發(fā)模塊，用于掃描任務(wù)隊(duì)列中的未處理任務(wù)，并將滿足任務(wù)分發(fā)條件的任務(wù)分發(fā)至任務(wù)預(yù)處理模塊；任務(wù)預(yù)處理模塊，用于在所分發(fā)的未處理任務(wù)中，為滿足任務(wù)編排條件的任務(wù)編排執(zhí)行步驟，并將已編排任務(wù)提交至任務(wù)執(zhí)行模塊；任務(wù)執(zhí)行模塊，用于將成功獲取的已編排任務(wù)按照匹配的執(zhí)行步驟執(zhí)行。該系統(tǒng)實(shí)現(xiàn)了對(duì)任務(wù)的有效管理，避免任務(wù)被重復(fù)執(zhí)行，避免造成任務(wù)堵塞。

技術(shù)領(lǐng)域

本發(fā)明實(shí)施例涉及軟件技術(shù)領(lǐng)域，尤其涉及一種任務(wù)調(diào)度系統(tǒng)、方法、設(shè)備及存儲(chǔ)介質(zhì)。

背景技術(shù)

目前許多業(yè)務(wù)處理是在指定時(shí)間進(jìn)行自動(dòng)處理的，例如月末的財(cái)務(wù)報(bào)表生成，或者傳統(tǒng)節(jié)日前優(yōu)惠信息的發(fā)送等。

現(xiàn)有技術(shù)中通常采用兩種方式進(jìn)行業(yè)務(wù)處理的定時(shí)觸發(fā)調(diào)度執(zhí)行。其中，第一種方式是采用Linux系統(tǒng)中的crontab命令為各任務(wù)執(zhí)行腳本程序配置定時(shí)觸發(fā)，Linux系統(tǒng)內(nèi)的cron進(jìn)程會(huì)根據(jù)預(yù)設(shè)的定時(shí)觸發(fā)規(guī)則進(jìn)行各任務(wù)執(zhí)行腳本程序的調(diào)度執(zhí)行。第二種方式是采用Quartz框架，將任務(wù)的定時(shí)調(diào)度整合到應(yīng)用系統(tǒng)中。Quartz是一種開源調(diào)度框架，提供多種調(diào)度方法，支持多種粒度的調(diào)度，支持多種存儲(chǔ)方式，具有一定的分布式集群能力。

但是，第一種方式不能對(duì)定時(shí)任務(wù)進(jìn)行有效的管理和監(jiān)控，在分布式環(huán)境下會(huì)造成任務(wù)的重復(fù)執(zhí)行。而第二種方式缺少對(duì)任務(wù)并發(fā)度和流控的有效管理，當(dāng)某時(shí)間段有大量待執(zhí)行任務(wù)時(shí)，容易造成任務(wù)嚴(yán)重堵塞。

發(fā)明內(nèi)容

本發(fā)明實(shí)施例提供了一種任務(wù)調(diào)度系統(tǒng)、方法、設(shè)備及存儲(chǔ)介質(zhì)，可以對(duì)任務(wù)進(jìn)行有效管理，避免任務(wù)被重復(fù)執(zhí)行，避免造成任務(wù)堵塞。

第一方面，本發(fā)明實(shí)施例提供了一種任務(wù)調(diào)度系統(tǒng)，該系統(tǒng)包括：定時(shí)調(diào)度模塊、任務(wù)掃描分發(fā)模塊、任務(wù)預(yù)處理模塊、任務(wù)執(zhí)行模塊以及任務(wù)隊(duì)列；

定時(shí)調(diào)度模塊，用于將滿足定時(shí)調(diào)度條件的未處理任務(wù)，加入至任務(wù)隊(duì)列；

任務(wù)掃描分發(fā)模塊，用于掃描任務(wù)隊(duì)列中的未處理任務(wù)，并將滿足任務(wù)分發(fā)條件的任務(wù)分發(fā)至任務(wù)預(yù)處理模塊；

任務(wù)預(yù)處理模塊，用于在所分發(fā)的未處理任務(wù)中，為滿足任務(wù)編排條件的任務(wù)編排執(zhí)行步驟，并將已編排任務(wù)提交至任務(wù)執(zhí)行模塊；

任務(wù)執(zhí)行模塊，用于將成功獲取的已編排任務(wù)按照匹配的執(zhí)行步驟執(zhí)行。

第二方面，本發(fā)明實(shí)施例還提供了一種任務(wù)調(diào)度方法，該方法包括：

通過調(diào)度模塊，將滿足定時(shí)調(diào)度條件的未處理任務(wù)，加入至任務(wù)隊(duì)列；

通過任務(wù)掃描分發(fā)模塊，掃描任務(wù)隊(duì)列中的未處理任務(wù)，并將滿足任務(wù)分發(fā)條件的任務(wù)分發(fā)至任務(wù)預(yù)處理模塊；

通過任務(wù)預(yù)處理模塊，在所分發(fā)的未處理任務(wù)中，為滿足任務(wù)編排條件的任務(wù)編排執(zhí)行步驟，并將已編排任務(wù)提交至任務(wù)執(zhí)行模塊；

通過任務(wù)執(zhí)行模塊，將成功獲取的已編排任務(wù)按照匹配的執(zhí)行步驟執(zhí)行。

第三方面，本發(fā)明實(shí)施例還提供了一種電子設(shè)備，該設(shè)備包括：

一個(gè)或多個(gè)處理器；

存儲(chǔ)裝置，用于存儲(chǔ)一個(gè)或多個(gè)程序，

當(dāng)所述一個(gè)或多個(gè)程序被所述一個(gè)或多個(gè)處理器執(zhí)行，使得所述一個(gè)或多個(gè)處理器實(shí)現(xiàn)如本發(fā)明任意實(shí)施例所述的一種任務(wù)調(diào)度方法。

第四方面，本發(fā)明實(shí)施例還提供了一種計(jì)算機(jī)可讀存儲(chǔ)介質(zhì)，其上存儲(chǔ)有計(jì)算機(jī)程序，該程序被處理器執(zhí)行時(shí)實(shí)現(xiàn)如本發(fā)明任意實(shí)施例所述的一種任務(wù)調(diào)度方法。