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

在審

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

1.一種基于多線程的定時(shí)任務(wù)運(yùn)行方法，其特征在于，所述基于多線程的定時(shí)任務(wù)運(yùn)行方法包括：

獲取多個(gè)定時(shí)任務(wù)與執(zhí)行時(shí)刻，所述多個(gè)定時(shí)任務(wù)為財(cái)務(wù)管理系統(tǒng)發(fā)出的多個(gè)任務(wù)；

基于每個(gè)定時(shí)任務(wù)讀取對(duì)應(yīng)的業(yè)務(wù)數(shù)據(jù)量，基于每個(gè)業(yè)務(wù)數(shù)據(jù)量將對(duì)應(yīng)的定時(shí)任務(wù)拆分為多個(gè)子定時(shí)任務(wù)；

基于預(yù)先設(shè)置好的數(shù)據(jù)庫(kù)鎖和多個(gè)預(yù)先設(shè)置好的運(yùn)行線程創(chuàng)建多個(gè)臨時(shí)子節(jié)點(diǎn)編號(hào)；

當(dāng)目標(biāo)子定時(shí)任務(wù)在所述執(zhí)行時(shí)刻被觸發(fā)時(shí)，基于所述多個(gè)臨時(shí)子節(jié)點(diǎn)編號(hào)和所述數(shù)據(jù)庫(kù)鎖在多個(gè)運(yùn)行線程中確定目標(biāo)運(yùn)行線程；

通過(guò)所述數(shù)據(jù)庫(kù)鎖更新所述目標(biāo)子定時(shí)任務(wù)的狀態(tài)為工作狀態(tài)，并通過(guò)所述目標(biāo)運(yùn)行線程執(zhí)行所述目標(biāo)子定時(shí)任務(wù)，得到與所述目標(biāo)子定時(shí)任務(wù)對(duì)應(yīng)的目標(biāo)任務(wù)數(shù)據(jù)。

2.根據(jù)權(quán)利要求1所述的基于多線程的定時(shí)任務(wù)運(yùn)行方法，其特征在于，所述基于預(yù)先設(shè)置好的數(shù)據(jù)庫(kù)鎖和多個(gè)預(yù)先設(shè)置好的運(yùn)行線程創(chuàng)建多個(gè)臨時(shí)子節(jié)點(diǎn)編號(hào)包括：

讀取預(yù)先設(shè)置好的數(shù)據(jù)庫(kù)鎖的名稱(chēng)，得到數(shù)據(jù)庫(kù)鎖名稱(chēng)，并創(chuàng)建以所述數(shù)據(jù)庫(kù)鎖名稱(chēng)命名路徑的父節(jié)點(diǎn)；

在所述父節(jié)點(diǎn)的路徑下創(chuàng)建與每個(gè)運(yùn)行線程對(duì)應(yīng)的臨時(shí)子節(jié)點(diǎn)，并讀取每個(gè)臨時(shí)子節(jié)點(diǎn)的路徑；

基于每個(gè)臨時(shí)子節(jié)點(diǎn)的路徑創(chuàng)建與每個(gè)臨時(shí)子節(jié)點(diǎn)對(duì)應(yīng)的臨時(shí)子節(jié)點(diǎn)編號(hào)，得到多個(gè)臨時(shí)子節(jié)點(diǎn)編號(hào)。

3.根據(jù)權(quán)利要求2所述的基于多線程的定時(shí)任務(wù)運(yùn)行方法，其特征在于，所述當(dāng)目標(biāo)子定時(shí)任務(wù)在所述執(zhí)行時(shí)刻被觸發(fā)時(shí)，基于所述多個(gè)臨時(shí)子節(jié)點(diǎn)編號(hào)和所述數(shù)據(jù)庫(kù)鎖在多個(gè)運(yùn)行線程中確定目標(biāo)運(yùn)行線程包括：

當(dāng)目標(biāo)子定時(shí)任務(wù)在所述執(zhí)行時(shí)刻被觸發(fā)時(shí)，在所述多個(gè)臨時(shí)子節(jié)點(diǎn)編號(hào)中搜尋最小的臨時(shí)子節(jié)點(diǎn)編號(hào)，將所述最小的臨時(shí)子節(jié)點(diǎn)編號(hào)確定為目標(biāo)子節(jié)點(diǎn)編號(hào)；

基于所述目標(biāo)子節(jié)點(diǎn)編號(hào)確定對(duì)應(yīng)的運(yùn)行線程為目標(biāo)運(yùn)行線程。

