[發(fā)明專利]任務(wù)管理方法、裝置、系統(tǒng)、計(jì)算機(jī)存儲(chǔ)介質(zhì)及電子設(shè)備

在審

• 申請(qǐng)?zhí)枺?/td>: 202010064754.9
• 申請(qǐng)日: 2020-01-20
• 公開（公告）號(hào): CN111290854A
• 公開（公告）日: 2020-06-16
• 發(fā)明（設(shè)計(jì)）人: 曹智穎
• 申請(qǐng)（專利權(quán)）人: 騰訊科技（深圳）有限公司
• 主分類號(hào): G06F9/50
• 分類號(hào): G06F9/50;G06F11/07;G06F16/27
• 代理公司: 深圳市隆天聯(lián)鼎知識(shí)產(chǎn)權(quán)代理有限公司 44232
• 代理人: 葉虹

1.一種任務(wù)管理方法，其特征在于，所述任務(wù)管理方法應(yīng)用于分布式任務(wù)管理系統(tǒng)，所述分布式任務(wù)管理系統(tǒng)包括任務(wù)調(diào)度服務(wù)器和與所述任務(wù)調(diào)度服務(wù)器中的多個(gè)任務(wù)調(diào)度服務(wù)所對(duì)應(yīng)的節(jié)點(diǎn)，其中所述任務(wù)調(diào)度服務(wù)用于管理、調(diào)度用戶的任務(wù)；所述方法包括：

各所述任務(wù)調(diào)度服務(wù)監(jiān)聽與所述節(jié)點(diǎn)對(duì)應(yīng)的父節(jié)點(diǎn)；

在監(jiān)聽到所述節(jié)點(diǎn)中存在被刪除的第一節(jié)點(diǎn)時(shí)，通過目標(biāo)任務(wù)調(diào)度服務(wù)創(chuàng)建與所述第一節(jié)點(diǎn)對(duì)應(yīng)的第二節(jié)點(diǎn)，所述第二節(jié)點(diǎn)對(duì)應(yīng)的目標(biāo)任務(wù)調(diào)度服務(wù)不同于與所述第一節(jié)點(diǎn)對(duì)應(yīng)的任務(wù)調(diào)度服務(wù)；

所述目標(biāo)任務(wù)調(diào)度服務(wù)從數(shù)據(jù)庫(kù)中獲取與所述第一節(jié)點(diǎn)對(duì)應(yīng)的任務(wù)信息，并將所述任務(wù)信息添加至與所述目標(biāo)任務(wù)調(diào)度服務(wù)對(duì)應(yīng)的任務(wù)隊(duì)列中。

2.根據(jù)權(quán)利要求1所述的任務(wù)管理方法，其特征在于：

通過各所述任務(wù)調(diào)度服務(wù)在分布式協(xié)調(diào)服務(wù)系統(tǒng)中進(jìn)行注冊(cè)，以獲取與各所述任務(wù)調(diào)度服務(wù)對(duì)應(yīng)的具有不同節(jié)點(diǎn)編號(hào)的節(jié)點(diǎn)。

3.根據(jù)權(quán)利要求1所述的任務(wù)管理方法，其特征在于，在將所述任務(wù)信息添加至與所述目標(biāo)任務(wù)調(diào)度服務(wù)對(duì)應(yīng)的任務(wù)隊(duì)列中之后，所述方法還包括：

將所述任務(wù)信息對(duì)應(yīng)的任務(wù)調(diào)度服務(wù)標(biāo)識(shí)修改為與所述目標(biāo)任務(wù)調(diào)度服務(wù)對(duì)應(yīng)的任務(wù)調(diào)度服務(wù)標(biāo)識(shí)。

4.根據(jù)權(quán)利要求1所述的任務(wù)管理方法，其特征在于，所述分布式任務(wù)管理系統(tǒng)還包括任務(wù)管理服務(wù)器和任務(wù)執(zhí)行服務(wù)器；

所述任務(wù)調(diào)度服務(wù)器接收所述任務(wù)管理服務(wù)器發(fā)送的待執(zhí)行任務(wù)，并根據(jù)所述待執(zhí)行任務(wù)形成任務(wù)執(zhí)行請(qǐng)求；

將所述任務(wù)執(zhí)行請(qǐng)求發(fā)送至所述任務(wù)執(zhí)行服務(wù)器，以使所述任務(wù)執(zhí)行服務(wù)器中的任務(wù)執(zhí)行服務(wù)執(zhí)行任務(wù)。

