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

有效

• 申請號: 202310714837.1
• 申請日: 2023-06-15
• 公開（公告）號: CN116483544B
• 公開（公告）日: 2023-09-19
• 發明（設計）人: 劉璐;何煒龍
• 申請（專利權）人: 阿里健康科技（杭州）有限公司
• 主分類號: G06F9/48
• 分類號: G06F9/48;G06Q10/0631;G06Q30/0601;G16H20/10
• 代理公司: 北京布瑞知識產權代理有限公司 11505
• 代理人: 周達

本說明書實施方式提供了一種任務處理方法、裝置、計算機設備和存儲介質。所述方法包括：接收目標數據處理任務；按照指定順序在多個任務隊列中確定最先存在空閑位置的目標任務隊列；將目標數據處理任務加入目標任務隊列；多個任務隊列分別對應有任務消費模塊；任務消費模塊用于批處理相應任務隊列中的數據處理任務。本說明書實施方式通過按照指定順序在多個任務隊列中確定最先存在空閑位置的目標任務隊列，并將接收到的目標數據處理任務加入該目標任務隊列以用于填充該目標任務隊列中的空閑位置，使得該目標任務隊列的等待新任務加入的時間較短，縮短了任務隊列的“攢批”時間，降低了應用整體的任務處理延遲，進而一定程度降低了應用的響應延遲。

技術領域

本說明書中實施方式關于云計算領域，具體關于一種任務處理方法、裝置、計算機設備和存儲介質。

背景技術

隨著網絡搜索、電子商務、社交網絡等在線數據密集型應用的發展，在線數據密集型應用對響應速度提出了越來越高的要求。因此，如何降低該應用的響應延遲成為了亟待解決的問題。任務處理延遲是影響該應用響應延遲的關鍵因素，而對多個任務進行批處理是降低任務處理延遲的重要手段。

目前，對多個任務進行批處理主要通過“排隊”、“攢批”和“批處理”三個過程實現。在需要處理的任務數量較多的情況下，可能存在多個任務隊列。此時，若出現新任務，則需要在多個存在空閑位置的任務隊列中為新任務指派加入的隊列。通常情況下，會將新任務指派給任務數量最少的任務隊列，以維持每個任務隊列的均衡，然而也可能導致較先存在空閑位置的隊列等待較長時間才有新任務加入，使得隊列的“攢批”時間較長，導致隊列任務處理延遲較高，進而影響應用的響應延遲。

因此，相關技術中存在任務隊列形成批處理的效率較低的技術問題。

發明內容

有鑒于此，本說明書中多個實施方式致力于提供一種任務處理方法、裝置、計算機設備和存儲介質，以一定程度上縮短較先存在空閑位置的隊列等待新任務加入的時間，從而提升整體上提升了針對任務進行批處理的效率。

本說明書中一個實施方式提供一種任務處理方法，包括：接收目標數據處理任務；按照指定順序在多個任務隊列中確定最先存在空閑位置的目標任務隊列；其中，多個任務隊列分別對應有任務消費模塊；所述任務消費模塊用于批處理相應任務隊列中的數據處理任務；將所述目標數據處理任務加入所述目標任務隊列。

本說明書的一個實施方式提供一種任務處理裝置，包括：接收模塊，用于接收目標數據處理任務；確定模塊，用于按照指定順序在多個任務隊列中確定最先存在空閑位置的目標任務隊列；其中，多個任務隊列分別對應有任務消費模塊；所述任務消費模塊用于批處理相應任務隊列中的數據處理任務；入隊模塊，用于將所述目標數據處理任務加入所述目標任務隊列。

本說明書實施方式提出一種計算機設備，包括存儲器和處理器，所述存儲器存儲有計算機程序，所述處理器執行所述計算機程序時實現上述實施方式所述的方法。

本說明書實施方式提供一種計算機可讀存儲介質，其上存儲有計算機程序指令，該程序被處理器執行時實現上述實施方式所述的方法。

本說明書提供的多個實施方式，通過在多個任務隊列中確定最先存在空閑位置的目標任務隊列，并將接收到的目標數據處理任務加入該目標任務隊列以用于填充該空閑位置，使得該目標任務隊列的等待新任務加入的時間較短，即，目標任務隊列可以在較短時間內完成“攢批”以進行“批處理”，縮短了任務隊列的“攢批”時間，降低了應用整體的任務處理延遲，進而降低了應用的響應延遲。

附圖說明

圖1為本說明書的一個實施方式提供的任務處理系統的多端交互示意圖。

圖2為本說明書的一個實施方式提供的任務處理系統中的服務器內部數據傳輸示意圖。

圖3為本說明書的一個實施方式提供的任務處理方法的流程示意圖。