[發(fā)明專利]一種任務(wù)按需生成與調(diào)度執(zhí)行的方法

在審

• 申請?zhí)枺?/td>: 202210890451.1
• 申請日: 2022-07-27
• 公開（公告）號(hào): CN115061807A
• 公開（公告）日: 2022-09-16
• 發(fā)明（設(shè)計(jì)）人: 陳強(qiáng);何旭
• 申請（專利權(quán)）人: 中建電子商務(wù)有限責(zé)任公司
• 主分類號(hào): G06F9/48
• 分類號(hào): G06F9/48
• 代理公司: 成都春夏知識(shí)產(chǎn)權(quán)代理事務(wù)所(特殊普通合伙) 51317
• 代理人: 夏琴

1.一種任務(wù)按需生成與調(diào)度執(zhí)行的方法，其特征在于，包括以下步驟：

步驟S1、將需處理的任務(wù)根據(jù)類型分組，對各組賦予任務(wù)標(biāo)識(shí)P1-Pn，組內(nèi)任務(wù)的任務(wù)標(biāo)識(shí)與該組任務(wù)標(biāo)識(shí)一致，將所述任務(wù)儲(chǔ)存至異步任務(wù)執(zhí)行清單中；

步驟S2、查詢異步任務(wù)執(zhí)行清單中是否存在任務(wù)標(biāo)識(shí)為 P1、任務(wù)狀態(tài)為待執(zhí)行或執(zhí)行中的任務(wù)；

步驟S3、經(jīng)查詢不存在任務(wù)標(biāo)識(shí)為P1的任務(wù)，生成新任務(wù)并儲(chǔ)存至異步任務(wù)執(zhí)行清單中；

步驟S4、間隔檢索異步任務(wù)執(zhí)行清單是否存在任務(wù)狀態(tài)為待執(zhí)行或執(zhí)行中的任務(wù)；

步驟S5、經(jīng)檢索當(dāng)前時(shí)間存在任務(wù)狀態(tài)為待執(zhí)行或執(zhí)行中的任務(wù)，有序調(diào)度任務(wù)執(zhí)行并檢查執(zhí)行中的任務(wù)是否出現(xiàn)異常中斷；

步驟S6、上報(bào)任務(wù)執(zhí)行狀態(tài)并監(jiān)控任務(wù)是否正常執(zhí)行，在執(zhí)行結(jié)束立刻更新任務(wù)狀態(tài)。

2.根據(jù)權(quán)利要求1所述的一種任務(wù)按需生成與調(diào)度執(zhí)行的方法，其特征在于，所述步驟S3具體包括：

步驟S31、對同一類型需處理的任務(wù)按序賦予任務(wù)號(hào)；

步驟S32、對各任務(wù)賦予同一任務(wù)標(biāo)識(shí) P1；

步驟S33、對各任務(wù)按序賦予任務(wù)狀態(tài)為待執(zhí)行，并設(shè)定任務(wù)執(zhí)行周期、任務(wù)準(zhǔn)備執(zhí)行時(shí)間以及允許的最大斷線時(shí)間；

步驟S34、將新任務(wù)儲(chǔ)存至異步任務(wù)執(zhí)行清單中。

3.根據(jù)權(quán)利要求2所述的一種任務(wù)按需生成與調(diào)度執(zhí)行的方法，其特征在于，對同一類型需處理的任務(wù)按序由1到n對每個(gè)任務(wù)賦予一個(gè)任務(wù)號(hào)，第一個(gè)任務(wù)的任務(wù)號(hào)為1。

4.根據(jù)權(quán)利要求2所述的一種任務(wù)按需生成與調(diào)度執(zhí)行的方法，其特征在于，所述任務(wù)準(zhǔn)備執(zhí)行時(shí)間為系統(tǒng)時(shí)間加上任務(wù)執(zhí)行周期，任務(wù)的初始狀態(tài)為待執(zhí)行。

5.根據(jù)權(quán)利要求2所述的一種任務(wù)按需生成與調(diào)度執(zhí)行的方法，其特征在于，所述步驟S5具體包括：

