[發明專利]一種任務調度系統、方法、設備及存儲介質

在審

• 申請號: 202011034859.6
• 申請日: 2020-09-27
• 公開（公告）號: CN112181621A
• 公開（公告）日: 2021-01-05
• 發明（設計）人: 史振華
• 申請（專利權）人: 中國建設銀行股份有限公司
• 主分類號: G06F9/48
• 分類號: G06F9/48
• 代理公司: 北京品源專利代理有限公司 11332
• 代理人: 孟金喆

1.一種任務調度系統，其特征在于，包括：定時調度模塊、任務掃描分發模塊、任務預處理模塊、任務執行模塊以及任務隊列；

定時調度模塊，用于將滿足定時調度條件的未處理任務，加入至任務隊列；

任務掃描分發模塊，用于掃描任務隊列中的未處理任務，并將滿足任務分發條件的任務分發至任務預處理模塊；

任務預處理模塊，用于在所分發的未處理任務中，為滿足任務編排條件的任務編排執行步驟，并將已編排任務提交至任務執行模塊；

任務執行模塊，用于將成功獲取的已編排任務按照匹配的執行步驟執行。

2.根據權利要求1所述的系統，其特征在于，所述定時調度模塊，具體用于：

當確定所述未處理任務到達觸發時間時，確定所述未處理任務是否存在監聽器；

當確定所述未處理任務不存在所述監聽器時，確定所述未處理任務滿足所述定時調度條件；

當確定所述未處理任務存在所述監聽器時，通過所述監聽器按照與所述未處理任務對應的預設檢測規則判斷所述未處理任務是否滿足業務觸發條件；

當確定所述未處理任務滿足業務觸發條件時，確定所述未處理任務滿足所述定時調度條件；

否則，確定所述未處理任務不滿足所述定時調度條件。

3.根據權利要求2所述的系統，其特征在于，所述定時調度模塊，具體又用于：

通過應用程序編程API接口配置所述未處理任務的任務參數；其中，所述任務參數包括所述未處理任務的監聽分組情況；

當所述未處理任務處于監聽器所對應的監聽分組時，確定所述未處理任務存在監聽器。

4.根據權利要求3所述的系統，其特征在于，所述任務掃描分發模塊，具體用于：

獲取所述未處理任務對應的任務并發度，并將滿足所述任務并發度的任務分發至所述任務預處理模塊。

5.根據權利要求4所述的系統，其特征在于，所述任務參數包括：任務編號、任務分類以及任務優先級；

所述任務掃描分發模塊，具體又用于：

根據所述任務編號、所述任務分類以及所述任務優先級確定所述未處理任務的任務分組結果以及排序結果；

根據所述任務分組結果以及所述排序結果，將滿足所述任務并發度的任務分發至所述任務預處理模塊。

6.根據權利要求5所述的系統，其特征在于，所述任務掃描分發模塊，具體又用于：

根據所述任務編號以及所述任務分類確定所述未處理任務的任務分組結果，并根據所述任務優先級確定任務分組后所述未處理任務的排序結果。

7.根據權利要求5或6所述的系統，其特征在于，所述任務掃描分發模塊，具體又用于：

當處于已編排任務和執行中的任務總數小于任務分組對應的所述任務并發度時，確定所述任務分組中的所述未處理任務滿足所述任務并發度，并將所述任務分組記為目標任務分組。

8.根據權利要求7所述的系統，其特征在于，所述任務掃描分發模塊，具體又用于：

在根據所述任務分組結果以及所述排序結果，將滿足所述任務并發度的任務分發至所述任務預處理模塊之前，獲取預設任務分組掃描閾值；

掃描任務隊列中不大于所述預設任務分組掃描閾值的所述目標任務分組中的所述未處理任務，并將掃描的所述未處理任務分發至所述任務預處理模塊。

9.根據權利要求1所述的系統，其特征在于，所述任務預處理模塊，具體用于：

通過至少一個預處理線程接收所述未處理任務，并以互斥加鎖方式為接收的未處理任務申請任務資源；

當所述未處理任務申請任務資源成功時，確定所述未處理任務滿足任務編排條件。