[發(fā)明專利]一種任務(wù)的并發(fā)計(jì)算方法及裝置、設(shè)備、存儲(chǔ)介質(zhì)

在審

• 申請(qǐng)?zhí)枺?/td>: 202011190312.5
• 申請(qǐng)日: 2020-10-30
• 公開(kāi)（公告）號(hào): CN112306713A
• 公開(kāi)（公告）日: 2021-02-02
• 發(fā)明（設(shè)計(jì)）人: 方文其;江旻;楊楊;徐為愷
• 申請(qǐng)（專利權(quán)）人: 深圳前海微眾銀行股份有限公司
• 主分類號(hào): G06F9/54
• 分類號(hào): G06F9/54;G06F9/50;G06F11/30
• 代理公司: 北京派特恩知識(shí)產(chǎn)權(quán)代理有限公司 11270
• 代理人: 崔曉嵐;張穎玲

本申請(qǐng)實(shí)施例公開(kāi)了一種任務(wù)的并發(fā)計(jì)算方法及裝置、設(shè)備、存儲(chǔ)介質(zhì)，其中，該方法包括：獲取各原子任務(wù)之間無(wú)依賴的原子任務(wù)集合，其中，所述原子任務(wù)集合中的每一原子任務(wù)為待處理任務(wù)中的對(duì)應(yīng)預(yù)設(shè)步驟；將所述原子任務(wù)集合中的原子任務(wù)按照特定順序放入線程調(diào)起隊(duì)列；調(diào)用處理器中的線程一一對(duì)應(yīng)地執(zhí)行所述線程調(diào)起隊(duì)列中的原子任務(wù)；監(jiān)聽(tīng)每一所述原子任務(wù)的執(zhí)行狀態(tài)；在每一所述原子任務(wù)的執(zhí)行狀態(tài)均為已完成狀態(tài)的情況下，確定對(duì)所述待處理任務(wù)的并發(fā)處理完成。

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

本申請(qǐng)實(shí)施例涉及但不限于金融科技(Fintech)的信息技術(shù)，尤其涉及一種任務(wù)的并發(fā)計(jì)算方法及裝置、設(shè)備、存儲(chǔ)介質(zhì)。

背景技術(shù)

隨著計(jì)算機(jī)技術(shù)的發(fā)展，越來(lái)越多的技術(shù)應(yīng)用在金融領(lǐng)域，傳統(tǒng)金融業(yè)正在逐步向金融科技(Fintech)轉(zhuǎn)變，然而，由于金融行業(yè)的安全性、實(shí)時(shí)性要求，金融科技也對(duì)技術(shù)提出了更高的要求。金融科技領(lǐng)域下，并行計(jì)算方法存在未充分利用圖形處理器(GraphicsProcessing Unit，GPU)的高并行的計(jì)算能力的問(wèn)題，導(dǎo)致任務(wù)執(zhí)行效率不高。

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

有鑒于此，本申請(qǐng)實(shí)施例為解決相關(guān)技術(shù)中存在的至少一個(gè)問(wèn)題而提供一種任務(wù)的并發(fā)計(jì)算方法及裝置、設(shè)備、存儲(chǔ)介質(zhì)。

本申請(qǐng)實(shí)施例的技術(shù)方案是這樣實(shí)現(xiàn)的：

一方面，本申請(qǐng)實(shí)施例提供一種任務(wù)的并發(fā)處理方法，所述方法包括：

獲取各原子任務(wù)之間無(wú)依賴的原子任務(wù)集合，其中，所述原子任務(wù)集合中的每一原子任務(wù)為待處理任務(wù)中的對(duì)應(yīng)預(yù)設(shè)步驟；

將所述原子任務(wù)集合中的原子任務(wù)按照特定順序放入線程調(diào)起隊(duì)列；

調(diào)用處理器中的線程一一對(duì)應(yīng)地執(zhí)行所述線程調(diào)起隊(duì)列中的原子任務(wù)；

監(jiān)聽(tīng)每一所述原子任務(wù)的執(zhí)行狀態(tài)；

在每一所述原子任務(wù)的執(zhí)行狀態(tài)均為已完成狀態(tài)的情況下，確定對(duì)所述待處理任務(wù)的并發(fā)處理完成。

又一方面，本申請(qǐng)實(shí)施例提供一種任務(wù)的并發(fā)處理裝置，所述裝置包括：

第一獲取模塊，用于獲取各原子任務(wù)之間無(wú)依賴的原子任務(wù)集合，其中，所述原子任務(wù)集合中的每一原子任務(wù)為待處理任務(wù)中的對(duì)應(yīng)預(yù)設(shè)步驟；

入隊(duì)模塊，用于將所述原子任務(wù)集合中的原子任務(wù)按照特定順序放入線程調(diào)起隊(duì)列；

執(zhí)行模塊，用于調(diào)用所述處理器中的線程一一對(duì)應(yīng)地執(zhí)行所述線程調(diào)起隊(duì)列中的原子任務(wù)；

監(jiān)聽(tīng)模塊，用于監(jiān)聽(tīng)每一所述原子任務(wù)的執(zhí)行狀態(tài)；

確定模塊，用于在每一所述原子任務(wù)的執(zhí)行狀態(tài)均為已完成狀態(tài)的情況下，確定對(duì)所述待處理任務(wù)的并發(fā)處理完成。

再一方面，本申請(qǐng)實(shí)施例提供一種計(jì)算機(jī)設(shè)備，包括存儲(chǔ)器和處理器，所述存儲(chǔ)器存儲(chǔ)有可在處理器上運(yùn)行的計(jì)算機(jī)程序，所述處理器執(zhí)行所述程序時(shí)實(shí)現(xiàn)上述方法中的步驟。

還一方面，本申請(qǐng)實(shí)施例提供一種計(jì)算機(jī)可讀存儲(chǔ)介質(zhì)，其上存儲(chǔ)有計(jì)算機(jī)程序，該計(jì)算機(jī)程序被處理器執(zhí)行時(shí)實(shí)現(xiàn)上述方法中的步驟。

本申請(qǐng)實(shí)施例提供的任務(wù)的并發(fā)處理方法，通過(guò)獲取各原子任務(wù)之間無(wú)依賴的原子任務(wù)集合；將所述原子任務(wù)集合中的原子任務(wù)按照特定順序放入線程調(diào)起隊(duì)列；調(diào)用處理器中的線程一一對(duì)應(yīng)地執(zhí)行所述線程調(diào)起隊(duì)列中的原子任務(wù)。這樣，能夠?qū)⒏髟尤蝿?wù)之間無(wú)依賴的原子任務(wù)放在一個(gè)集合中，在保證集合中的原子任務(wù)執(zhí)行時(shí)不會(huì)相互影響的前提下，通過(guò)同時(shí)調(diào)用多個(gè)線程一一對(duì)應(yīng)的執(zhí)行所述線程調(diào)起隊(duì)列中的原子任務(wù)，實(shí)現(xiàn)多線程并發(fā)的計(jì)算原子任務(wù)，從而充分利用處理器的高并行計(jì)算能力，提高所述原子任務(wù)的執(zhí)行效率。

附圖說(shuō)明

圖1為本申請(qǐng)實(shí)施例任務(wù)的并發(fā)處理方法的實(shí)現(xiàn)流程示意圖；