[發明專利]任務執行方法、裝置、存儲介質及電子設備

在審

• 申請號: 201911063138.5
• 申請日: 2019-10-31
• 公開（公告）號: CN112748993A
• 公開（公告）日: 2021-05-04
• 發明（設計）人: 周婧
• 申請（專利權）人: 北京國雙科技有限公司
• 主分類號: G06F9/48
• 分類號: G06F9/48
• 代理公司: 北京康信知識產權代理有限責任公司 11240
• 代理人: 黃海英

1.一種任務執行方法，其特征在于，包括：

獲取待執行的目標任務，并將所述目標任務拆分為多個子任務；

確定所述子任務中能夠并發執行的目標子任務的數量；

根據所述目標子任務的數量，確定待啟動線程的數量；

在目標進程內啟動對應數量的線程，并通過所述線程執行每個所述子任務，得到所述目標任務的執行結果。

2.根據權利要求1所述的方法，其特征在于，所述將所述目標任務拆分為多個子任務，包括：

確定所述目標任務包含的任務節點；

根據所述任務節點，對所述目標任務進行拆分，得到所述多個子任務；

和/或，

在將所述目標任務拆分為多個子任務之后，所述方法還包括：

確定所述子任務之間的依賴關系，以及每個所述子任務的執行順序；

和/或，

根據所述目標子任務的數量，確定待啟動線程的數量，包括：

將所述目標子任務的數量，確定為所述待啟動線程的數量，以便每個線程執行一個所述目標子任務。

3.根據權利要求2所述的方法，其特征在于，在通過所述線程執行每個所述子任務之前，所述方法還包括：

將所述子任務中需要串聯執行的子任務，確定為串聯子任務，所述串聯子任務為所述目標子任務之外的子任務；

根據所述子任務之間的依賴關系，確定與每個所述目標子任務存在依賴關系的目標串聯子任務；

將所述目標串聯子任務和所述目標子任務，按照所述子任務的執行順序進行組合，得到組合任務；

將執行每個所述目標子任務的線程，確定為執行對應的組合任務的線程；

和/或，

通過所述線程執行每個所述子任務，包括：

通過每個線程按照所述執行順序分別執行對應的組合任務中的每個子任務，得到所述目標任務的執行結果。

4.根據權利要求1所述的方法，其特征在于，在每個所述子任務執行完畢后，所述方法還包括：

根據每個所述子任務的執行結果，判斷所述子任務是否成功執行；

如果未成功執行，則確定未成功執行的原因，并基于所述未成功執行的原因對所述子任務的執行方式進行調整后，再重復執行所述子任務，直至所述子任務執行成功，或，達到預設的執行次數。

5.根據權利要求1所述的方法，其特征在于，所述目標任務為多個，且多個所述目標任務構成一個任務包，所述方法還包括：

根據所述目標任務的數量，確定待啟動的目標進程的數量，以使每個目標進程用于執行一個所述目標任務；和/或，

在得到所述目標任務的執行結果之后，所述方法還包括：

獲取所述目標任務之間的依賴關系；

根據所述依賴關系，將所述多個目標任務的執行結果進行拼接，得到所述任務包的執行結果。

6.根據權利要求1所述的方法，其特征在于，所述目標任務為數據查詢任務，所述將所述目標任務拆分為多個子任務，包括：

根據所述數據查詢任務對應的查詢時間段，將所述數據查詢任務拆分為多個查詢子任務。

7.根據權利要求6所述的方法，其特征在于，所述查詢子任務至少包括：第一查詢子任務和第二查詢子任務，所述第一查詢子任務用于從Elasticsearch數據庫中查詢數據，所述第二查詢子任務用于從Hbase數據庫中查詢數據；

和/或，

所述第一查詢子任務和所述第二查詢子任務之間存在依賴關系，所述第一查詢子任務和所述第二查詢子任務構成一個組合任務，且所述第一查詢子任務的執行順序在所述第二查詢子任務的執行順序之前。

8.一種任務執行裝置，其特征在于，包括：

第一獲取單元，用于獲取待執行的目標任務，并將所述目標任務拆分為多個子任務；

第一確定單元，用于確定所述子任務中能夠并發執行的目標子任務的數量；

第二確定單元，用于根據所述目標子任務的數量，確定待啟動線程的數量；

啟動單元，用于在目標進程內啟動對應數量的線程，并通過所述線程執行每個所述子任務，得到所述目標任務的執行結果。