步驟S51、檢查任務(wù)集是否存在任務(wù)狀態(tài)為執(zhí)行中的任務(wù)；

步驟S52、任務(wù)集中存在任務(wù)狀態(tài)為執(zhí)行中的任務(wù)則進(jìn)入步驟S53，任務(wù)集中不存在任務(wù)狀態(tài)為執(zhí)行中的任務(wù)則進(jìn)入步驟S55；

步驟S53、判斷當(dāng)前系統(tǒng)時(shí)間減去任務(wù)最后執(zhí)行時(shí)間是否小于允許的最大斷線時(shí)間；

步驟S54、當(dāng)前系統(tǒng)時(shí)間減去任務(wù)最后執(zhí)行時(shí)間小于或等于允許的最大斷線時(shí)間，判定任務(wù)為正常執(zhí)行，結(jié)束流程；當(dāng)前系統(tǒng)時(shí)間減去任務(wù)最后執(zhí)行時(shí)間大于允許的最大斷線時(shí)間，判定任務(wù)為異常中斷，設(shè)置該任務(wù)的任務(wù)狀態(tài)為執(zhí)行中斷，并跳轉(zhuǎn)至步驟S55；

步驟S55、檢查任務(wù)集是否存在任務(wù)狀態(tài)為待執(zhí)行的任務(wù)；

步驟S56、任務(wù)集中不存在任務(wù)狀態(tài)為待執(zhí)行的任務(wù)，結(jié)束流程；

步驟S57、任務(wù)集中存在任務(wù)狀態(tài)為待執(zhí)行的任務(wù)，且準(zhǔn)備執(zhí)行時(shí)間小于當(dāng)前系統(tǒng)時(shí)間，結(jié)束流程；任務(wù)集中存在任務(wù)狀態(tài)為待執(zhí)行的任務(wù)，且準(zhǔn)備執(zhí)行時(shí)間大于或等于當(dāng)前系統(tǒng)時(shí)間，進(jìn)行異步執(zhí)行任務(wù)。

6.根據(jù)權(quán)利要求5所述的一種任務(wù)按需生成與調(diào)度執(zhí)行的方法，其特征在于，所述步驟S6具體包括：

步驟61、賦予當(dāng)前待執(zhí)行的任務(wù)內(nèi)部執(zhí)行標(biāo)識(shí)，并將內(nèi)部執(zhí)行標(biāo)識(shí)設(shè)定為1；

步驟62、更新異步任務(wù)執(zhí)行清單中當(dāng)前任務(wù)的任務(wù)狀態(tài)為執(zhí)行中、最后執(zhí)行時(shí)間為系統(tǒng)時(shí)間；

步驟63、執(zhí)行預(yù)定的任務(wù)處理程序，并同步啟用狀態(tài)上報(bào)程序；

步驟64、任務(wù)處理程序結(jié)束，更新當(dāng)前任務(wù)的任務(wù)狀態(tài)為執(zhí)行完成或執(zhí)行失敗，并設(shè)定其內(nèi)部執(zhí)行標(biāo)識(shí)為0。

7.根據(jù)權(quán)利要求6所述的一種任務(wù)按需生成與調(diào)度執(zhí)行的方法，其特征在于，內(nèi)部執(zhí)行標(biāo)識(shí)為0表示任務(wù)執(zhí)行結(jié)束，內(nèi)部執(zhí)行標(biāo)識(shí)為1表示任務(wù)處于執(zhí)行中。

8.根據(jù)權(quán)利要求6所述的一種任務(wù)按需生成與調(diào)度執(zhí)行的方法，其特征在于，所述狀態(tài)上報(bào)程序具體為：每間隔5秒檢查任務(wù)內(nèi)部執(zhí)行標(biāo)識(shí)是否為0，內(nèi)部執(zhí)行標(biāo)識(shí)為1，獲取當(dāng)前系統(tǒng)時(shí)間并更新異步任務(wù)執(zhí)行清單該任務(wù)的最后執(zhí)行時(shí)間；內(nèi)部執(zhí)行標(biāo)識(shí)為0，退出流程。