5.根據(jù)權(quán)利要求4所述的任務(wù)管理方法，其特征在于，所述任務(wù)調(diào)度服務(wù)器接收所述任務(wù)管理服務(wù)器發(fā)送的待執(zhí)行任務(wù)，并根據(jù)所述待執(zhí)行任務(wù)形成任務(wù)執(zhí)行請(qǐng)求，包括：

將所述待執(zhí)行任務(wù)添加至與所述任務(wù)調(diào)度服務(wù)對(duì)應(yīng)的任務(wù)隊(duì)列中，并判斷所述任務(wù)調(diào)度服務(wù)的線程池中是否存在空閑線程；

當(dāng)存在所述空閑線程時(shí)，從與所述任務(wù)調(diào)度服務(wù)對(duì)應(yīng)的任務(wù)隊(duì)列中拉取所述待執(zhí)行任務(wù)，并獲取所述待執(zhí)行任務(wù)中的子任務(wù)；

根據(jù)所述子任務(wù)的屬性信息和所述子任務(wù)形成所述任務(wù)執(zhí)行請(qǐng)求。

6.根據(jù)權(quán)利要求5所述的任務(wù)管理方法，其特征在于，所述根據(jù)所述子任務(wù)的屬性信息和所述子任務(wù)形成所述任務(wù)執(zhí)行請(qǐng)求，包括：

判斷所述子任務(wù)是否為待執(zhí)行子任務(wù)；

當(dāng)判定所述子任務(wù)為待執(zhí)行子任務(wù)時(shí)，根據(jù)所述待執(zhí)行子任務(wù)形成所述任務(wù)執(zhí)行請(qǐng)求。

7.根據(jù)權(quán)利要求4所述的任務(wù)管理方法，其特征在于，所述任務(wù)執(zhí)行服務(wù)的數(shù)量為多個(gè)，并且各所述任務(wù)執(zhí)行服務(wù)具有不同的任務(wù)類型標(biāo)簽；

所述將所述任務(wù)執(zhí)行請(qǐng)求發(fā)送至所述任務(wù)執(zhí)行服務(wù)器，以使所述任務(wù)執(zhí)行服務(wù)器中的任務(wù)執(zhí)行服務(wù)執(zhí)行任務(wù)，包括：

將所述任務(wù)執(zhí)行請(qǐng)求中待執(zhí)行任務(wù)的任務(wù)類型與所述任務(wù)類型標(biāo)簽進(jìn)行匹配，以確定目標(biāo)任務(wù)執(zhí)行服務(wù)；

將所述任務(wù)執(zhí)行請(qǐng)求發(fā)送至所述目標(biāo)任務(wù)執(zhí)行服務(wù)，以使所述目標(biāo)任務(wù)執(zhí)行服務(wù)執(zhí)行任務(wù)。

8.根據(jù)權(quán)利要求4所述的任務(wù)管理方法，其特征在于，在將所述任務(wù)執(zhí)行請(qǐng)求發(fā)送至所述任務(wù)執(zhí)行服務(wù)器之后，所述方法還包括：

查詢所述待執(zhí)行子任務(wù)是否執(zhí)行完成；

若所述待執(zhí)行子任務(wù)執(zhí)行完成，則更新所述數(shù)據(jù)庫(kù)中與所述待執(zhí)行任務(wù)對(duì)應(yīng)的任務(wù)進(jìn)度信息；

若所述待執(zhí)行子任務(wù)執(zhí)行未完成，則將所述待執(zhí)行任務(wù)重新添加至與所述任務(wù)調(diào)度服務(wù)對(duì)應(yīng)的任務(wù)隊(duì)列中。

9.根據(jù)權(quán)利要求8所述的任務(wù)管理方法，其特征在于，在更新所述數(shù)據(jù)庫(kù)中與所述待執(zhí)行任務(wù)對(duì)應(yīng)的任務(wù)進(jìn)度信息之后，所述方法還包括：

判斷所述待執(zhí)行任務(wù)中是否存在未執(zhí)行子任務(wù)；

若存在，則在所述未執(zhí)行子任務(wù)為待執(zhí)行子任務(wù)時(shí)執(zhí)行所述未執(zhí)行子任務(wù)，直至所述待執(zhí)行任務(wù)中不存在未執(zhí)行子任務(wù)；

若不存在，則更新所述數(shù)據(jù)庫(kù)中與所述待執(zhí)行任務(wù)對(duì)應(yīng)的任務(wù)狀態(tài)信息。