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

在審

• 申請(qǐng)?zhí)枺?/td>: 202011144112.6
• 申請(qǐng)日: 2020-10-21
• 公開（公告）號(hào): CN112199180A
• 公開（公告）日: 2021-01-08
• 發(fā)明（設(shè)計(jì)）人: 張珩智;王超;周磊;薛超
• 申請(qǐng)（專利權(quán)）人: 北京三快在線科技有限公司
• 主分類號(hào): G06F9/48
• 分類號(hào): G06F9/48
• 代理公司: 北京潤澤恒知識(shí)產(chǎn)權(quán)代理有限公司 11319
• 代理人: 任亞娟

本發(fā)明公開了一種多任務(wù)調(diào)度的方法及裝置、電子設(shè)備及可讀存儲(chǔ)介質(zhì)。其中，該方法包括：在接收到任務(wù)獲取指令時(shí)，獲取目標(biāo)系統(tǒng)中的可執(zhí)行任務(wù)隊(duì)列，所述可執(zhí)行任務(wù)隊(duì)列包括可執(zhí)行的多個(gè)待執(zhí)行任務(wù)；并行執(zhí)行所述可執(zhí)行任務(wù)隊(duì)列中的待執(zhí)行任務(wù)；在所述待執(zhí)行任務(wù)完成時(shí)，生成所述任務(wù)獲取指令。本發(fā)明解決了由于相關(guān)技術(shù)中系統(tǒng)各種多任務(wù)中存在依賴任務(wù)，而導(dǎo)致任務(wù)無法完全并行執(zhí)行的技術(shù)問題。

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

本發(fā)明涉及數(shù)據(jù)庫技術(shù)領(lǐng)域，具體而言，涉及一種多任務(wù)調(diào)度的方法及裝置、電子設(shè)備及可讀存儲(chǔ)介質(zhì)。

背景技術(shù)

在某些業(yè)務(wù)場(chǎng)景中，業(yè)務(wù)流程是由多個(gè)任務(wù)組合而成的，流程的執(zhí)行就是對(duì)多個(gè)任務(wù)的執(zhí)行。如果任務(wù)是互相獨(dú)立的，那么任務(wù)的執(zhí)行不需要排序，不同的執(zhí)行順序?qū)Y(jié)果沒有影響，可以將所有任務(wù)并行執(zhí)行以降低耗時(shí)，提升性能。如果任務(wù)不是互相獨(dú)立，而是彼此之間有依賴關(guān)系，每個(gè)流程可以抽象為一個(gè)有向無環(huán)的流程圖，任務(wù)按照拓?fù)渑判虻姆绞剑却蕾嚾蝿?wù)執(zhí)行完成才能執(zhí)行。在這種情況下，所有任務(wù)無法完全并行執(zhí)行，需要設(shè)計(jì)一個(gè)存在依賴關(guān)系的任務(wù)并行執(zhí)行策略。

在現(xiàn)有的多任務(wù)依賴場(chǎng)景中，有兩種并行執(zhí)行任務(wù)的策略，分別是任務(wù)分組策略和Fork-Join策略。

任務(wù)分組策略是將任務(wù)分組，每個(gè)任務(wù)組內(nèi)的任務(wù)互相獨(dú)立，任務(wù)組與任務(wù)組之間存在依賴關(guān)系。在執(zhí)行的過程中，任務(wù)組內(nèi)的任務(wù)并行執(zhí)行，任務(wù)組和任務(wù)組之間的任務(wù)串行執(zhí)行，需要等待上一個(gè)任務(wù)組內(nèi)的任務(wù)全部執(zhí)行完成才能執(zhí)行。

Fork-Join策略是采用分治的思想，分治的是任務(wù)的依賴任務(wù)(子任務(wù))。在執(zhí)行過程中，首先并行執(zhí)行當(dāng)前任務(wù)的依賴任務(wù)(Fork)，等待依賴任務(wù)都執(zhí)行完成后(Join)，再執(zhí)行當(dāng)前任務(wù)。

可見，相關(guān)技術(shù)中針對(duì)上述的問題，目前尚未提出有效的解決方案。

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

