[發(fā)明專利]一種任務(wù)調(diào)度方法、裝置、存儲介質(zhì)及電子設(shè)備

在審

• 申請?zhí)枺?/td>: 202110309222.1
• 申請日: 2021-03-23
• 公開（公告）號: CN113032119A
• 公開（公告）日: 2021-06-25
• 發(fā)明（設(shè)計）人: 蔡元發(fā)
• 申請（專利權(quán)）人: 北京三快在線科技有限公司
• 主分類號: G06F9/48
• 分類號: G06F9/48
• 代理公司: 北京曼威知識產(chǎn)權(quán)代理有限公司 11709
• 代理人: 方志煒

本說明書公開了一種任務(wù)調(diào)度方法、裝置、存儲介質(zhì)及電子設(shè)備，本說明書實施例在分布式系統(tǒng)的當(dāng)前處理節(jié)點監(jiān)控自身的負載狀態(tài)，當(dāng)自身的負載狀態(tài)未達到負載閾值時，當(dāng)前處理節(jié)點主動從任務(wù)隊列中獲取任務(wù)。然后，對獲取到的任務(wù)進行處理或發(fā)送給其他處理節(jié)點進行處理。在此方法中，當(dāng)前處理節(jié)點根據(jù)自身的負載狀態(tài)，自主地從任務(wù)隊列中獲取任務(wù)，可以避免處理節(jié)點的任務(wù)數(shù)量超過負載能力的問題，從而提高處理任務(wù)的處理效率。

技術(shù)領(lǐng)域

本說明書涉及計算機技術(shù)領(lǐng)域，尤其涉及一種任務(wù)調(diào)度方法、裝置、存儲介質(zhì)及電子設(shè)備。

背景技術(shù)

如今，隨著經(jīng)濟的快速發(fā)展，計算機需要處理的任務(wù)的數(shù)據(jù)量也成倍增長。而任務(wù)中數(shù)據(jù)量的大幅度增加，不利于任務(wù)的處理。因此，為了提高任務(wù)的處理效率，可以通過分布式系統(tǒng)對任務(wù)進行處理，而通過分布式系統(tǒng)對任務(wù)進行處理就需要對任務(wù)進行調(diào)度。

現(xiàn)有技術(shù)中，通過分布式系統(tǒng)中的調(diào)度器將整個任務(wù)分割成多個子任務(wù)，然后，針對每個子任務(wù)，將該子任務(wù)調(diào)度到具有處理該子任務(wù)所需數(shù)據(jù)的節(jié)點上。在每個節(jié)點對各自的子任務(wù)進行處理后，對每個節(jié)點的處理結(jié)果進行匯總，得到整個任務(wù)的處理結(jié)果。

然而，現(xiàn)有技術(shù)中分布式系統(tǒng)的調(diào)度器只根據(jù)保存有處理子任務(wù)時所需數(shù)據(jù)的節(jié)點，對每個子任務(wù)進行調(diào)度，這樣易導(dǎo)致節(jié)點的子任務(wù)量超出該節(jié)點的負載能力，從而影響該節(jié)點對子任務(wù)的處理效率，因此降低了整個任務(wù)的處理效率。

發(fā)明內(nèi)容

本說明書實施例提供一種任務(wù)調(diào)度方法、裝置、存儲介質(zhì)及電子設(shè)備，以部分解決上述現(xiàn)有技術(shù)存在的問題。

本說明書實施例采用下述技術(shù)方案：

本說明書提供的一種任務(wù)調(diào)度方法，包括：

分布式系統(tǒng)中的當(dāng)前處理節(jié)點監(jiān)控自身的負載狀態(tài)，判斷自身當(dāng)前的負載狀態(tài)是否達到負載閾值；

若負載狀態(tài)未達到負載閾值，則主動從預(yù)先存儲任務(wù)的任務(wù)隊列中獲取任務(wù)；

根據(jù)獲取到的任務(wù)以及所述當(dāng)前處理節(jié)點自身保存的數(shù)據(jù)，對所述任務(wù)進行處理或者發(fā)送給所述分布式系統(tǒng)中的其他處理節(jié)點進行處理。

可選地，根據(jù)獲取到的任務(wù)以及所述當(dāng)前處理節(jié)點自身保存的數(shù)據(jù)，對所述任務(wù)進行處理或者發(fā)送給所述分布式系統(tǒng)中的其他處理節(jié)點進行處理，具體包括：

根據(jù)獲取到的任務(wù)，確定處理所述任務(wù)時所需的數(shù)據(jù)，作為任務(wù)數(shù)據(jù)；

根據(jù)所述任務(wù)數(shù)據(jù)以及所述當(dāng)前處理節(jié)點自身保存的數(shù)據(jù)，判斷所述當(dāng)前處理節(jié)點是否適合處理所述任務(wù)；

若所述當(dāng)前處理節(jié)點適合處理所述任務(wù)，則將所述任務(wù)保存到自身的負載隊列中，并對所述任務(wù)進行處理；

若所述當(dāng)前處理節(jié)點不適合處理所述任務(wù)，則將所述任務(wù)發(fā)送給所述分布式系統(tǒng)中的其他處理節(jié)點進行處理。

可選地，根據(jù)所述任務(wù)數(shù)據(jù)以及所述當(dāng)前處理節(jié)點自身保存的數(shù)據(jù)，判斷所述當(dāng)前處理節(jié)點是否適合處理所述任務(wù)，具體包括：

根據(jù)所述任務(wù)數(shù)據(jù)、所述當(dāng)前處理節(jié)點自身保存的數(shù)據(jù)以及所述當(dāng)前處理節(jié)點當(dāng)前的負載狀態(tài)，確定所述當(dāng)前處理節(jié)點處理所述任務(wù)的代價值；

將所述代價值與代價閾值進行比較，判斷所述當(dāng)前處理節(jié)點是否適合處理所述任務(wù)。

可選地，將所述任務(wù)發(fā)送給所述分布式系統(tǒng)中的其他處理節(jié)點進行處理，具體包括：

根據(jù)處理所述任務(wù)的任務(wù)數(shù)據(jù)，查找所述分布式系統(tǒng)中具有所述任務(wù)數(shù)據(jù)的其他處理節(jié)點，并將所述其他處理節(jié)點中任意的處理節(jié)點，作為備選處理節(jié)點；