[發(fā)明專利]任務(wù)調(diào)度方法、裝置、設(shè)備及存儲(chǔ)介質(zhì)

在審

• 申請(qǐng)?zhí)枺?/td>: 202011548515.7
• 申請(qǐng)日: 2020-12-24
• 公開（公告）號(hào): CN114661432A
• 公開（公告）日: 2022-06-24
• 發(fā)明（設(shè)計(jì)）人: 王博
• 申請(qǐng)（專利權(quán)）人: 蘇州國雙軟件有限公司
• 主分類號(hào): G06F9/48
• 分類號(hào): G06F9/48
• 代理公司: 北京集佳知識(shí)產(chǎn)權(quán)代理有限公司 11227
• 代理人: 林哲生

1.一種任務(wù)調(diào)度方法，其特征在于，應(yīng)用于任務(wù)調(diào)度系統(tǒng)的調(diào)度節(jié)點(diǎn)，所述任務(wù)調(diào)度系統(tǒng)包括所述調(diào)度節(jié)點(diǎn)以及多個(gè)任務(wù)執(zhí)行節(jié)點(diǎn)，所述方法包括：

將待處理的工作流中的至少一個(gè)任務(wù)存儲(chǔ)到正常任務(wù)集合，所述至少一個(gè)任務(wù)分別具有各自的調(diào)度優(yōu)先級(jí)，且每個(gè)任務(wù)均配置有用于執(zhí)行所述任務(wù)的任務(wù)執(zhí)行節(jié)點(diǎn)的信息；

按照所述正常任務(wù)集合中任務(wù)對(duì)應(yīng)的調(diào)度優(yōu)先級(jí)，從所述正常任務(wù)集合中取出待調(diào)度的目標(biāo)任務(wù)；

依據(jù)所述目標(biāo)任務(wù)配置的任務(wù)執(zhí)行節(jié)點(diǎn)的信息，執(zhí)行所述目標(biāo)任務(wù)的分發(fā)處理；

如所述目標(biāo)任務(wù)分發(fā)失敗，將所述目標(biāo)任務(wù)加入到異常任務(wù)集合，并返回執(zhí)行所述從所述正常任務(wù)集合中取出待調(diào)度的目標(biāo)任務(wù)的操作，直至所述正常任務(wù)集合中不存在未被分發(fā)的任務(wù)。

2.根據(jù)權(quán)利要求1所述的方法，其特征在于，在所述將所述目標(biāo)任務(wù)加入到異常任務(wù)集合之后，還包括：

為所述目標(biāo)任務(wù)設(shè)置延遲重試時(shí)長；

在所述目標(biāo)任務(wù)本次加入所述異常任務(wù)集合的時(shí)長達(dá)到所述目標(biāo)任務(wù)的延遲重試時(shí)長后，將所述目標(biāo)任務(wù)從所述異常任務(wù)集合轉(zhuǎn)移到所述正常任務(wù)集合。

3.根據(jù)權(quán)利要求2所述的方法，其特征在于，在將所述目標(biāo)任務(wù)加入到異常任務(wù)集合之后，還包括：

更新所述目標(biāo)任務(wù)進(jìn)入所述異常任務(wù)集合的進(jìn)入次數(shù)；

所述為所述目標(biāo)任務(wù)設(shè)置延遲重試時(shí)長，包括：

根據(jù)更新后的所述進(jìn)入次數(shù)，為所述目標(biāo)任務(wù)設(shè)置延遲重試時(shí)長，其中，進(jìn)入次數(shù)越多，所述延遲重試時(shí)長越長。

4.根據(jù)權(quán)利要求1所述的方法，其特征在于，如所述目標(biāo)任務(wù)分發(fā)失敗，將所述目標(biāo)任務(wù)加入到異常任務(wù)集合，包括：

如所述目標(biāo)任務(wù)分發(fā)失敗，更新所述目標(biāo)任務(wù)的分發(fā)失敗次數(shù)；

如所述分發(fā)失敗次數(shù)未達(dá)到設(shè)定次數(shù)，返回執(zhí)行所述依據(jù)所述目標(biāo)任務(wù)配置的任務(wù)執(zhí)行節(jié)點(diǎn)的信息，執(zhí)行所述目標(biāo)任務(wù)的分發(fā)處理的操作；

