[發(fā)明專利]基于多線程的定時(shí)任務(wù)運(yùn)行方法、裝置、設(shè)備及存儲介質(zhì)

在審

• 申請?zhí)枺?/td>: 202011207416.2
• 申請日: 2020-11-03
• 公開（公告）號: CN112307105A
• 公開（公告）日: 2021-02-02
• 發(fā)明（設(shè)計(jì)）人: 周光華
• 申請（專利權(quán)）人: 平安普惠企業(yè)管理有限公司
• 主分類號: G06F16/25
• 分類號: G06F16/25;G06F16/23;G06F16/22;G06Q40/00
• 代理公司: 北京市京大律師事務(wù)所 11321
• 代理人: 姚維

本發(fā)明涉及云技術(shù)領(lǐng)域，公開了一種基于多線程的定時(shí)任務(wù)運(yùn)行方法、裝置、設(shè)備及存儲介質(zhì)，用于提高資源的利用率和處理數(shù)據(jù)的工作效率。基于多線程的定時(shí)任務(wù)運(yùn)行方法包括：獲取多個(gè)定時(shí)任務(wù)與執(zhí)行時(shí)刻；基于每個(gè)業(yè)務(wù)數(shù)據(jù)量將對應(yīng)的定時(shí)任務(wù)拆分為多個(gè)子定時(shí)任務(wù)；基于預(yù)先設(shè)置好的數(shù)據(jù)庫鎖和多個(gè)預(yù)先設(shè)置好的運(yùn)行線程創(chuàng)建多個(gè)臨時(shí)子節(jié)點(diǎn)編號；當(dāng)目標(biāo)子定時(shí)任務(wù)在執(zhí)行時(shí)刻被觸發(fā)時(shí)，基于多個(gè)臨時(shí)子節(jié)點(diǎn)編號和數(shù)據(jù)庫鎖在多個(gè)運(yùn)行線程中確定目標(biāo)運(yùn)行線程；通過數(shù)據(jù)庫鎖更新目標(biāo)子定時(shí)任務(wù)的狀態(tài)為工作狀態(tài)，并通過目標(biāo)運(yùn)行線程執(zhí)行目標(biāo)子定時(shí)任務(wù)，得到目標(biāo)任務(wù)數(shù)據(jù)，此外，本發(fā)明還涉及區(qū)塊鏈技術(shù)，目標(biāo)任務(wù)數(shù)據(jù)可存儲于區(qū)塊鏈中。

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

本發(fā)明涉及云計(jì)算技術(shù)領(lǐng)域，尤其涉及一種基于多線程的定時(shí)任務(wù)運(yùn)行方法、裝置、設(shè)備及存儲介質(zhì)。

背景技術(shù)

分布式系統(tǒng)是多個(gè)處理機(jī)通過通信線路互聯(lián)而構(gòu)成的松散耦合的系統(tǒng)，分布式系統(tǒng)擁有多種通用的物理和邏輯資源，可以動(dòng)態(tài)的分配任務(wù)，分散的物理和邏輯資源通過計(jì)算機(jī)網(wǎng)絡(luò)實(shí)現(xiàn)信息交換。

目前，很多公司的管理系統(tǒng)都會在分布式環(huán)境下執(zhí)行定時(shí)任務(wù)，某管理系統(tǒng)涉及到多臺服務(wù)器以及多個(gè)定時(shí)任務(wù)，當(dāng)在某一個(gè)時(shí)刻服務(wù)器需要執(zhí)行某一項(xiàng)定時(shí)任務(wù)時(shí)，通常有兩種執(zhí)行方式，其中一種是將該定時(shí)任務(wù)部署到其中一臺服務(wù)器上進(jìn)行執(zhí)行，若服務(wù)器出現(xiàn)故障，則無法及時(shí)執(zhí)行該定時(shí)任務(wù)。另一個(gè)方式是在分布式環(huán)境下多臺服務(wù)器執(zhí)行該定時(shí)任務(wù)，這種方式會導(dǎo)致該定時(shí)任務(wù)被重復(fù)執(zhí)行，既浪費(fèi)資源又降低了處理數(shù)據(jù)的工作效率。

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

本發(fā)明提供了一種基于多線程的定時(shí)任務(wù)運(yùn)行方法、裝置、設(shè)備及存儲介質(zhì)，提高了資源的利用率和處理數(shù)據(jù)的工作效率。

