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

有效

• 申請(qǐng)?zhí)枺?/td>: 202111005900.1
• 申請(qǐng)日: 2021-08-30
• 公開（公告）號(hào): CN113656257B
• 公開（公告）日: 2023-08-11
• 發(fā)明（設(shè)計(jì)）人: 彭佩
• 申請(qǐng)（專利權(quán)）人: 中國(guó)平安財(cái)產(chǎn)保險(xiǎn)股份有限公司
• 主分類號(hào): G06F11/30
• 分類號(hào): G06F11/30;G06F9/48
• 代理公司: 北京市京大律師事務(wù)所 11321
• 代理人: 姚維

1.一種調(diào)度任務(wù)的監(jiān)控方法，其特征在于，所述調(diào)度任務(wù)的監(jiān)控方法包括：

構(gòu)建調(diào)度存儲(chǔ)區(qū)，其中，所述調(diào)度存儲(chǔ)區(qū)包括一個(gè)雙向鏈表和多個(gè)候選鍵值對(duì)；

當(dāng)預(yù)設(shè)的項(xiàng)目程序啟動(dòng)之后，對(duì)所述雙向鏈表進(jìn)行數(shù)據(jù)初始化，得到第一任務(wù)隊(duì)列，以及對(duì)所述候選鍵值對(duì)進(jìn)行數(shù)據(jù)初始化，得到多個(gè)初始鍵值對(duì)，其中，所述第一任務(wù)隊(duì)列用于表示多個(gè)調(diào)度任務(wù)的執(zhí)行順序，所述初始鍵值對(duì)用于存儲(chǔ)每個(gè)調(diào)度任務(wù)的元信息；

接收終端發(fā)送的調(diào)度參數(shù)，并根據(jù)所述調(diào)度參數(shù)，確定所述初始鍵值對(duì)中的期望鍵值對(duì)，以及對(duì)所述期望鍵值對(duì)進(jìn)行數(shù)據(jù)更新，得到目標(biāo)鍵值對(duì)，對(duì)所述第一任務(wù)隊(duì)列進(jìn)行數(shù)據(jù)更新，得到第二任務(wù)隊(duì)列；

根據(jù)預(yù)設(shè)的業(yè)務(wù)需求，構(gòu)建監(jiān)控觸發(fā)器，并基于所述監(jiān)控觸發(fā)器、所述初始鍵值對(duì)以及所述目標(biāo)鍵值對(duì)確定所述第二任務(wù)隊(duì)列的任務(wù)編號(hào)，根據(jù)所述任務(wù)編號(hào)依次對(duì)所述第二任務(wù)隊(duì)列中的調(diào)度任務(wù)進(jìn)行超時(shí)檢測(cè)；

所述接收終端發(fā)送的調(diào)度參數(shù)，并根據(jù)所述調(diào)度參數(shù)，確定所述初始鍵值對(duì)中的期望鍵值對(duì)，以及對(duì)所述期望鍵值對(duì)進(jìn)行數(shù)據(jù)更新，得到目標(biāo)鍵值對(duì)包括：

接收終端發(fā)送的調(diào)度參數(shù)，所述調(diào)度參數(shù)中包括目標(biāo)任務(wù)的任務(wù)編號(hào)參數(shù)和目標(biāo)任務(wù)的執(zhí)行時(shí)刻參數(shù)，所述目標(biāo)任務(wù)為所述第一任務(wù)隊(duì)列中正在執(zhí)行的一項(xiàng)調(diào)度任務(wù)；

依次將每個(gè)初始鍵值對(duì)的第一鍵位與所述目標(biāo)任務(wù)的任務(wù)編號(hào)參數(shù)進(jìn)行匹配，當(dāng)匹配成功時(shí)，確定當(dāng)前的初始鍵值對(duì)為所述目標(biāo)任務(wù)對(duì)應(yīng)的期望鍵值對(duì)；

根據(jù)所述目標(biāo)任務(wù)的執(zhí)行時(shí)刻參數(shù)，更新目標(biāo)第二鍵位中的最近執(zhí)行時(shí)刻，得到目標(biāo)鍵值對(duì)，其中，所述目標(biāo)第二鍵位為所述期望鍵值對(duì)的第二鍵位。

2.根據(jù)權(quán)利要求1所述的調(diào)度任務(wù)的監(jiān)控方法，其特征在于，所述對(duì)所述雙向鏈表進(jìn)行數(shù)據(jù)初始化，得到第一任務(wù)隊(duì)列包括：

獲取所述項(xiàng)目程序中的注冊(cè)信息表，基于所述項(xiàng)目程序中的注冊(cè)信息表，確定每個(gè)調(diào)度任務(wù)的數(shù)據(jù)注入順序；

