[發(fā)明專利]一種任務(wù)調(diào)度的方法及系統(tǒng)

有效

• 申請?zhí)枺?/td>: 201510080579.1
• 申請日: 2015-02-13
• 公開（公告）號: CN104657212B
• 公開（公告）日: 2018-02-16
• 發(fā)明（設(shè)計(jì)）人: 王全勝;馮文
• 申請（專利權(quán)）人: 北京亞信數(shù)據(jù)有限公司
• 主分類號: G06F9/48
• 分類號: G06F9/48;G06F9/38
• 代理公司: 北京中博世達(dá)專利商標(biāo)代理有限公司11274
• 代理人: 申健

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

本發(fā)明涉及網(wǎng)絡(luò)通信技術(shù)領(lǐng)域，尤其涉及一種任務(wù)調(diào)度的方法及系統(tǒng)。

背景技術(shù)

在IT(Information Technology，信息技術(shù))系統(tǒng)中，存在大量后臺需要周期性運(yùn)行的任務(wù)，這些任務(wù)分布在多個系統(tǒng)平臺，并且具有一定的優(yōu)先級關(guān)系以及依賴關(guān)系，由于用于處理這些任務(wù)的資源是有限的，所以需要對這些任務(wù)進(jìn)行合理的調(diào)度。

目前，進(jìn)行任務(wù)調(diào)度的方法通常為調(diào)度工具提供一個任務(wù)配置界面，人工在任務(wù)配置界面上將需要運(yùn)行的任務(wù)一個一個連接起來，然后根據(jù)業(yè)務(wù)經(jīng)驗(yàn)設(shè)置每個任務(wù)的運(yùn)行順序、依賴條件以及優(yōu)先級等。完成任務(wù)配置之后，任務(wù)調(diào)度系統(tǒng)根據(jù)人工配置的運(yùn)行順序并行運(yùn)行某些任務(wù)時，如果任務(wù)調(diào)度系統(tǒng)的資源還有剩余，如果即將運(yùn)行的任務(wù)所占用的資源小于任務(wù)調(diào)度系統(tǒng)的剩余資源時，任務(wù)調(diào)度系統(tǒng)可以運(yùn)行該即將運(yùn)行的任務(wù)，但當(dāng)即將運(yùn)行的任務(wù)所需占用的資源大于任務(wù)調(diào)度系統(tǒng)的剩余資源時，則任務(wù)調(diào)度系統(tǒng)不會啟動該即將運(yùn)行的任務(wù)，直到當(dāng)前正在運(yùn)行的任務(wù)運(yùn)行結(jié)束之后再啟動該即將運(yùn)行的任務(wù)，因而在任務(wù)調(diào)度系統(tǒng)的剩余資源不足以運(yùn)行即將運(yùn)行的任務(wù)時導(dǎo)致等待時間過長，任務(wù)調(diào)度的效率低。

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

本發(fā)明的實(shí)施例提供一種任務(wù)調(diào)度的方法及系統(tǒng)，可以解決任務(wù)調(diào)度效率低的問題。

為達(dá)到上述目的，本發(fā)明的實(shí)施例采用如下技術(shù)方案：

一方面，本發(fā)明的實(shí)施例提供一種任務(wù)調(diào)度的方法，所述方法應(yīng)用于任務(wù)調(diào)度系統(tǒng)中，所述任務(wù)調(diào)度系統(tǒng)包括調(diào)度服務(wù)器、消息總線、用于運(yùn)行不同任務(wù)的多個運(yùn)行平臺，所述方法包括：

所述調(diào)度服務(wù)器通過所述消息總線接收當(dāng)前任務(wù)對應(yīng)的運(yùn)行平臺發(fā)送的任務(wù)完成消息，所述任務(wù)完成消息用于指示所述當(dāng)前任務(wù)對應(yīng)的運(yùn)行平臺已完成所述當(dāng)前任務(wù)；

所述調(diào)度服務(wù)器通過所述任務(wù)完成消息更新所述當(dāng)前任務(wù)的任務(wù)狀態(tài)以及所述當(dāng)前任務(wù)的后續(xù)任務(wù)的任務(wù)狀態(tài)，所述當(dāng)前任務(wù)的后續(xù)任務(wù)為規(guī)定運(yùn)行完所述當(dāng)前任務(wù)之后運(yùn)行的任務(wù)，其中，任務(wù)的任務(wù)狀態(tài)包括等待狀態(tài)、就緒狀態(tài)、運(yùn)行中狀態(tài)和完成狀態(tài)；

