[發(fā)明專利]任務(wù)處理方法、裝置、計(jì)算機(jī)設(shè)備和存儲介質(zhì)

有效

• 申請?zhí)枺?/td>: 202310714837.1
• 申請日: 2023-06-15
• 公開（公告）號: CN116483544B
• 公開（公告）日: 2023-09-19
• 發(fā)明（設(shè)計(jì)）人: 劉璐;何煒龍
• 申請（專利權(quán)）人: 阿里健康科技（杭州）有限公司
• 主分類號: G06F9/48
• 分類號: G06F9/48;G06Q10/0631;G06Q30/0601;G16H20/10
• 代理公司: 北京布瑞知識產(chǎn)權(quán)代理有限公司 11505
• 代理人: 周達(dá)

1.一種任務(wù)處理方法，其特征在于，包括：

接收目標(biāo)數(shù)據(jù)處理任務(wù)；

按照指定順序在多個(gè)任務(wù)隊(duì)列中確定存在空閑位置的首個(gè)任務(wù)隊(duì)列作為目標(biāo)任務(wù)隊(duì)列；其中，多個(gè)任務(wù)隊(duì)列分別對應(yīng)有任務(wù)消費(fèi)模塊；所述任務(wù)消費(fèi)模塊用于批處理相應(yīng)任務(wù)隊(duì)列中的數(shù)據(jù)處理任務(wù)；

將所述目標(biāo)數(shù)據(jù)處理任務(wù)加入所述目標(biāo)任務(wù)隊(duì)列。

2.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述指定順序包括：所述任務(wù)隊(duì)列被創(chuàng)建的時(shí)間順序；或者，依照所述任務(wù)隊(duì)列的隊(duì)列優(yōu)先級，針對多個(gè)任務(wù)隊(duì)列的排列順序。

3.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述方法還包括：

存儲接收到的數(shù)據(jù)處理任務(wù)；

在接收到任務(wù)異常信息的情況下，從存儲的數(shù)據(jù)處理任務(wù)中，讀取與所述任務(wù)異常信息對應(yīng)的數(shù)據(jù)處理任務(wù)作為所述目標(biāo)數(shù)據(jù)處理任務(wù)；其中，所述任務(wù)異常信息攜帶有與處于異常狀態(tài)的數(shù)據(jù)處理任務(wù)的任務(wù)標(biāo)識。

4.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述方法還包括：

檢查所述目標(biāo)任務(wù)隊(duì)列包括的數(shù)據(jù)處理任務(wù)的數(shù)量；

在所述目標(biāo)任務(wù)隊(duì)列包括的數(shù)據(jù)處理任務(wù)的數(shù)量不小于第一數(shù)量閾值的情況下，觸發(fā)數(shù)量閾值事件，以用于所述任務(wù)消費(fèi)模塊在捕捉到所述數(shù)量閾值事件的情況下，對所述目標(biāo)任務(wù)隊(duì)列包括的所述第一數(shù)量閾值個(gè)數(shù)據(jù)處理任務(wù)執(zhí)行批處理。

5.根據(jù)權(quán)利要求4所述的方法，其特征在于，所述目標(biāo)任務(wù)隊(duì)列設(shè)置有任務(wù)執(zhí)行鎖；所述任務(wù)執(zhí)行鎖具有第一鎖定狀態(tài)和第一釋放狀態(tài)；所述任務(wù)消費(fèi)模塊在捕捉到所述數(shù)量閾值事件的情況下，對所述目標(biāo)任務(wù)隊(duì)列包括的數(shù)據(jù)處理任務(wù)執(zhí)行批處理，包括：

在所述任務(wù)消費(fèi)模塊捕捉到所述數(shù)量閾值事件的情況下，將所述目標(biāo)任務(wù)隊(duì)列的任務(wù)執(zhí)行鎖設(shè)置為第一鎖定狀態(tài)；

對所述第一數(shù)量閾值個(gè)數(shù)據(jù)處理任務(wù)執(zhí)行批處理；

在完成所述批處理的情況下，將所述目標(biāo)任務(wù)隊(duì)列的任務(wù)執(zhí)行鎖設(shè)置為第一釋放狀態(tài)；

從所述目標(biāo)任務(wù)隊(duì)列中刪除所述批處理所執(zhí)行的數(shù)據(jù)處理任務(wù)。

6.根據(jù)權(quán)利要求1所述的方法，其特征在于，每個(gè)任務(wù)隊(duì)列設(shè)置有時(shí)間鎖；所述時(shí)間鎖具有第二鎖定狀態(tài)和第二釋放狀態(tài)；所述時(shí)間鎖處于所述第二鎖定狀態(tài)達(dá)成指定鎖定時(shí)長后，自動變更為所述第二釋放狀態(tài)；每個(gè)任務(wù)隊(duì)列對應(yīng)有用于周期性執(zhí)行計(jì)時(shí)周期的計(jì)時(shí)器；所述方法還包括：

在所述計(jì)時(shí)器每次完成計(jì)時(shí)周期后，請求獲取所述時(shí)間鎖的控制權(quán)限，至獲得所述時(shí)間鎖的控制權(quán)限；其中，僅在所述時(shí)間鎖處于所述第二釋放狀態(tài)的情況下，能夠取得所述時(shí)間鎖的控制權(quán)限；

在根據(jù)所述時(shí)間鎖的控制權(quán)限將所述時(shí)間鎖設(shè)置為所述第二鎖定狀態(tài)的情況下，觸發(fā)時(shí)間閾值事件；

在所述任務(wù)消費(fèi)模塊捕捉到所述時(shí)間閾值事件的情況下，針對所述時(shí)間閾值事件對應(yīng)的任務(wù)隊(duì)列包括的不多于第一數(shù)量閾值個(gè)數(shù)據(jù)處理任務(wù)執(zhí)行批處理。

7.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述方法還包括：

分別統(tǒng)計(jì)每個(gè)任務(wù)隊(duì)列在指定時(shí)間段內(nèi)的數(shù)據(jù)處理任務(wù)的累計(jì)數(shù)量；

銷毀所述累計(jì)數(shù)量小于第二數(shù)量閾值的任務(wù)隊(duì)列。

8.一種任務(wù)處理裝置，其特征在于，包括：

接收模塊，用于接收目標(biāo)數(shù)據(jù)處理任務(wù)；

確定模塊，用于按照指定順序在多個(gè)任務(wù)隊(duì)列中確定存在空閑位置的首個(gè)任務(wù)隊(duì)列作為目標(biāo)任務(wù)隊(duì)列；其中，多個(gè)任務(wù)隊(duì)列分別對應(yīng)有任務(wù)消費(fèi)模塊；所述任務(wù)消費(fèi)模塊用于批處理相應(yīng)任務(wù)隊(duì)列中的數(shù)據(jù)處理任務(wù)；

入隊(duì)模塊，用于將所述目標(biāo)數(shù)據(jù)處理任務(wù)加入所述目標(biāo)任務(wù)隊(duì)列。

9.一種電子設(shè)備，包括存儲器和處理器，所述存儲器存儲有計(jì)算機(jī)程序，所述處理器執(zhí)行所述計(jì)算機(jī)程序時(shí)實(shí)現(xiàn)權(quán)利要求1至7中任一項(xiàng)所述的方法。

10.一種計(jì)算機(jī)可讀存儲介質(zhì)，其上存儲有計(jì)算機(jī)程序，所述計(jì)算機(jī)程序被處理器執(zhí)行時(shí)實(shí)現(xiàn)權(quán)利要求1至7中任一項(xiàng)所述的方法。