[發(fā)明專利]交易任務(wù)的并行處理方法、裝置、電子設(shè)備和存儲介質(zhì)在審
| 申請?zhí)枺?/td> | 202010019486.9 | 申請日: | 2020-01-08 |
| 公開(公告)號: | CN113094184A | 公開(公告)日: | 2021-07-09 |
| 發(fā)明(設(shè)計)人: | 王緒旭;彭程;張曉亮 | 申請(專利權(quán))人: | 北京奇虎科技有限公司 |
| 主分類號: | G06F9/52 | 分類號: | G06F9/52;G06Q20/40;G06Q40/04 |
| 代理公司: | 北京恒博知識產(chǎn)權(quán)代理有限公司 11528 | 代理人: | 范勝祥 |
| 地址: | 100088 北京市西城區(qū)新*** | 國省代碼: | 北京;11 |
| 權(quán)利要求書: | 查看更多 | 說明書: | 查看更多 |
| 摘要: | |||
| 搜索關(guān)鍵詞: | 交易 任務(wù) 并行 處理 方法 裝置 電子設(shè)備 存儲 介質(zhì) | ||
本發(fā)明公開了交易任務(wù)的并行處理方法、裝置、電子設(shè)備和存儲介質(zhì)。所述方法包括:按照交易任務(wù)涉及的交易方,對多個交易任務(wù)進(jìn)行分組,得到多個交易任務(wù)組;啟動多個交易處理線程進(jìn)行并行的交易任務(wù)處理,在接收到交易處理線程的任務(wù)處理請求時,從非空的交易任務(wù)組中取出交易任務(wù)下發(fā)給相應(yīng)的交易處理線程。該技術(shù)方案的有益效果在于,利用交易處理線程組實現(xiàn)了交易任務(wù)的并行處理,并且通過按照交易任務(wù)涉及的交易方進(jìn)行預(yù)先分組,能夠在很大程度上避免交易任務(wù)之間的沖突。
技術(shù)領(lǐng)域
本發(fā)明涉及區(qū)塊鏈技術(shù)領(lǐng)域,具體涉及交易任務(wù)的并行處理方法、裝置、電子設(shè)備和存儲介質(zhì)。
背景技術(shù)
區(qū)塊鏈目前最廣泛的應(yīng)用就是數(shù)據(jù)資產(chǎn)的交易,但是,目前交易任務(wù)通常都是串行處理的,效率較低。而在于交易任務(wù)之間直接可能存在沖突,因此,交易任務(wù)的并行處理是一個新的挑戰(zhàn)。
發(fā)明內(nèi)容
鑒于上述問題,提出了本發(fā)明以便提供一種克服上述問題或者至少部分地解決上述問題的交易任務(wù)的并行處理方法、裝置、電子設(shè)備和存儲介質(zhì)。
依據(jù)本發(fā)明的一個方面,提供了一種交易任務(wù)的并行處理方法,包括:
按照交易任務(wù)涉及的交易方,對多個交易任務(wù)進(jìn)行分組,得到多個交易任務(wù)組;
啟動多個交易處理線程進(jìn)行并行的交易任務(wù)處理,在接收到交易處理線程的任務(wù)處理請求時,從非空的交易任務(wù)組中取出交易任務(wù)下發(fā)給相應(yīng)的交易處理線程。
可選地,所述方法還包括:
若所有交易任務(wù)均被處理和/或已處理的交易任務(wù)數(shù)量滿足第一閾值,則結(jié)束所有交易處理線程。
可選地,所述按照交易任務(wù)涉及的交易方,對多個交易任務(wù)進(jìn)行分組包括:
將涉及相同交易方的交易任務(wù)劃分至同一交易任務(wù)組。
可選地,所述按照交易任務(wù)涉及的交易方,對多個交易任務(wù)進(jìn)行分組包括:
使同一交易任務(wù)組中的交易任務(wù)數(shù)量不超過第二閾值。
可選地,所述啟動多個交易處理線程進(jìn)行并行的交易任務(wù)處理包括:
接收目標(biāo)交易處理線程對目標(biāo)變量的鎖請求,所述目標(biāo)變量為區(qū)塊鏈上數(shù)據(jù)所包含的變量;
若所述目標(biāo)變量已被添加變量鎖,則通知所述目標(biāo)交易處理線程等待該變量鎖釋放;
若所述目標(biāo)變量未被添加變量鎖,則使所述目標(biāo)交易處理線程獲得該目標(biāo)變量的變量鎖,并在目標(biāo)交易處理線程釋放該目標(biāo)變量的變量鎖后,通知等待該目標(biāo)變量的變量鎖釋放的各交易處理線程。
可選地,所述通知所述目標(biāo)交易處理線程等待該變量鎖釋放包括:
為所述目標(biāo)交易處理線程隨機(jī)設(shè)置等待時間,以使所述目標(biāo)交易處理線程在等待超時后,釋放其獲得的所有變量鎖。
可選地,所述方法還包括:
根據(jù)并行的交易任務(wù)處理過程中涉及的所有目標(biāo)變量,為每個處理成功的交易任務(wù)生成變量標(biāo)識;
根據(jù)所述變量標(biāo)識進(jìn)行并行的交易任務(wù)驗證。
可選地,所述根據(jù)所述變量標(biāo)識進(jìn)行并行的交易任務(wù)驗證包括:
啟動多個交易驗證線程,其中,在接收到一個交易驗證線程發(fā)送的交易驗證請求時,判斷下一個待驗證的交易任務(wù)的變量標(biāo)識是否與當(dāng)前正在驗證的各交易任務(wù)的變量標(biāo)識存在沖突,若存在沖突的變量標(biāo)識,則阻塞相應(yīng)的交易驗證線程,直至沖突的變量標(biāo)識對應(yīng)的交易任務(wù)被驗證完畢。
可選地,所述根據(jù)并行的交易任務(wù)處理過程中涉及的所有目標(biāo)變量,為每個處理成功的交易任務(wù)生成變量標(biāo)識包括:
該專利技術(shù)資料僅供研究查看技術(shù)是否侵權(quán)等信息,商用須獲得專利權(quán)人授權(quán)。該專利全部權(quán)利屬于北京奇虎科技有限公司,未經(jīng)北京奇虎科技有限公司許可,擅自商用是侵權(quán)行為。如果您想購買此專利、獲得商業(yè)授權(quán)和技術(shù)合作,請聯(lián)系【客服】
本文鏈接:http://www.szxzyx.cn/pat/books/202010019486.9/2.html,轉(zhuǎn)載請聲明來源鉆瓜專利網(wǎng)。
- 任務(wù)協(xié)作裝置及方法
- 用于量化任務(wù)價值的任務(wù)管理方法及裝置
- 用于運行任務(wù)的系統(tǒng)、方法和裝置
- 一種分布式任務(wù)調(diào)度系統(tǒng)及方法
- 任務(wù)信息處理方法
- 一種同步任務(wù)異步執(zhí)行的方法和調(diào)度系統(tǒng)
- 數(shù)據(jù)處理方法、裝置、電子設(shè)備及計算機(jī)可讀介質(zhì)
- 一種自動分配和推送的任務(wù)管理平臺及方法
- 程序執(zhí)行控制的裝置及方法、終端和存儲介質(zhì)
- 基于會話的任務(wù)待辦方法、系統(tǒng)、電子設(shè)備及存儲介質(zhì)





