[發明專利]一種任務調度方法、裝置、設備及可讀存儲介質

在審

• 申請號: 202111119452.8
• 申請日: 2021-09-24
• 公開（公告）號: CN113835859A
• 公開（公告）日: 2021-12-24
• 發明（設計）人: 張揚;李成才;鄧柯
• 申請（專利權）人: 成都質數斯達克科技有限公司
• 主分類號: G06F9/48
• 分類號: G06F9/48
• 代理公司: 暫無信息
• 代理人: 暫無信息

本發明涉及任務調度技術領域，具體而言，涉及一種任務調度方法、裝置、設備及可讀存儲介質，該方法包括：獲取多個執行失敗的任務，并將所述執行失敗的任務錄入第一任務清單，并記為待執行任務；在所述第一任務清單中撈取多個所述待執行的任務，并將被撈取的所述待執行的任務記為第一補償任務；根據每個所述第一補償任務的類型，分別將每個所述第一補償任務發送到對應的令牌桶內，本發明通過將執行失敗的任務根據其類型，分發到對應的指令桶內，利用指令桶限制執行某一具體類型的任務的線程數，進而有效避免當所有任務都捕撈起來并執行時，可能會超出線程池的處理能力，導致任務堆積的問題，極大地增加了系統的運行速度。

技術領域

本發明涉及任務調度技術領域，具體而言，涉及一種任務調度方法、裝置、設備及可讀存儲介質。

背景技術

傳統任務補償機制，會有一個定時任務把失敗的任務定時捕撈起來執行,執行成功會把任務狀態扭轉為已成功，但上述任務補償方法存在當所有任務都捕撈起來并執行時，可能會超出線程池的處理能力，導致任務堆積的問題，極大地降低了系統的運行速度。

發明內容

本發明的目的在于提供一種任務調度方法、裝置、設備及可讀存儲介質，以改善上述問題。

為了實現上述目的，本申請實施例提供了如下技術方案：

一方面，本申請實施例提供了一種任務調度方法，所述方法包括：獲取多個執行失敗的任務，并將所述執行失敗的任務錄入第一任務清單，并記為待執行任務；

在所述第一任務清單中撈取多個所述待執行的任務，并將被撈取的所述待執行的任務記為第一補償任務；

根據每個所述第一補償任務的類型，分別將每個所述第一補償任務發送到對應的令牌桶內，所述令牌桶用于為所述第一補償任務匹配運行編號，且每個所述指令桶所擁有的標號數量為有限個數，所述運行編號用于觸發線程池調度器根據所述運行編號的大小將對應的所述第一補償任務調入處理器的任務線程中。

可選地，所述將執行失敗的任務錄入第一任務清單，并記為待執行任務，包括：

獲取所述執行失敗的任務的任務信息，所述任務信息包括失敗任務類型和失敗次數；

根據所述失敗任務類型匹配對應的失敗降級策略；

根據所述失敗降級策略和所述失敗次數，計算得到所述執行失敗的任務的重啟時間；

將所述執行失敗的任務和對應的所述重啟時間均記錄在所述第一任務清單上。

可選地，所述在所述第一任務清單中撈取多個所述待執行的任務，包括：

獲取第一間隔時間段，所述第一時間段為兩次相鄰的撈取多個所述待執行的任務的間隔時長；

在所述第一任務清單中調取重啟時間在所述第一間隔時間段內的多個所述待執行任務，并將被調取的所述待執行任務記為第一補償任務。

可選地，所述根據每個所述第一補償任務的類型，分別將每個所述第一補償任務發送到對應的令牌桶內，包括：

調取所述第一補償任務；

檢測所述第一補償任務的類型，并根據所述第一補償任務的類型找到對應的所述令牌桶，記為第一令牌桶；

檢測當前所述令牌桶的空閑指令數，若所述空閑指令數為非零值，則將所述第一補償任務發送到所述第一令牌桶。

第二方面，本申請實施例提供了一種任務調度裝置，所述裝置包括：

第一計算模塊，用于獲取多個執行失敗的任務，并將所述執行失敗的任務錄入第一任務清單，并記為待執行任務；

第二計算模塊，用于在所述第一任務清單中撈取多個所述待執行的任務，將所述待執行的任務記為第一補償任務；