本發(fā)明實(shí)施例提供了一種多任務(wù)調(diào)度的方法及裝置、電子設(shè)備及可讀存儲(chǔ)介質(zhì)，以至少解決由于相關(guān)技術(shù)中系統(tǒng)各種多任務(wù)中存在依賴任務(wù)，而導(dǎo)致任務(wù)無法完全并行執(zhí)行的技術(shù)問題。

根據(jù)本發(fā)明實(shí)施例的一個(gè)方面，提供了一種多任務(wù)執(zhí)行方法，包括：在接收到任務(wù)獲取指令時(shí)，獲取目標(biāo)系統(tǒng)中的可執(zhí)行任務(wù)隊(duì)列，所述可執(zhí)行任務(wù)隊(duì)列包括可執(zhí)行的多個(gè)待執(zhí)行任務(wù)；并行執(zhí)行所述可執(zhí)行任務(wù)隊(duì)列中的待執(zhí)行任務(wù)；在所述待執(zhí)行任務(wù)完成時(shí)，生成所述任務(wù)獲取指令。

進(jìn)一步地，獲取目標(biāo)系統(tǒng)中的可執(zhí)行任務(wù)隊(duì)列，包括：確定所述目標(biāo)系統(tǒng)中的全部可執(zhí)行任務(wù)；根據(jù)多個(gè)所述待執(zhí)行任務(wù)的優(yōu)先級(jí)對(duì)所述全部任務(wù)進(jìn)行排序，以得到所述可執(zhí)行任務(wù)隊(duì)列。

進(jìn)一步地，根據(jù)所述任務(wù)的優(yōu)先級(jí)對(duì)所述全部任務(wù)進(jìn)行排序，以得到所述可執(zhí)行任務(wù)隊(duì)列，包括：確定所述全部可執(zhí)行任務(wù)中的依賴任務(wù)以及一般任務(wù)；提升所述依賴任務(wù)的優(yōu)先級(jí)；根據(jù)所述依賴任務(wù)和所述一般任務(wù)的優(yōu)先級(jí)，對(duì)所述全部任務(wù)進(jìn)行排序，以得到所述可執(zhí)行任務(wù)隊(duì)列。

進(jìn)一步地，根據(jù)所述依賴任務(wù)和所述一般任務(wù)的優(yōu)先級(jí)，對(duì)所述全部任務(wù)進(jìn)行排序，以得到所述可執(zhí)行任務(wù)隊(duì)列，包括：根據(jù)所述目標(biāo)系統(tǒng)對(duì)應(yīng)的處理器的性能參數(shù)；根據(jù)所述性能參數(shù)確定所述可執(zhí)行任務(wù)隊(duì)列的隊(duì)列長度；根據(jù)所述隊(duì)列長度、所述依賴任務(wù)和所述一般任務(wù)的優(yōu)先級(jí)，對(duì)所述全部任務(wù)進(jìn)行排序，以得到所述可執(zhí)行任務(wù)隊(duì)列，

進(jìn)一步地，在所述待執(zhí)行任務(wù)完成時(shí)，生成所述任務(wù)獲取指令，包括：在所述待執(zhí)行任務(wù)完成時(shí)，生成任務(wù)完成事件；將所述任務(wù)完成事件加入通知隊(duì)列；根據(jù)所述通知隊(duì)列生成所述任務(wù)獲取指令。

根據(jù)本發(fā)明實(shí)施例的另一方面，還提供了一種多任務(wù)執(zhí)行裝置，包括：獲取單元，用于在接收到任務(wù)獲取指令時(shí)，獲取目標(biāo)系統(tǒng)中的可執(zhí)行任務(wù)隊(duì)列，所述可執(zhí)行任務(wù)隊(duì)列包括可執(zhí)行的多個(gè)待執(zhí)行任務(wù)；執(zhí)行單元，用于并行執(zhí)行所述可執(zhí)行任務(wù)隊(duì)列中的待執(zhí)行任務(wù)；處理單元，用于在所述待執(zhí)行任務(wù)完成時(shí)，生成所述任務(wù)獲取指令。