[發明專利]任務調度方法、裝置、計算機設備和存儲介質

在審

• 申請號: 202011027115.1
• 申請日: 2020-09-25
• 公開（公告）號: CN112162839A
• 公開（公告）日: 2021-01-01
• 發明（設計）人: 張德銀;劉豐;吳朝文
• 申請（專利權）人: 太平金融科技服務（上海）有限公司
• 主分類號: G06F9/48
• 分類號: G06F9/48;G06F9/50
• 代理公司: 廣州華進聯合專利商標代理有限公司 44224
• 代理人: 姜曉云

1.一種任務調度方法，其特征在于，所述方法包括：

接收待調度任務調度請求，所述待調度任務調度請求中攜帶有待調度任務標識；

獲取所述待調度任務標識對應的待調度任務；其中，所述待調度任務中包括多于一個的單片任務，并且每一個所述單片任務對應的任務類型相同；

計算各執行機對應的處理性能指標；

根據各所述處理性能指標確定分組比例，并根據所述分組比例將所述待調度任務中的各所述單片任務進行分組處理得到多個分組任務；

根據各所述執行機對應的處理性能指標將各所述分組任務分配至對應的所述執行機中，以指示所述執行機根據分配到的所述分組任務確定對應數量的處理線程，并根據各所述處理線程并行處理分配到的所述分組任務。

2.根據權利要求1所述的方法，其特征在于，所述計算各執行機對應的處理性能指標，包括：

獲取分配到各所述執行機中的待處理任務對應的待處理任務標識；

獲取各所述待處理任務標識對應的待處理任務，根據所述待處理任務計算得到當前資源負載率；

根據各所述當前資源負載率得到各所述執行機對應的處理性能指標。

3.根據權利要求2所述的方法，其特征在于，所述根據各所述當前資源負載率得到各所述執行機對應的處理性能指標，包括：

根據各所述執行機的當前資源負載率以及預設資源負載率得到各所述執行機對應的處理性能指標；其中，所述預設資源負載率是各所述執行機負載最大任務量時對應的負載率；

所述根據各所述處理性能指標確定分組比例，并根據所述分組比例將所述待調度任務中的各所述單片任務進行分組處理得到多個分組任務，包括：

根據所述處理性能指標從所述待調度任務中提取可分配待調度任務；

根據所述處理性能指標確定分組比例，并根據分組比例將所述可分配待調度任務中的各單片任務進行分組處理得到多個分組任務。

4.根據權利要求1所述的方法，其特征在于，所述根據各所述執行機對應的處理性能指標將各所述分組任務分配至對應的所述執行機中，以指示所述執行機根據分配到的所述分組任務確定對應數量的處理線程，并根據各所述處理線程并行處理分配到的所述分組任務，包括：

獲取所述待調度任務對應的預設處理時間；

根據各所述執行機對應的所述處理性能指標將各所述分組任務分配至對應的所述執行機中，獲取各執行機利用一個處理線程對分配到的所述分組任務進行處理時對應的實際處理時間；

根據所述預設處理時間以及所述實際處理時間確定各所述執行機中的處理線程的線程數量；

在各所述執行機中根據對應線程數量的處理線程對分配到的所述分組任務并行處理。

5.根據權利要求2所述的方法，其特征在于，所述獲取各執行機對應的處理性能指標之后，還包括：

當所述待調度任務對應為不可拆分的單任務時，將所述待調度任務分配至最大的所述處理性能指標對應的執行機中，以指示所述執行機處理分配到的所述任務；

當所述待調度任務對應為可拆分的多任務時，繼續根據所述處理性能指標將所述待調度任務進行分組處理得到多個分組任務。

6.根據權利要求5所述的方法，其特征在于，所述根據各所述處理性能指標確定分組比例，并根據所述分組比例將所述待調度任務中的各所述單片任務進行分組處理得到多個分組任務，包括：

獲取所述待調度任務對應的最小任務分組單元以及所述最小任務分組單元對應的分組單元數量；

當所述執行機數量小于所述分組單元數量時，根據各所述執行機的處理性能指標對應的數值構建分組比例，根據所述最小任務分組單元以及所述分組比例對所述待調度任務進行分組處理，得到分組單元數量符合所述分組比例的多個分組任務；

當所述執行機數量不小于所述分組單元數量時，將所述待調度任務劃分為最小任務分組單元對應的分組任務，按照所述處理性能指標從高到低的順序依次將所述分組任務分配至對應的執行機中。