[發明專利]基于集群的任務提交方法、計算機程序產品及電子設備

有效

• 申請號: 202110604816.5
• 申請日: 2021-05-31
• 公開（公告）號: CN113254177B
• 公開（公告）日: 2023-06-27
• 發明（設計）人: 黃海升;陳武
• 申請（專利權）人: 廣州虎牙科技有限公司
• 主分類號: G06F9/48
• 分類號: G06F9/48;G06F9/50
• 代理公司: 北京博思佳知識產權代理有限公司 11415
• 代理人: 林祥

1.一種基于集群的任務提交方法，所述任務被拆分為由至少一個應用運行，其特征在于，所述方法包括：

從用戶輸入的指令中提取執行任務的實例的數據時間，所述數據時間由用戶設定，針對不同實例所設定的數據時間不同；

獲取所述任務預存的偏移時間，所述偏移時間基于以下方式確定：根據所述任務的下游任務的提交時間確定所述任務的完成時間；根據所述任務的完成時間與所述任務的執行時長計算第一偏移時間；根據所述任務的期望完成時間與所述執行時長計算第二偏移時間，將所述第一偏移時間與所述第二偏移時間中的最小值為所述偏移時間；

根據所述數據時間與所述偏移時間計算所述任務的提交時間；

根據所述提交時間，生成提交指令，并按照所述提交指令向集群提交所述任務。

2.根據權利要求1所述的方法，其特征在于，所述下游任務包括不同優先級的下游任務；所述完成時間包括不同優先級的完成時間；所述第一偏移時間包括不同優先級的第一偏移時間；所述確定所述第一偏移時間與所述第二偏移時間中的最小值為所述偏移時間，包括：

將所述第二偏移時間分別與所述不同優先級的第一偏移時間對比，確定最小值為不同優先級的偏移時間。

3.根據權利要求2所述的方法，其特征在于，所述提交時間還根據緩沖時間計算，優先級高的偏移時間對應的緩沖時間比優先級低的偏移時間對應的緩沖時間長；所述提交時間的計算步驟包括：

根據所述數據時間、所述不同優先級的偏移時間、以及不同優先級的偏移時間對應的緩沖時間，確定不同優先級的提交時間；

確定所述不同優先級的提交時間中的最小值為所述任務的提交時間。

4.根據權利要求1所述的方法，其特征在于，所述根據所述提交時間，生成提交指令，并按照所述提交指令向集群提交所述任務，包括：

將所述任務提交到任務隊列，所述任務隊列按照所述任務的執行時長以及算力耗費從低到高依次向所述集群提交所述任務。

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

當到達預設周期時，將所述任務列隊中已超過所述提交時間的超時任務提交到超時隊列，所述超時隊列按照所述超時任務的超時時長從高到低依次向所述集群提交所述超時任務。

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

獲取所述集群的負載狀態；

當表征所述負載狀態的參數小于預設閾值時，向所述集群提交所述任務。

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

處理器；

用于存儲處理器可執行指令的存儲器；

其中，所述處理器被配置為：

從用戶輸入的指令中提取執行任務的實例的數據時間，所述數據時間由用戶設定，針對不同實例所設定的數據時間不同；所述任務被拆分為由至少一個應用運行；

獲取所述任務預存的偏移時間，所述偏移時間基于以下方式確定：根據所述任務的下游任務的提交時間確定所述任務的完成時間；根據所述任務的完成時間與所述任務的執行時長計算第一偏移時間；根據所述任務的期望完成時間與所述執行時長計算第二偏移時間，將所述第一偏移時間與所述第二偏移時間中的最小值為所述偏移時間；

根據所述數據時間與所述偏移時間計算所述任務的提交時間；

根據所述提交時間，生成提交指令，并按照所述提交指令向集群提交所述任務。

8.一種計算機可讀存儲介質，其特征在于，其上存儲有計算機指令，該指令被處理器執行時實現權利要求1-6任一所述的方法。