[發(fā)明專利]基于多進(jìn)程的任務(wù)調(diào)度方法、裝置、計(jì)算機(jī)設(shè)備及介質(zhì)

在審

• 申請?zhí)枺?/td>: 202010610172.6
• 申請日: 2020-06-29
• 公開（公告）號(hào): CN111813515A
• 公開（公告）日: 2020-10-23
• 發(fā)明（設(shè)計(jì)）人: 鄒芳;黃鵬;趙永超;李彥良
• 申請（專利權(quán)）人: 中國平安人壽保險(xiǎn)股份有限公司
• 主分類號(hào): G06F9/48
• 分類號(hào): G06F9/48;G06F9/50
• 代理公司: 深圳市世聯(lián)合知識(shí)產(chǎn)權(quán)代理有限公司 44385
• 代理人: 汪琳琳

1.一種基于多進(jìn)程的任務(wù)調(diào)度方法，其特征在于，所述基于多進(jìn)程的任務(wù)調(diào)度方法包括：

獲取每個(gè)待處理的基礎(chǔ)任務(wù)，對所述基礎(chǔ)任務(wù)進(jìn)行解析，得到所述基礎(chǔ)任務(wù)的開始時(shí)間和結(jié)束時(shí)間；

基于所述開始時(shí)間的先后順序，對所述基礎(chǔ)任務(wù)進(jìn)行排序，得到任務(wù)序列；

初始化最小堆二叉樹，將所述任務(wù)序列第一個(gè)基礎(chǔ)任務(wù)的結(jié)束時(shí)間寫入到所述最小堆二叉樹的節(jié)點(diǎn)鍵值中，并構(gòu)建任務(wù)進(jìn)程，使用所述任務(wù)進(jìn)程執(zhí)行所述任務(wù)序列中的第一個(gè)基礎(chǔ)任務(wù)，其中，所述最小堆二叉樹的每條分枝指示一個(gè)任務(wù)進(jìn)程；

針對任務(wù)序列中的第i個(gè)所述基礎(chǔ)任務(wù)，在當(dāng)前時(shí)間為所述基礎(chǔ)任務(wù)的開始時(shí)間時(shí)，若所述最小堆二叉樹中的根節(jié)點(diǎn)鍵值對應(yīng)的時(shí)間點(diǎn)在當(dāng)前時(shí)間之后，則對所述最小堆二叉樹生成新的分枝，并將第i個(gè)基礎(chǔ)任務(wù)對應(yīng)的結(jié)束時(shí)間寫入到所述新的分枝的節(jié)點(diǎn)鍵值中，其中，i為大于1的正整數(shù)；

構(gòu)建所述新的分枝對應(yīng)的任務(wù)進(jìn)程，使用所述新的分枝對應(yīng)的任務(wù)進(jìn)程執(zhí)行第i個(gè)所述基礎(chǔ)任務(wù)。

2.如權(quán)利要求1所述的基于多進(jìn)程的任務(wù)調(diào)度方法，其特征在于，在所述基于所述開始時(shí)間的先后順序，對所述基礎(chǔ)任務(wù)進(jìn)行排序，得到任務(wù)序列之后，所述基于多進(jìn)程的任務(wù)調(diào)度方法還包括：

接收新的任務(wù)數(shù)據(jù)，并獲取所述新的任務(wù)數(shù)據(jù)的開始時(shí)間和所述新的任務(wù)數(shù)據(jù)的結(jié)束時(shí)間；

從所述任務(wù)序列中，隨機(jī)選取一個(gè)位置，作為所述新的任務(wù)數(shù)據(jù)的初始位置；

基于所述初始位置和所述新的任務(wù)數(shù)據(jù)的開始時(shí)間，采用二分法進(jìn)行調(diào)整排序，得到更新后的任務(wù)序列。

