[發明專利]一種任務調度方法、裝置、存儲介質及電子設備

在審

• 申請號: 202110309222.1
• 申請日: 2021-03-23
• 公開（公告）號: CN113032119A
• 公開（公告）日: 2021-06-25
• 發明（設計）人: 蔡元發
• 申請（專利權）人: 北京三快在線科技有限公司
• 主分類號: G06F9/48
• 分類號: G06F9/48
• 代理公司: 北京曼威知識產權代理有限公司 11709
• 代理人: 方志煒

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

分布式系統中的當前處理節點監控自身的負載狀態，判斷自身當前的負載狀態是否達到負載閾值；

若負載狀態未達到負載閾值，則主動從預先存儲任務的任務隊列中獲取任務；

根據獲取到的任務以及所述當前處理節點自身保存的數據，對所述任務進行處理或者發送給所述分布式系統中的其他處理節點進行處理。

2.如權利要求1所述的方法，其特征在于，根據獲取到的任務以及所述當前處理節點自身保存的數據，對所述任務進行處理或者發送給所述分布式系統中的其他處理節點進行處理，具體包括：

根據獲取到的任務，確定處理所述任務時所需的數據，作為任務數據；

根據所述任務數據以及所述當前處理節點自身保存的數據，判斷所述當前處理節點是否適合處理所述任務；

若所述當前處理節點適合處理所述任務，則將所述任務保存到自身的負載隊列中，并對所述任務進行處理；

若所述當前處理節點不適合處理所述任務，則將所述任務發送給所述分布式系統中的其他處理節點進行處理。

3.如權利要求2所述的方法，其特征在于，根據所述任務數據以及所述當前處理節點自身保存的數據，判斷所述當前處理節點是否適合處理所述任務，具體包括：

根據所述任務數據、所述當前處理節點自身保存的數據以及所述當前處理節點當前的負載狀態，確定所述當前處理節點處理所述任務的代價值；

將所述代價值與代價閾值進行比較，判斷所述當前處理節點是否適合處理所述任務。

4.如權利要求2所述的方法，其特征在于，將所述任務發送給所述分布式系統中的其他處理節點進行處理，具體包括：

根據處理所述任務的任務數據，查找所述分布式系統中具有所述任務數據的其他處理節點，并將所述其他處理節點中任意的處理節點，作為備選處理節點；

針對每個備選處理節點，將所述任務發送給該備選處理節點，以使該備選處理節點確定出該備選處理節點處理所述任務的代價值，并將該備選處理節點確定出的代價值與代價閾值進行比較，得到比較結果；

根據該備選處理節點返回的比較結果，判斷該備選處理節點是否適合處理所述任務；

若該備選處理節點適合處理所述任務，則確定所述任務由該備選處理節點進行處理；

若該備選處理節點不適合處理所述任務，則繼續將所述任務發送給其他的備選處理節點，直至確定出處理所述任務的備選處理節點或遍歷完所有備選處理節點為止。

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

若所有備選處理節點都不適合處理所述任務，則將所述任務保存到所述當前處理節點自身的負載隊列中，并對所述任務進行處理。

6.如權利要求5所述的方法，其特征在于，對所述任務進行處理，具體包括：

當所述當前處理節點自身保存的數據中沒有處理所述任務的任務數據時，對所述任務數據進行下載；

根據下載完成的任務數據，所述當前處理節點自身對所述任務進行處理。

7.如權利要求6所述的方法，其特征在于，查找具有所述任務數據的其他處理節點，具體包括：

根據所述當前處理節點所在的分布式系統的維護節點中保存的各個任務數據與各個處理節點的關聯關系，查找具有所述任務數據的其他處理節點；

在對所述任務數據進行下載之后，所述方法還包括：

將所述任務數據與所述當前處理節點的關聯關系更新到所述維護節點中。

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

判斷模塊，用于分布式系統中的當前處理節點監控自身的負載狀態，判斷自身當前的負載狀態是否達到負載閾值；

獲取模塊，用于若負載狀態未達到負載閾值，則主動從預先存儲任務的任務隊列中獲取任務；

處理模塊，用于根據獲取到的任務以及所述當前處理節點自身保存的數據，對所述任務進行處理或發送給所述分布式系統中的其他處理節點進行處理。