[發(fā)明專利]任務(wù)管理方法、系統(tǒng)、服務(wù)器集群和計算機可讀介質(zhì)

在審

• 申請?zhí)枺?/td>: 201810088229.3
• 申請日: 2018-01-29
• 公開（公告）號: CN110096344A
• 公開（公告）日: 2019-08-06
• 發(fā)明（設(shè)計）人: 杜剛;楊林
• 申請（專利權(quán)）人: 北京京東尚科信息技術(shù)有限公司;北京京東世紀(jì)貿(mào)易有限公司
• 主分類號: G06F9/48
• 分類號: G06F9/48;G06F9/54
• 代理公司: 中科專利商標(biāo)代理有限責(zé)任公司 11021
• 代理人: 呂雁葭

1.一種任務(wù)管理方法，包括：

獲取待處理任務(wù)，并將所述待處理任務(wù)存儲于待處理任務(wù)集合中；

將所述待處理任務(wù)集合中的待處理任務(wù)按照優(yōu)先級順序加入優(yōu)先級隊列中；

以限速的方式將所述優(yōu)先級隊列中的待處理任務(wù)轉(zhuǎn)移至消息隊列；

通過所述消息隊列將所述待處理任務(wù)分發(fā)至任務(wù)處理單元；以及

由所述任務(wù)處理單元處理所述待處理任務(wù)。

2.根據(jù)權(quán)利要求1所述的方法，其中，所述將所述待處理任務(wù)集合中的待處理任務(wù)按照優(yōu)先級順序加入優(yōu)先級隊列中包括：

按預(yù)設(shè)的時間周期，將所述待處理任務(wù)集合中滿足條件的待處理任務(wù)按照優(yōu)先級順序加入優(yōu)先級隊列，

其中，所述滿足條件的待處理任務(wù)包括以下至少一種：

待處理任務(wù)集合中未被處理過的任務(wù)；或者

曾執(zhí)行失敗但未達(dá)到最大重試次數(shù)的任務(wù)。

3.根據(jù)權(quán)利要求1所述的方法，其中，所述待處理任務(wù)執(zhí)行多次，所述將所述待處理任務(wù)集合中的待處理任務(wù)按照優(yōu)先級順序加入優(yōu)先級隊列中包括：

在多個待處理任務(wù)的優(yōu)先級一致的情況下，依據(jù)所述多個待處理任務(wù)前一次執(zhí)行的執(zhí)行時間的時間順序，將所述多個待處理任務(wù)加入優(yōu)先級隊列中，其中，前一次執(zhí)行的執(zhí)行時間較早的待處理任務(wù)優(yōu)先于前一次執(zhí)行的執(zhí)行時間較晚的待處理任務(wù)。

4.根據(jù)權(quán)利要求1所述的方法，其中，所述以限速的方式將所述優(yōu)先級隊列中的待處理任務(wù)轉(zhuǎn)移至消息隊列包括：

通過第一線程池獲取待處理任務(wù)，其中，所述第一線程池具有配置信息，所述配置信息用于限制所述第一線程池獲取待處理任務(wù)的速度，包括線程數(shù)、每次獲取待處理任務(wù)的數(shù)量或者休息時間中的至少一種；以及

通過第二線程池將所述第一線程池獲取的待處理任務(wù)轉(zhuǎn)移至消息隊列。

5.根據(jù)權(quán)利要求1所述的方法，其中，所述任務(wù)處理單元處理所述待處理任務(wù)包括：

確定所述待處理任務(wù)的任務(wù)狀態(tài)標(biāo)識；以及

在所述任務(wù)狀態(tài)標(biāo)識表明所述任務(wù)處于可用狀態(tài)的情況下，處理所述待處理任務(wù)。

6.根據(jù)權(quán)利要求5所述的方法，其中，所述在所述任務(wù)狀態(tài)標(biāo)識表明所述任務(wù)處于可執(zhí)行狀態(tài)的情況下，處理所述待處理任務(wù)包括：

在所述任務(wù)狀態(tài)標(biāo)識表明所述任務(wù)處于可用狀態(tài)的情況下，修改所述待處理任務(wù)的狀態(tài)為不可用狀態(tài)，并處理所述待處理任務(wù)。

7.根據(jù)權(quán)利要求6所述的方法，還包括以下至少一種：

在所述不可用狀態(tài)持續(xù)第一預(yù)設(shè)時間后，將所述任務(wù)狀態(tài)標(biāo)識修改為可用狀態(tài)，其中，所述第一預(yù)設(shè)時間不小于所述待處理任務(wù)的處理時間；

在所述待處理任務(wù)處理成功后，將所述任務(wù)狀態(tài)標(biāo)識修改為不可用狀態(tài)，并持續(xù)第二預(yù)設(shè)時間；或者

在所述待處理任務(wù)處理失敗后，將所述任務(wù)狀態(tài)標(biāo)識修改為可用狀態(tài)。

8.根據(jù)權(quán)利要求1所述的方法，還包括以下至少一種：

展示所述待處理任務(wù)集合的狀態(tài)信息；

展示所述消息隊列的狀態(tài)信息；或者

展示所述任務(wù)狀態(tài)標(biāo)識信息。

9.根據(jù)權(quán)利要求1所述的方法，還包括：

響應(yīng)于控制指令，將指定的待處理任務(wù)發(fā)送至任務(wù)處理單元，使所述任務(wù)處理單元處理所述指定的待處理任務(wù)。

10.一種任務(wù)管理系統(tǒng)，包括：

獲取模塊，用于獲取待處理任務(wù)，并將所述待處理任務(wù)存儲于待處理任務(wù)集合中；

處理模塊，用于將所述待處理任務(wù)集合中的待處理任務(wù)按照優(yōu)先級順序加入優(yōu)先級隊列中；

限速模塊，用于以限速的方式將所述優(yōu)先級隊列中的待處理任務(wù)轉(zhuǎn)移至消息隊列；

分發(fā)模塊，用于通過所述消息隊列將所述待處理任務(wù)分發(fā)至任務(wù)處理單元；以及

執(zhí)行模塊，用于由所述任務(wù)處理單元處理所述待處理任務(wù)。