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

在審

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

本申請涉及一種任務調度方法、裝置、計算機設備和存儲介質。方法包括：接收待調度任務調度請求，待調度任務調度請求中攜帶有待調度任務標識；獲取待調度任務標識對應的待調度任務；其中，待調度任務中包括多于一個的單片任務；并且每一個所述單片任務對應的任務類型相同計算各執行機對應的處理性能指標；根據各處理性能指標確定分組比例，并根據分組比例將待調度任務進行分組處理得到多個分組任務；根據各執行機中的各單片任務對應的處理性能指標將各分組任務分配至對應的執行機中，以指示執行機處理根據分配到的分組任務確定對應數量的處理線程，并根據各處理線程并行分配到的分組任務。通過該方法能夠提高任務執行的效率。

技術領域

本申請涉及計算機技術領域，特別是涉及一種任務調度方法、裝置、計算機設備和存儲介質。

背景技術

隨著互聯網技術的快速發展，各行業的數據需求量不斷增大，隨之而產生的大量任務需要處理。例如任務數據可以通過任務調度的形式定時、批量、有效地進行處理，如目前常用的Quartz任務調度，Quartz是一個完全由Java編寫的開源作業調度架構，待調度任務以作業的概念進行存儲，調度機通過觸發機來調用作業，Quartz支持豐富多樣的調度，調度數據的多種存儲方式，滿足各種常規及特殊需求。

但是任務調度的過程中是在多節點下部署，通過競爭數據庫鎖來保證只有一個任務在執行，雖然解決了集群高可用的問題，但是同一個任務只能有一個節點運行，導致任務的執行效率低下。

發明內容

基于此，有必要針對上述技術問題，提供一種能夠提高任務執行效率的任務調度方法、裝置、計算機設備和存儲介質。

一種任務調度方法，方法包括：接收待調度任務調度請求，待調度任務調度請求中攜帶有待調度任務標識；獲取待調度任務標識對應的待調度任務；其中，待調度任務中包括多于一個的單片任務，并且每一個單片任務對應的任務類型相同；計算各執行機對應的處理性能指標；根據各處理性能指標確定分組比例，并根據分組比例將待調度任務中的各單片任務進行分組處理得到多個分組任務；根據各執行機對應的處理性能指標將各分組任務分配至對應的執行機中，以指示執行機根據分配到的分組任務確定對應數量的處理線程，并根據各處理線程并行處理分配到的分組任務。

在一個實施例中，計算各執行機對應的處理性能指標，包括：獲取分配到各執行機中的待處理任務對應的待處理任務標識；獲取各待處理任務標識對應的待處理任務，根據待處理任務計算得到當前資源負載率；根據各當前資源負載率得到各執行機對應的處理性能指標。

在一個實施例中，根據各當前資源負載率得到各執行機對應的處理性能指標，包括：根據各執行機的當前資源負載率以及預設資源負載率得到各執行機對應的處理性能指標；其中，預設資源負載率是各執行機負載最大任務量時對應的負載率；根據各處理性能指標確定分組比例，并根據分組比例將待調度任務中的各單片任務進行分組處理得到多個分組任務，包括：根據處理性能指標從待調度任務中提取可分配待調度任務；根據處理性能指標確定分組比例，并根據分組比例將可分配待調度任務中的各單片任務進行分組處理得到多個分組任務。

在一個實施例中，方法還包括：根據各執行機對應的處理性能指標將各分組任務分配至對應的執行機中，以指示執行機根據分配到的分組任務確定對應數量的處理線程，并根據各處理線程并行處理分配到的分組任務，包括：獲取待調度任務對應的預設處理時間；根據各執行機對應的處理性能指標將各分組任務分配至對應的執行機中，獲取各執行機利用一個處理線程對分配到的分組任務進行處理對應的實際處理時間；根據預設處理時間以及實際處理時間確定各執行機中的處理線程的線程數量；在各執行機中根據對應線程數量的處理線程對分配到的分組任務并行處理。

在一個實施例中，獲取各執行機對應的處理性能指標之后，還包括：當待調度任務對應為不可拆分的單任務時，將待調度任務分配至最大的處理性能指標對應的執行機中，以指示執行機處理分配到的任務；當待調度任務對應為可拆分的多任務時，繼續根據處理性能指標將待調度任務進行分組處理得到多個分組任務。