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

在審

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

本發(fā)明公開(kāi)了一種任務(wù)調(diào)度方法、裝置、設(shè)備及存儲(chǔ)介質(zhì)，在本發(fā)明中，任務(wù)調(diào)度系統(tǒng)的調(diào)度節(jié)點(diǎn)將待處理的工作流中的至少一個(gè)任務(wù)存儲(chǔ)到正常任務(wù)集合；按照正常任務(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ù)。本發(fā)明可以減少由于任務(wù)執(zhí)行節(jié)點(diǎn)異常而導(dǎo)致任務(wù)調(diào)度阻塞的情況。

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

本發(fā)明涉及計(jì)算機(jī)技術(shù)領(lǐng)域，尤其涉及一種任務(wù)調(diào)度方法、裝置、設(shè)備及存儲(chǔ)介質(zhì)。

背景技術(shù)

工作流是對(duì)工作流程及工作流程中各操作步驟之間業(yè)務(wù)規(guī)則的抽象以及概括描述。工作流一般包括一個(gè)或者多個(gè)任務(wù)(task)，每個(gè)任務(wù)代表需要執(zhí)行的某項(xiàng)工作。通過(guò)任務(wù)調(diào)度系統(tǒng)可以對(duì)工作流中的任務(wù)進(jìn)行任務(wù)調(diào)度，以將工作流中的任務(wù)分發(fā)給任務(wù)執(zhí)行節(jié)點(diǎn)中的任務(wù)執(zhí)行程序運(yùn)行。

在任務(wù)調(diào)度過(guò)程中，如果某個(gè)任務(wù)指定的任務(wù)執(zhí)行節(jié)點(diǎn)上的任務(wù)執(zhí)行程序存在異常，而會(huì)導(dǎo)致該任務(wù)分發(fā)失敗。然而，任務(wù)調(diào)度系統(tǒng)需要按照工作流中各任務(wù)的先后順序依次調(diào)度各個(gè)任務(wù)，因此，如果某個(gè)任務(wù)分發(fā)失敗，則會(huì)導(dǎo)致工作流中該任務(wù)之后的其他任務(wù)的調(diào)度被阻塞，從而影響到工作流的處理效率。

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

鑒于上述問(wèn)題，本發(fā)明提供一種克服上述問(wèn)題或者至少部分地解決上述問(wèn)題的一種任務(wù)調(diào)度方法、裝置、設(shè)備及存儲(chǔ)介質(zhì)。

一方面，本申請(qǐng)?zhí)峁┝艘环N任務(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ù)。

優(yōu)選的，在所述將所述目標(biāo)任務(wù)加入到異常任務(wù)集合之后，還包括：

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

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

優(yōu)選的，在將所述目標(biāo)任務(wù)加入到異常任務(wù)集合之后，還包括：

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

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

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

優(yōu)選的，如所述目標(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ù)集合。

優(yōu)選的，所述將待處理的工作流中的至少一個(gè)任務(wù)存儲(chǔ)到正常任務(wù)集合，包括：