[發明專利]實時任務調度方法、裝置、調度系統及存儲介質

在審

• 申請號: 202010911651.1
• 申請日: 2020-09-02
• 公開（公告）號: CN112068940A
• 公開（公告）日: 2020-12-11
• 發明（設計）人: 張小軍;劉磊;李燦
• 申請（專利權）人: 微醫云（杭州）控股有限公司
• 主分類號: G06F9/48
• 分類號: G06F9/48;G06F9/54;G06F16/22
• 代理公司: 北京品源專利代理有限公司 11332
• 代理人: 孟金喆

1.一種實時任務調度方法，其特征在于，包括：

根據實時檢測到的實時任務的元數據創建實時任務對象，并將所述實時任務對象投遞至對應的隊列表；

控制消費線程消費對應隊列表中處于有效執行時間區間內的實時任務對象。

2.根據權利要求1所述的方法，其特征在于，所述根據實時檢測到的實時任務的元數據創建實時任務對象，包括：

對實時檢測到的實時任務的配置文件進行解析，以得到實時任務的元數據；

將所述元數據存儲至元數據表，并根據所述元數據表中的元數據創建實時任務對象。

3.根據權利要求1所述的方法，其特征在于，所述控制消費線程消費對應隊列表中處于有效執行時間區間內的實時任務對象，包括：

控制消費線程執行以下步驟：

確定對應隊列表中的目標實時任務對象，以及確定所確定的目標實時任務對象的執行時間區間是否包含當前時刻；

若是，則判定所述目標實時任務對象處于有效執行區間，并對該目標實時任務對象進行消費。

4.根據權利要求1所述的方法，其特征在于，在創建實時任務對象的同時/之后，還包括：

控制守護進程向所述隊列表發送心跳數據，以由相應消費線程消費所述心跳數據；

在檢測到所述隊列表中存在心跳數據超過預設時間閾值仍未被消費的實時任務對象時，重新啟動該未被消費的心跳數據對應的實時任務對象。

5.根據權利要求2所述的方法，其特征在于，所述將所述元數據存儲至元數據表的同時，還包括：

將所述元數據同步至Zookeeper。

6.根據權利要求5所述的方法，其特征在于，在所述將所述元數據存儲至元數據表之后，還包括：

在檢測到Zookeeper中缺少任一隊列表中的一個或多個實時任務對象時，在Zookeeper中創建相應的實時任務對象。

7.根據權利要求6所述的方法，其特征在于，還包括：

在檢測到所述實時任務的元數據發生改變時，更新對應隊列中的相應實時任務對象以及Zookeeper中的相應實時任務對象。

8.一種實時任務調度裝置，其特征在于，包括：

創建模塊，用于根據實時檢測到的實時任務的元數據創建實時任務對象，并將所述實時任務對象投遞至對應的隊列表；

消費模塊，用于控制消費線程消費對應隊列表中處于有效執行時間區間內的實時任務對象。

9.一種調度系統，其特征在于，所述調度系統包括：

一個或多個處理器；

存儲裝置，用于存儲一個或多個程序；

當所述一個或多個程序被所述一個或多個處理器執行，使得所述一個或多個處理器實現如權利要求1-7中任一所述的實時任務調度方法。

10.一種包含計算機可執行指令的存儲介質，其特征在于，所述計算機可執行指令在由計算機處理器執行時用于執行如權利要求1-7中任一所述的實時任務調度方法。