如所述分發(fā)失敗次數(shù)達(dá)到所述設(shè)定次數(shù)，將所述目標(biāo)任務(wù)加入到異常任務(wù)集合。

5.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述將待處理的工作流中的至少一個(gè)任務(wù)存儲(chǔ)到正常任務(wù)集合，包括：

確定待處理的工作流中待調(diào)度處理的至少一個(gè)任務(wù)；

按照所述至少一個(gè)任務(wù)各自的調(diào)度優(yōu)先級(jí)，將所述至少一個(gè)任務(wù)加入到正常任務(wù)隊(duì)列，其中，調(diào)度優(yōu)先級(jí)越高的任務(wù)在所述正常任務(wù)隊(duì)列中的排序越靠前；

所述按照所述正常任務(wù)集合中任務(wù)對(duì)應(yīng)的調(diào)度優(yōu)先級(jí)，從所述正常任務(wù)集合中取出待調(diào)度的目標(biāo)任務(wù)，包括：

按照所述正常任務(wù)隊(duì)列中各任務(wù)的先后順序，從所述正常任務(wù)隊(duì)列中取出待調(diào)度的目標(biāo)任務(wù)。

6.根據(jù)權(quán)利要求2所述的方法，其特征在于，所述為所述目標(biāo)任務(wù)設(shè)置延遲重試時(shí)長，包括：

通過異常監(jiān)控線程為所述目標(biāo)任務(wù)設(shè)置延遲重試時(shí)長；

所述在所述目標(biāo)任務(wù)本次加入所述異常任務(wù)集合的時(shí)長達(dá)到所述目標(biāo)任務(wù)的延遲重試時(shí)長后，將所述目標(biāo)任務(wù)加入到所述正常任務(wù)集合，包括：

通過所述異常監(jiān)控線程監(jiān)控所述異常任務(wù)集合中各任務(wù)當(dāng)前加入所述異常任務(wù)集合的時(shí)長；

在所述異常監(jiān)控線程確認(rèn)所述目標(biāo)任務(wù)本次加入所述異常任務(wù)集合的時(shí)長達(dá)到所述目標(biāo)任務(wù)的延遲重試時(shí)長后，將所述目標(biāo)任務(wù)從所述異常任務(wù)集合轉(zhuǎn)移到所述正常任務(wù)集合。

7.一種任務(wù)調(diào)度裝置，其特征在于，應(yīng)用于任務(wù)調(diào)度系統(tǒng)的調(diào)度節(jié)點(diǎn)，所述任務(wù)調(diào)度系統(tǒng)包括所述調(diào)度節(jié)點(diǎn)以及多個(gè)任務(wù)執(zhí)行節(jié)點(diǎn)，所述裝置包括：

任務(wù)存儲(chǔ)單元，用于將待處理的工作流中的至少一個(gè)任務(wù)存儲(chǔ)到正常任務(wù)集合，所述至少一個(gè)任務(wù)分別具有各自的調(diào)度優(yōu)先級(jí)，且每個(gè)任務(wù)均配置有用于執(zhí)行所述任務(wù)的任務(wù)執(zhí)行節(jié)點(diǎn)的信息；

任務(wù)調(diào)度單元，用于按照所述正常任務(wù)集合中任務(wù)對(duì)應(yīng)的調(diào)度優(yōu)先級(jí)，從所述正常任務(wù)集合中取出待調(diào)度的目標(biāo)任務(wù)；

任務(wù)分發(fā)單元，用于依據(jù)所述目標(biāo)任務(wù)配置的任務(wù)執(zhí)行節(jié)點(diǎn)的信息，執(zhí)行所述目標(biāo)任務(wù)的分發(fā)處理；

異常處理單元，用于如所述目標(biāo)任務(wù)分發(fā)失敗，將所述目標(biāo)任務(wù)加入到異常任務(wù)集合，并返回執(zhí)行所述從所述正常任務(wù)集合中取出待調(diào)度的目標(biāo)任務(wù)的操作，直至所述正常任務(wù)集合中不存在未被分發(fā)的任務(wù)。