[發(fā)明專利]數(shù)據(jù)調度方法、裝置及電子設備

有效

• 申請?zhí)枺?/td>: 202110744136.3
• 申請日: 2021-07-01
• 公開（公告）號: CN113220442B
• 公開（公告）日: 2021-11-26
• 發(fā)明（設計）人: 黃淑寧;張杰;涂山山;王少帥;朱佳明
• 申請（專利權）人: 北京輕松籌信息技術有限公司
• 主分類號: G06F9/48
• 分類號: G06F9/48
• 代理公司: 北京集佳知識產權代理有限公司 11227
• 代理人: 張靜

1.一種數(shù)據(jù)調度方法，其特征在于，包括：

當接收到第一目標任務的圈人請求后，將所述第一目標任務存儲在第一任務集合中；

當檢測到第二任務集合中包含的任務的數(shù)量小于預設的閾值的情況下，從所述第一任務集合中調取第二目標任務；所述第二目標任務為所述第一任務集合中滿足預設條件的第一目標任務；所述預設的閾值小于或者等于datahub的項目中能夠存儲的主題的數(shù)量的最大上限值；

執(zhí)行所述第二目標任務的圈人請求，將所述第二目標任務的狀態(tài)設置為正在圈人狀態(tài)，并在所述第二目標任務的圈人請求執(zhí)行完成后，將所述第二目標任務從正在圈人狀態(tài)修改為圈人完成狀態(tài)；

當所述第二任務集合中存在處于圈人完成狀態(tài)的第三目標任務時，觸發(fā)所述第三目標任務的推送請求，并執(zhí)行所述第三目標任務的推送請求；

當所述第三目標任務的推送請求執(zhí)行完成后，從所述第二任務集合中刪除所述第三目標任務。

2.根據(jù)權利要求1所述的方法，其特征在于，所述當接收到第一目標任務的圈人請求后，將所述第一目標任務存儲在第一任務集合中，包括：

當接收到第一目標任務的圈人請求后，根據(jù)接收到所述第一目標任務的圈人請求的時間，設置所述第一目標任務的優(yōu)先級；接收到第一目標任務的圈人請求的時間越早，則所述第一目標任務的優(yōu)先級越高；

將所述第一目標任務存儲在所述第一任務集合中。

3.根據(jù)權利要求2所述的方法，其特征在于，所述調取的第二目標任務為所述第一任務集合中優(yōu)先級最高的任務。

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

當所述第二任務集合中存在處于圈人完成狀態(tài)的第三目標任務的情況下，將所述第三目標任務推送到第三任務集合中；

基于所述第三任務集合中包含的任務的數(shù)量，確定并發(fā)調度的任務的數(shù)量。

5.根據(jù)權利要求1所述的方法，其特征在于，所述調取的第二目標任務為第一任務集合中的周期任務。

6.一種數(shù)據(jù)調度裝置，其特征在于，包括：

預存儲單元，用于當接收到第一目標任務的圈人請求后，將所述第一目標任務存儲在第一任務集合中；

調取單元，用于當檢測到第二任務集合中包含的任務的數(shù)量小于預設的閾值的情況下，從所述第一任務集合中調取第二目標任務；所述第二目標任務為所述第一任務集合中滿足預設條件的任務；所述預設的閾值小于或者等于datahub的項目中能夠存儲的主題的數(shù)量的最大上限值；

狀態(tài)設置單元，用于執(zhí)行所述第二目標任務的圈人請求，將所述第二目標任務的狀態(tài)設置為正在圈人狀態(tài)，并在所述第二目標任務的圈人請求執(zhí)行完成后，將所述第二目標任務從正在圈人狀態(tài)修改為圈人完成狀態(tài)；

推送請求執(zhí)行單元，用于當?shù)诙蝿占现写嬖谔幱谌θ送瓿蔂顟B(tài)的第三目標任務時，觸發(fā)所述第三目標任務的推送請求，并執(zhí)行所述第三目標任務的推送請求；當所述第三目標任務的推送請求執(zhí)行完成后，從所述第二任務集合中刪除所述第三目標任務。

7.根據(jù)權利要求6所述的裝置，其特征在于，所述預存儲單元，包括：

優(yōu)先級設置子單元，用于當接收到第一目標任務的圈人請求后，根據(jù)接收到所述第一目標任務的圈人請求的時間，設置所述第一目標任務的優(yōu)先級；接收到第一目標任務的圈人請求的時間越早，則所述第一目標任務的優(yōu)先級越高；

預存儲子單元，用于將所述第一目標任務存儲在所述第一任務集合中。

8.一種電子設備，其特征在于，所述電子設備包括：

存儲器和處理器；

所述存儲器用于存儲程序；

所述處理器用于執(zhí)行所述存儲器中的程序時，至少執(zhí)行上述權利要求1-5中任一項所述的數(shù)據(jù)調度方法。