本發(fā)明第一方面提供了一種基于多線程的定時(shí)任務(wù)運(yùn)行方法，包括：獲取多個(gè)定時(shí)任務(wù)與執(zhí)行時(shí)刻，所述多個(gè)定時(shí)任務(wù)為財(cái)務(wù)管理系統(tǒng)發(fā)出的多個(gè)任務(wù)；基于每個(gè)定時(shí)任務(wù)讀取對應(yīng)的業(yè)務(wù)數(shù)據(jù)量，基于每個(gè)業(yè)務(wù)數(shù)據(jù)量將對應(yīng)的定時(shí)任務(wù)拆分為多個(gè)子定時(shí)任務(wù)；基于預(yù)先設(shè)置好的數(shù)據(jù)庫鎖和多個(gè)預(yù)先設(shè)置好的運(yùn)行線程創(chuàng)建多個(gè)臨時(shí)子節(jié)點(diǎn)編號；當(dāng)目標(biāo)子定時(shí)任務(wù)在所述執(zhí)行時(shí)刻被觸發(fā)時(shí)，基于所述多個(gè)臨時(shí)子節(jié)點(diǎn)編號和所述數(shù)據(jù)庫鎖在多個(gè)運(yùn)行線程中確定目標(biāo)運(yùn)行線程；通過所述數(shù)據(jù)庫鎖更新所述目標(biāo)子定時(shí)任務(wù)的狀態(tài)為工作狀態(tài)，并通過所述目標(biāo)運(yùn)行線程執(zhí)行所述目標(biāo)子定時(shí)任務(wù)，得到與所述目標(biāo)子定時(shí)任務(wù)對應(yīng)的目標(biāo)任務(wù)數(shù)據(jù)。

可選的，在本發(fā)明第一方面的第一種實(shí)現(xiàn)方式中，所述基于預(yù)先設(shè)置好的數(shù)據(jù)庫鎖和多個(gè)預(yù)先設(shè)置好的運(yùn)行線程創(chuàng)建多個(gè)臨時(shí)子節(jié)點(diǎn)編號包括：讀取預(yù)先設(shè)置好的數(shù)據(jù)庫鎖的名稱，得到數(shù)據(jù)庫鎖名稱，并創(chuàng)建以所述數(shù)據(jù)庫鎖名稱命名路徑的父節(jié)點(diǎn)；在所述父節(jié)點(diǎn)的路徑下創(chuàng)建與每個(gè)運(yùn)行線程對應(yīng)的臨時(shí)子節(jié)點(diǎn)，并讀取每個(gè)臨時(shí)子節(jié)點(diǎn)的路徑；基于每個(gè)臨時(shí)子節(jié)點(diǎn)的路徑創(chuàng)建與每個(gè)臨時(shí)子節(jié)點(diǎn)對應(yīng)的臨時(shí)子節(jié)點(diǎn)編號，得到多個(gè)臨時(shí)子節(jié)點(diǎn)編號。

可選的，在本發(fā)明第一方面的第二種實(shí)現(xiàn)方式中，所述當(dāng)目標(biāo)子定時(shí)任務(wù)在所述執(zhí)行時(shí)刻被觸發(fā)時(shí)，基于所述多個(gè)臨時(shí)子節(jié)點(diǎn)編號和所述數(shù)據(jù)庫鎖在多個(gè)運(yùn)行線程中確定目標(biāo)運(yùn)行線程包括：當(dāng)目標(biāo)子定時(shí)任務(wù)在所述執(zhí)行時(shí)刻被觸發(fā)時(shí)，在所述多個(gè)臨時(shí)子節(jié)點(diǎn)編號中搜尋最小的臨時(shí)子節(jié)點(diǎn)編號，將所述最小的臨時(shí)子節(jié)點(diǎn)編號確定為目標(biāo)子節(jié)點(diǎn)編號；基于所述目標(biāo)子節(jié)點(diǎn)編號確定對應(yīng)的運(yùn)行線程為目標(biāo)運(yùn)行線程。

可選的，在本發(fā)明第一方面的第三種實(shí)現(xiàn)方式中，所述通過所述數(shù)據(jù)庫鎖更新所述目標(biāo)子定時(shí)任務(wù)的狀態(tài)為工作狀態(tài)，并通過所述目標(biāo)運(yùn)行線程執(zhí)行所述目標(biāo)子定時(shí)任務(wù)，得到與所述目標(biāo)子定時(shí)任務(wù)對應(yīng)的目標(biāo)任務(wù)數(shù)據(jù)包括：調(diào)整所述數(shù)據(jù)庫鎖的記錄為工作記錄，從而將所述目標(biāo)子定時(shí)任務(wù)的狀態(tài)更新為工作狀態(tài)；通過所述目標(biāo)運(yùn)行線程確定所述目標(biāo)子定時(shí)任務(wù)對應(yīng)的目標(biāo)數(shù)據(jù)哈希值；根據(jù)所述目標(biāo)數(shù)據(jù)哈希值確定與所述目標(biāo)子定時(shí)任務(wù)對應(yīng)的目標(biāo)任務(wù)數(shù)據(jù)。