根據(jù)所述數(shù)據(jù)注入順序，依次將所述注冊(cè)信息表中每個(gè)調(diào)度任務(wù)對(duì)應(yīng)的任務(wù)編號(hào)存儲(chǔ)至所述雙向鏈表中，得到第一任務(wù)隊(duì)列。

3.根據(jù)權(quán)利要求2所述的調(diào)度任務(wù)的監(jiān)控方法，其特征在于，所述對(duì)所述候選鍵值對(duì)進(jìn)行數(shù)據(jù)初始化，得到多個(gè)初始鍵值對(duì)包括：

將所述注冊(cè)信息表中每個(gè)調(diào)度任務(wù)對(duì)應(yīng)的任務(wù)編號(hào)存儲(chǔ)至每個(gè)候選鍵值對(duì)中的第一鍵位；

將所述注冊(cè)信息表中每個(gè)調(diào)度任務(wù)對(duì)應(yīng)的最近執(zhí)行時(shí)刻以及所述注冊(cè)信息表中每個(gè)調(diào)度任務(wù)對(duì)應(yīng)的執(zhí)行時(shí)刻表達(dá)式存儲(chǔ)至每個(gè)候選鍵值對(duì)中的第二鍵位，得到多個(gè)初始鍵值對(duì)，其中，所述最近執(zhí)行時(shí)刻為距離當(dāng)前時(shí)間點(diǎn)最近一個(gè)的執(zhí)行時(shí)刻。

4.根據(jù)權(quán)利要求1所述的調(diào)度任務(wù)的監(jiān)控方法，其特征在于，所述第一任務(wù)隊(duì)列進(jìn)行數(shù)據(jù)更新，得到第二任務(wù)隊(duì)列還包括：

根據(jù)所述目標(biāo)任務(wù)的任務(wù)編號(hào)參數(shù)，在所述第一任務(wù)隊(duì)列中查找所述目標(biāo)任務(wù)對(duì)應(yīng)的任務(wù)編號(hào)；

將所述目標(biāo)任務(wù)對(duì)應(yīng)的任務(wù)編號(hào)移至所述第一任務(wù)隊(duì)列的隊(duì)尾，得到第二任務(wù)隊(duì)列。

5.根據(jù)權(quán)利要求4所述的調(diào)度任務(wù)的監(jiān)控方法，其特征在于，所述根據(jù)預(yù)設(shè)的業(yè)務(wù)需求，構(gòu)建監(jiān)控觸發(fā)器，并基于所述監(jiān)控觸發(fā)器、所述初始鍵值對(duì)以及所述目標(biāo)鍵值對(duì)確定所述第二任務(wù)隊(duì)列的任務(wù)編號(hào)，根據(jù)所述任務(wù)編號(hào)依次對(duì)所述第二任務(wù)隊(duì)列中的調(diào)度任務(wù)進(jìn)行超時(shí)檢測(cè)包括：

根據(jù)預(yù)設(shè)的業(yè)務(wù)需求，構(gòu)建監(jiān)控觸發(fā)器，并調(diào)用所述監(jiān)控觸發(fā)器，獲取所述第二任務(wù)隊(duì)列中首個(gè)調(diào)度任務(wù)對(duì)應(yīng)的第一任務(wù)編號(hào)，以及根據(jù)所述第一任務(wù)編號(hào)，從所述初始鍵值對(duì)和所述目標(biāo)鍵值對(duì)中查找第一鍵值對(duì)；

根據(jù)所述第一鍵值對(duì)，確定所述首個(gè)調(diào)度任務(wù)對(duì)應(yīng)的最近執(zhí)行時(shí)刻和所述首個(gè)調(diào)度任務(wù)對(duì)應(yīng)的執(zhí)行時(shí)刻表達(dá)式，并基于所述首個(gè)調(diào)度任務(wù)對(duì)應(yīng)的最近執(zhí)行時(shí)刻和所述首個(gè)調(diào)度任務(wù)對(duì)應(yīng)的執(zhí)行時(shí)刻表達(dá)式，計(jì)算首個(gè)調(diào)度任務(wù)對(duì)應(yīng)的下次執(zhí)行時(shí)刻；

獲取當(dāng)前系統(tǒng)時(shí)刻，將所述首個(gè)調(diào)度任務(wù)對(duì)應(yīng)的下次執(zhí)行時(shí)刻與所述當(dāng)前系統(tǒng)時(shí)刻進(jìn)行比較，若所述當(dāng)前系統(tǒng)時(shí)刻大于所述首個(gè)調(diào)度任務(wù)對(duì)應(yīng)的下次執(zhí)行時(shí)刻，則確定所述首個(gè)調(diào)度任務(wù)超時(shí)，并對(duì)所述第二任務(wù)隊(duì)列中的下一個(gè)調(diào)度任務(wù)進(jìn)行檢測(cè)，直至檢測(cè)到未超時(shí)的調(diào)度任務(wù)時(shí)，停止超時(shí)檢測(cè)。