[發明專利]任務處理方法、裝置、電子設備和存儲介質

在審

• 申請號: 202310012740.6
• 申請日: 2023-01-05
• 公開（公告）號: CN116048757A
• 公開（公告）日: 2023-05-02
• 發明（設計）人: 鄭振宇
• 申請（專利權）人: 北京達佳互聯信息技術有限公司
• 主分類號: G06F9/48
• 分類號: G06F9/48
• 代理公司: 華進聯合專利商標代理有限公司 44224
• 代理人: 鄧云鵬

本公開關于一種任務處理方法、裝置、電子設備和存儲介質。所述方法包括：獲取工作流中的多個目標節點任務；所述工作流包括多個節點任務，所述多個目標節點任務為所述多個節點任務中相互獨立的節點任務；并發執行所述多個目標節點任務；在并發執行過程中，對于當前已完成的目標節點任務，獲取所述已完成的目標節點任務的第一子節點任務，并發執行所述第一子節點任務和其他未完成的目標節點任務；所述第一子節點任務在所述工作流中單依賴于所述已完成的目標節點任務。本公開方案中，可以在并發執行的多個任務中存在未完成任務時，繼續執行單依賴于已完成任務的子節點任務，減少任務處理過程中的等待時間，提高任務處理效率。

技術領域

本公開涉及計算機技術領域，尤其涉及一種任務處理方法、裝置、電子設備和存儲介質。

背景技術

隨著計算機技術發展，在處理包含多個節點任務的工作流時，為了優化各個節點任務的調度效率，處理設備可以根據工作流中各個任務節點的依賴關系執行多個節點任務。

在相關技術中，為了提高任務處理效率，可以通過層序遍歷的方式處理多個節點任務，具體而言，在層序遍歷中，可以逐層地進行節點任務處理，針對同層相互獨立的節點任務可以并發處理，避免逐一依次執行。

然而，在實際處理節點任務的過程中，不同節點任務的處理時間長短不一，容易出現處理較快、更早完成的節點任務等待未完成節點任務處理完畢的情況，任務處理效率較低。

發明內容

本公開提供一種任務處理方法、裝置、電子設備和存儲介質，以至少解決相關技術中任務處理效率較低的問題。本公開的技術方案如下：

根據本公開實施例的第一方面，提供一種任務處理方法，包括：

獲取工作流中的多個目標節點任務；所述工作流包括多個節點任務，所述多個目標節點任務為所述多個節點任務中相互獨立的節點任務；

并發執行所述多個目標節點任務；

在并發執行過程中，對于當前已完成的目標節點任務，獲取所述已完成的目標節點任務的第一子節點任務，并發執行所述第一子節點任務和其他未完成的目標節點任務；所述第一子節點任務在所述工作流中單依賴于所述已完成的目標節點任務。

在一示例性實施例中，所述并發執行所述多個目標節點任務，包括：

調用多個線程并發執行所述多個目標節點任務；

所述并發執行所述第一子節點任務和其他未完成的目標節點任務，包括：

確定所述已完成的目標節點任務對應的線程為目標線程；

基于所述目標線程執行所述第一子節點任務，以及基于其他線程繼續執行其他未完成的目標節點任務，所述其他線程為所述多個線程中除所述目標線程以外的線程。

在一示例性實施例中，所述基于所述目標線程執行所述第一子節點任務，包括：

在所述已完成的目標節點任務執行結束后，保持所述目標線程的占用狀態；

將所述第一子節點任務確定為新的目標節點任務，并基于處于占用狀態的所述目標線程繼續執行所述新的目標節點任務；

所述并發執行所述第一子節點任務和其他未完成的目標節點任務之后，還包括：

返回在并發執行過程中，對于當前已完成的目標節點任務，獲取所述已完成的目標節點任務的第一子節點任務的步驟，直到各個目標節點任務完成。

在一示例性實施例中，所述將所述第一子節點任務確定為目標節點任務，利用處于占用狀態中的所述目標線程繼續執行所述目標節點任務，包括：

若所述第一子節點任務為多個，則將多個第一子節點任務確定為多個新的目標節點任務；