4.根據(jù)權(quán)利要求1所述的基于多線程的定時(shí)任務(wù)運(yùn)行方法，其特征在于，所述通過(guò)所述數(shù)據(jù)庫(kù)鎖更新所述目標(biāo)子定時(shí)任務(wù)的狀態(tài)為工作狀態(tài)，并通過(guò)所述目標(biāo)運(yùn)行線程執(zhí)行所述目標(biāo)子定時(shí)任務(wù)，得到與所述目標(biāo)子定時(shí)任務(wù)對(duì)應(yīng)的目標(biāo)任務(wù)數(shù)據(jù)包括：

調(diào)整所述數(shù)據(jù)庫(kù)鎖的記錄為工作記錄，從而將所述目標(biāo)子定時(shí)任務(wù)的狀態(tài)更新為工作狀態(tài)；

通過(guò)所述目標(biāo)運(yùn)行線程確定所述目標(biāo)子定時(shí)任務(wù)對(duì)應(yīng)的目標(biāo)數(shù)據(jù)哈希值；

根據(jù)所述目標(biāo)數(shù)據(jù)哈希值確定與所述目標(biāo)子定時(shí)任務(wù)對(duì)應(yīng)的目標(biāo)任務(wù)數(shù)據(jù)。

5.根據(jù)權(quán)利要求4所述的基于多線程的定時(shí)任務(wù)運(yùn)行方法，其特征在于，所述通過(guò)所述目標(biāo)運(yùn)行線程確定所述目標(biāo)子定時(shí)任務(wù)對(duì)應(yīng)的目標(biāo)數(shù)據(jù)哈希值包括：

從所述目標(biāo)子定時(shí)任務(wù)中讀取目標(biāo)子定時(shí)任務(wù)編號(hào)，并通過(guò)所述目標(biāo)運(yùn)行線程在多個(gè)預(yù)置的數(shù)據(jù)分區(qū)中確定與所述目標(biāo)子定時(shí)任務(wù)編號(hào)對(duì)應(yīng)的目標(biāo)數(shù)據(jù)分區(qū)，所述目標(biāo)子定時(shí)任務(wù)編號(hào)與所述目標(biāo)數(shù)據(jù)分區(qū)的編號(hào)相同；

通過(guò)所述目標(biāo)運(yùn)行線程在所述目標(biāo)數(shù)據(jù)分區(qū)中確定目標(biāo)數(shù)據(jù)鍵名；

基于預(yù)置的哈希函數(shù)結(jié)合所述目標(biāo)數(shù)據(jù)鍵名和所述目標(biāo)子定時(shí)任務(wù)的編號(hào)計(jì)算哈希值，得到目標(biāo)哈希值。

6.根據(jù)權(quán)利要求1所述的基于多線程的定時(shí)任務(wù)運(yùn)行方法，其特征在于，在所述獲取多個(gè)定時(shí)任務(wù)與執(zhí)行時(shí)刻，所述多個(gè)定時(shí)任務(wù)為財(cái)務(wù)管理系統(tǒng)發(fā)出的多個(gè)任務(wù)之前，所述基于多線程的定時(shí)任務(wù)運(yùn)行方法還包括：

在預(yù)置的數(shù)據(jù)庫(kù)表中增加數(shù)據(jù)庫(kù)鎖，并讀取服務(wù)器的線程閾值，基于所述線程閾值創(chuàng)建線程，得到多個(gè)運(yùn)行線程，所述數(shù)據(jù)庫(kù)鎖用于鎖定任務(wù)的狀態(tài)。

7.根據(jù)權(quán)利要求1-6中任意一項(xiàng)所述的基于多線程的定時(shí)任務(wù)運(yùn)行方法，其特征在于，在所述通過(guò)所述數(shù)據(jù)庫(kù)鎖更新所述目標(biāo)子定時(shí)任務(wù)的狀態(tài)為工作狀態(tài)，并通過(guò)所述目標(biāo)運(yùn)行線程執(zhí)行所述目標(biāo)子定時(shí)任務(wù)，得到與所述目標(biāo)子定時(shí)任務(wù)對(duì)應(yīng)的目標(biāo)任務(wù)數(shù)據(jù)之后，所述基于多線程的定時(shí)任務(wù)運(yùn)行方法還包括：

實(shí)時(shí)讀取所述目標(biāo)子定時(shí)任務(wù)的狀態(tài)，得到實(shí)時(shí)目標(biāo)子定時(shí)任務(wù)狀態(tài)；

判斷所述實(shí)時(shí)目標(biāo)子定時(shí)任務(wù)狀態(tài)是否為斷開(kāi)狀態(tài)；

若所述實(shí)時(shí)目標(biāo)子定時(shí)任務(wù)狀態(tài)為所述斷開(kāi)狀態(tài)，則基于數(shù)據(jù)庫(kù)鎖再次在所述多個(gè)運(yùn)行線程中確定目標(biāo)運(yùn)行線程。