所述調(diào)度服務(wù)器從數(shù)據(jù)庫中獲取就緒任務(wù)，按照任務(wù)類型對所述就緒任務(wù)進(jìn)行分組，并對每組中的就緒任務(wù)按靜態(tài)優(yōu)先級排序，所述任務(wù)類型為根據(jù)各任務(wù)平均每次運(yùn)行時長劃分的類型；

所述調(diào)度服務(wù)器獲取每種任務(wù)類型的最大并發(fā)數(shù)、每種任務(wù)類型的就緒任務(wù)數(shù)量，以及每種任務(wù)類型的運(yùn)行中任務(wù)數(shù)量，所述最大并發(fā)數(shù)為所述任務(wù)調(diào)度系統(tǒng)允許并行運(yùn)行每種任務(wù)類型的任務(wù)的最大數(shù)量；

所述調(diào)度服務(wù)器通過所述每種任務(wù)類型的最大并發(fā)數(shù)、所述每種任務(wù)類型的就緒任務(wù)數(shù)量，以及所述每種任務(wù)類型的運(yùn)行中任務(wù)數(shù)量，調(diào)整所述每種任務(wù)類型的最大并發(fā)數(shù)，將每種任務(wù)類型的就緒任務(wù)分別按照各組內(nèi)就緒任務(wù)的排列順序派發(fā)給各任務(wù)對應(yīng)的運(yùn)行平臺運(yùn)行，直至每種任務(wù)類型的運(yùn)行中任務(wù)數(shù)量達(dá)到各自任務(wù)類型的最大并發(fā)數(shù)。

在本發(fā)明的另一實(shí)施例中，所述任務(wù)類型包括第一類型、第二類型、第三類型，其中，所述第一類型為平均每次運(yùn)行時長大于等于第一預(yù)設(shè)時長的任務(wù)，所述第二類型為平均每次運(yùn)行時長小于所述第一預(yù)設(shè)時長大于第二預(yù)設(shè)時長的任務(wù)，所述第三類型為平均每次運(yùn)行時長小于等于所述第二預(yù)設(shè)時長的任務(wù)；

所述調(diào)度服務(wù)器通過所述每種任務(wù)類型的最大并發(fā)數(shù)、所述每種任務(wù)類型的就緒任務(wù)數(shù)量，以及所述每種任務(wù)類型的運(yùn)行中任務(wù)數(shù)量，調(diào)整所述每種任務(wù)類型的最大并發(fā)數(shù)，將每種任務(wù)類型的就緒任務(wù)分別按照各組內(nèi)就緒任務(wù)的排列順序派發(fā)給各任務(wù)對應(yīng)的運(yùn)行平臺運(yùn)行，直至每種任務(wù)類型的運(yùn)行中任務(wù)數(shù)量達(dá)到各自任務(wù)類型的最大并發(fā)數(shù)，包括：

所述調(diào)度服務(wù)器確定第一類型的運(yùn)行中任務(wù)數(shù)量小于第一類型的最大并發(fā)數(shù)時，將第一類型的就緒任務(wù)按照靜態(tài)優(yōu)先級從高到低的順序派發(fā)給各自對應(yīng)的運(yùn)行平臺運(yùn)行，直至所述第一類型的運(yùn)行中任務(wù)數(shù)量達(dá)到所述第一類型的最大并發(fā)數(shù)；

當(dāng)所述第一類型的就緒任務(wù)全部開始運(yùn)行時，所述第一類型的運(yùn)行中任務(wù)數(shù)量仍未達(dá)到所述第一類型的最大并發(fā)數(shù)，將所述第一類型的最大并發(fā)數(shù)中的剩余數(shù)量轉(zhuǎn)換為第二類型的轉(zhuǎn)換并發(fā)數(shù)，將第二類型的最大并發(fā)數(shù)更新為第二類型的原始最大并發(fā)數(shù)+所述第二類型的轉(zhuǎn)換并發(fā)數(shù)；

所述調(diào)度服務(wù)器確定所述第二類型的運(yùn)行中任務(wù)數(shù)量小于所述第二類型的最大并發(fā)數(shù)時，將第二類型的就緒任務(wù)按照靜態(tài)優(yōu)先級從高到低的順序派發(fā)給各自對應(yīng)的運(yùn)行平臺運(yùn)行，直至所述第二類型的運(yùn)行中任務(wù)數(shù)量達(dá)到所述第二類型的最大并發(fā)數(shù)；