3.如權(quán)利要求1所述的基于多進(jìn)程的任務(wù)調(diào)度方法，其特征在于，所述構(gòu)建任務(wù)進(jìn)程，使用所述任務(wù)進(jìn)程執(zhí)行所述任務(wù)序列中的第一個(gè)基礎(chǔ)任務(wù)之后，所述基于多進(jìn)程的任務(wù)調(diào)度方法還包括：

按照預(yù)設(shè)的線程數(shù)量，在所述任務(wù)進(jìn)程中創(chuàng)建定長線程池；

通過所述定長線程池，執(zhí)行所述任務(wù)進(jìn)程中的第一個(gè)基礎(chǔ)任務(wù)。

4.如權(quán)利要求1至3任一項(xiàng)所述的基于多進(jìn)程的任務(wù)調(diào)度方法，其特征在于，在所述初始化最小堆二叉樹，將所述任務(wù)序列第一個(gè)基礎(chǔ)任務(wù)的結(jié)束時(shí)間寫入到所述最小堆二叉樹的節(jié)點(diǎn)鍵值中，并構(gòu)建任務(wù)進(jìn)程，使用所述任務(wù)進(jìn)程執(zhí)行所述任務(wù)序列中的第一個(gè)基礎(chǔ)任務(wù)之后，所述基于多進(jìn)程的任務(wù)調(diào)度方法還包括：

定期獲取根節(jié)點(diǎn)鍵值對應(yīng)的時(shí)間點(diǎn)，并將所述根節(jié)點(diǎn)鍵值對應(yīng)的時(shí)間點(diǎn)與獲取時(shí)間點(diǎn)進(jìn)行比較，得到比較結(jié)果；

若所述比較結(jié)果為所述根節(jié)點(diǎn)鍵值對應(yīng)的時(shí)間點(diǎn)在所述獲取時(shí)間點(diǎn)之前，則將所述根節(jié)點(diǎn)進(jìn)行節(jié)點(diǎn)下沉，作為更新后的子節(jié)點(diǎn)，并構(gòu)建新的根節(jié)點(diǎn)；

銷毀更新后的子節(jié)點(diǎn)對應(yīng)的任務(wù)進(jìn)程。

5.如權(quán)利要求4所述的基于多進(jìn)程的任務(wù)調(diào)度方法，其特征在于，若所述比較結(jié)果為所述根節(jié)點(diǎn)鍵值對應(yīng)的時(shí)間點(diǎn)在所述獲取時(shí)間點(diǎn)之前，則將所述根節(jié)點(diǎn)進(jìn)行節(jié)點(diǎn)下沉，作為更新后的子節(jié)點(diǎn)，并構(gòu)建新的根節(jié)點(diǎn)包括：

從所述根節(jié)點(diǎn)的子節(jié)點(diǎn)中，選取任一子節(jié)點(diǎn)作為目標(biāo)子節(jié)點(diǎn)；

在所述根節(jié)點(diǎn)與所述目標(biāo)子節(jié)點(diǎn)中，插入新的節(jié)點(diǎn)，作為中間節(jié)點(diǎn)，其中，所述中間節(jié)點(diǎn)的鍵值的初始值為空；

將所述根節(jié)點(diǎn)與所述中間節(jié)點(diǎn)的鍵值進(jìn)行交換，更新節(jié)點(diǎn)索引，并將下沉后的根節(jié)點(diǎn)，作為更新后的子節(jié)點(diǎn)，將更新后的中間節(jié)點(diǎn)，作為所述新的根節(jié)點(diǎn)。

6.如權(quán)利要求1所述的基于多進(jìn)程的任務(wù)調(diào)度方法，其特征在于，在構(gòu)建所述新的分枝對應(yīng)的任務(wù)進(jìn)程，使用所述新的分枝對應(yīng)的任務(wù)進(jìn)程執(zhí)行第i個(gè)基礎(chǔ)任務(wù)之后，所述基于多進(jìn)程的任務(wù)調(diào)度方法還包括：將得到的最小堆二叉樹存儲(chǔ)于區(qū)塊鏈網(wǎng)絡(luò)節(jié)點(diǎn)中。