[發(fā)明專利]任務(wù)調(diào)度方法、裝置、計(jì)算機(jī)設(shè)備和計(jì)算機(jī)可讀介質(zhì)

在審

• 申請?zhí)枺?/td>: 201910905458.4
• 申請日: 2019-09-24
• 公開（公告）號: CN112631764A
• 公開（公告）日: 2021-04-09
• 發(fā)明（設(shè)計(jì)）人: 韓大鶴
• 申請（專利權(quán)）人: 中興通訊股份有限公司
• 主分類號: G06F9/50
• 分類號: G06F9/50;G06F9/48;G06F9/54;G06F16/25
• 代理公司: 北京天昊聯(lián)合知識產(chǎn)權(quán)代理有限公司 11112
• 代理人: 姜春咸;劉悅晗

1.一種任務(wù)調(diào)度方法，應(yīng)用于第一調(diào)度裝置，所述第一調(diào)度裝置被配置為集群內(nèi)的主調(diào)度裝置，所述方法包括：

根據(jù)任務(wù)隊(duì)列中的任務(wù)的最小資源需求單元以及集群內(nèi)各執(zhí)行節(jié)點(diǎn)上報(bào)的資源總量和資源使用情況，確定用于執(zhí)行所述任務(wù)的執(zhí)行節(jié)點(diǎn)，所述任務(wù)隊(duì)列中的任務(wù)滿足相應(yīng)的任務(wù)啟動(dòng)條件；

將所述任務(wù)從所述任務(wù)隊(duì)列中取出并分發(fā)到所述執(zhí)行節(jié)點(diǎn)中。

2.如權(quán)利要求1所述的方法，其中，所述根據(jù)任務(wù)隊(duì)列中的任務(wù)的最小資源需求單元以及集群內(nèi)各執(zhí)行節(jié)點(diǎn)上報(bào)的資源總量和資源使用情況，確定用于執(zhí)行所述任務(wù)的執(zhí)行節(jié)點(diǎn)，包括：

根據(jù)任務(wù)隊(duì)列中的任務(wù)的最小資源需求單元以及集群內(nèi)各執(zhí)行節(jié)點(diǎn)上報(bào)的資源總量和資源使用情況，分別計(jì)算集群內(nèi)各執(zhí)行節(jié)點(diǎn)能夠執(zhí)行所述任務(wù)的最小資源需求單元的數(shù)量；

確定所述數(shù)量最多的執(zhí)行節(jié)點(diǎn)，并將所述執(zhí)行節(jié)點(diǎn)作為用于執(zhí)行所述任務(wù)的執(zhí)行節(jié)點(diǎn)。

3.如權(quán)利要求2所述的方法，其中，所述確定所述數(shù)量最多的執(zhí)行節(jié)點(diǎn)，并將所述執(zhí)行節(jié)點(diǎn)作為用于執(zhí)行所述任務(wù)的執(zhí)行節(jié)點(diǎn)，包括：

若所述數(shù)量最多的執(zhí)行節(jié)點(diǎn)為至少兩個(gè)，則從中選擇節(jié)點(diǎn)類型與所述任務(wù)的任務(wù)類型不對應(yīng)的執(zhí)行節(jié)點(diǎn)作為用于執(zhí)行所述任務(wù)的執(zhí)行節(jié)點(diǎn)。

4.如權(quán)利要求1所述的方法，其中，所述將所述任務(wù)從所述任務(wù)隊(duì)列中取出并分發(fā)到所述執(zhí)行節(jié)點(diǎn)中之后，還包括：

按照預(yù)設(shè)的第一周期從所述執(zhí)行節(jié)點(diǎn)獲取所述任務(wù)的狀態(tài)；

若根據(jù)所述任務(wù)的狀態(tài)確定出所述任務(wù)啟動(dòng)失敗，則將所述任務(wù)放入所述任務(wù)隊(duì)列中。

5.如權(quán)利要求1所述的方法，其中，還包括以下步驟之一或任意組合：

記錄所述任務(wù)的任務(wù)信息與節(jié)點(diǎn)地址之間的映射關(guān)系，并將所述映射關(guān)系同步到第二調(diào)度裝置，所述第二調(diào)度裝置當(dāng)前被配置為備份調(diào)度裝置；

將所述任務(wù)隊(duì)列同步到所述第二調(diào)度裝置；

將集群內(nèi)各執(zhí)行節(jié)點(diǎn)上報(bào)的資源使用情況同步到所述第二調(diào)度裝置；

所述方法還包括：

當(dāng)所述任務(wù)結(jié)束時(shí)，刪除與所述任務(wù)對應(yīng)的任務(wù)信息與節(jié)點(diǎn)地址之間的映射關(guān)系和/或任務(wù)隊(duì)列中的所述任務(wù)，并同步更新所述第二調(diào)度裝置存儲的任務(wù)信息與節(jié)點(diǎn)地址之間的映射關(guān)系和/或任務(wù)隊(duì)列。

6.如權(quán)利要求1-5任一項(xiàng)所述的方法，其中，還包括：

接收廣播消息，所述廣播消息包括第二調(diào)度裝置的地址；

將本設(shè)備配置為備份調(diào)度裝置。

7.如權(quán)利要求6所述的方法，其中，所述將本設(shè)備配置為備份調(diào)度裝置之后，還包括：

按照預(yù)設(shè)的第二周期獲取所述第二調(diào)度裝置的系統(tǒng)狀態(tài)信息，其中，所述第二調(diào)度裝置當(dāng)前被配置為主調(diào)度裝置；

若根據(jù)所述系統(tǒng)狀態(tài)信息確定出所述第二調(diào)度裝置工作異常，則在集群內(nèi)廣播本設(shè)備的地址，并將本設(shè)備配置為主調(diào)度裝置。

8.一種調(diào)度裝置，所述調(diào)度裝置能夠被配置為集群內(nèi)的主調(diào)度裝置，包括節(jié)點(diǎn)確定模塊和任務(wù)調(diào)度模塊；

所述節(jié)點(diǎn)確定模塊用于，根據(jù)任務(wù)隊(duì)列中的任務(wù)的最小資源需求單元以及集群內(nèi)各執(zhí)行節(jié)點(diǎn)上報(bào)的資源總量和資源使用情況，確定用于執(zhí)行所述任務(wù)的執(zhí)行節(jié)點(diǎn)，所述任務(wù)隊(duì)列中的任務(wù)滿足相應(yīng)的任務(wù)啟動(dòng)條件；

所述任務(wù)調(diào)度模塊用于，將所述任務(wù)從所述任務(wù)隊(duì)列中取出并分發(fā)到所述執(zhí)行節(jié)點(diǎn)中。

9.一種計(jì)算機(jī)設(shè)備，包括：

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

存儲裝置，其上存儲有一個(gè)或多個(gè)程序；

當(dāng)所述一個(gè)或多個(gè)程序被所述一個(gè)或多個(gè)處理器執(zhí)行時(shí)，使得所述一個(gè)或多個(gè)處理器實(shí)現(xiàn)如權(quán)利要求1-7任一項(xiàng)所述的任務(wù)調(diào)度方法。

10.一種計(jì)算機(jī)可讀介質(zhì)，其上存儲有計(jì)算機(jī)程序，其中，所述程序被執(zhí)行時(shí)實(shí)現(xiàn)如權(quán)利要求1-7任一項(xiàng)所述的任務(wù)調(diào)度方法。