[發(fā)明專利]基于內(nèi)存映射文件的跨進(jìn)程異步任務(wù)處理方法及系統(tǒng)在審
| 申請(qǐng)?zhí)枺?/td> | 202110321934.5 | 申請(qǐng)日: | 2021-03-25 |
| 公開(公告)號(hào): | CN112965805A | 公開(公告)日: | 2021-06-15 |
| 發(fā)明(設(shè)計(jì))人: | 吝曉軍;宋仁春 | 申請(qǐng)(專利權(quán))人: | 興業(yè)數(shù)字金融服務(wù)(上海)股份有限公司 |
| 主分類號(hào): | G06F9/48 | 分類號(hào): | G06F9/48;G06F12/0871;G06F12/0873 |
| 代理公司: | 上海段和段律師事務(wù)所 31334 | 代理人: | 李佳俊;郭國(guó)中 |
| 地址: | 200120 上海市*** | 國(guó)省代碼: | 上海;31 |
| 權(quán)利要求書: | 查看更多 | 說(shuō)明書: | 查看更多 |
| 摘要: | |||
| 搜索關(guān)鍵詞: | 基于 內(nèi)存 映射 文件 跨進(jìn) 異步 任務(wù) 處理 方法 系統(tǒng) | ||
1.一種基于內(nèi)存映射文件的跨進(jìn)程異步任務(wù)處理方法,其特征在于,包括:
步驟S1:主交易進(jìn)程調(diào)用異步任務(wù)信息記錄模塊將需要處理的異步任務(wù)寫入任務(wù)存儲(chǔ)模塊中;
步驟S2:異步任務(wù)信息處理模塊從任務(wù)存儲(chǔ)模塊中讀取待處理的異步任務(wù)進(jìn)行處理。
2.根據(jù)權(quán)利要求1所述的基于內(nèi)存映射文件的跨進(jìn)程異步任務(wù)處理方法,其特征在于,所述步驟S1中任務(wù)存儲(chǔ)模塊包括:N個(gè)存儲(chǔ)組,每個(gè)存儲(chǔ)組包括任務(wù)信息存儲(chǔ)文件和任務(wù)信息索引文件;
所述任務(wù)信息存儲(chǔ)文件被格式化成多個(gè)存儲(chǔ)單元,每個(gè)存儲(chǔ)單元存儲(chǔ)一個(gè)任務(wù)信息,占用固定的空間;
所述任務(wù)信息索引文件記錄每個(gè)存儲(chǔ)單元的狀態(tài),組成一個(gè)循環(huán)鏈表按順序存儲(chǔ)。
3.根據(jù)權(quán)利要求1所述的基于內(nèi)存映射文件的跨進(jìn)程異步任務(wù)處理方法,其特征在于,所述步驟S1包括:鎖定任務(wù)存儲(chǔ)模塊中一個(gè)存儲(chǔ)組,查找存儲(chǔ)組的任務(wù)信息索引文件的循環(huán)鏈表,在待處理單元后面最近的空閑存儲(chǔ)單元進(jìn)行記錄,記錄后將當(dāng)前存儲(chǔ)單元設(shè)置為待處理。
4.根據(jù)權(quán)利要求1所述的基于內(nèi)存映射文件的跨進(jìn)程異步任務(wù)處理方法,其特征在于,所述步驟S2包括:針對(duì)任務(wù)存儲(chǔ)模塊中每一個(gè)存儲(chǔ)組創(chuàng)建一個(gè)線程,當(dāng)前線程負(fù)責(zé)順序讀取存儲(chǔ)組的任務(wù)信息索引文件的循環(huán)鏈表,查找最前面的狀態(tài)為待處理的任務(wù),任務(wù)處理線程池執(zhí)行最前面的狀態(tài)為待處理的任務(wù),在處理完成后將任務(wù)信息索引文件存儲(chǔ)單元狀態(tài)設(shè)置為空閑。
5.根據(jù)權(quán)利要求1所述的基于內(nèi)存映射文件的跨進(jìn)程異步任務(wù)處理方法,其特征還包括:異步任務(wù)信息記錄模塊和異步任務(wù)信息處理模塊在兩個(gè)進(jìn)程中,運(yùn)行在同一個(gè)服務(wù)器中,且均采用內(nèi)存映射文件技術(shù)將任務(wù)存儲(chǔ)模塊的存儲(chǔ)文件映射到內(nèi)存進(jìn)行讀寫,以便于提高性能及跨進(jìn)程數(shù)據(jù)數(shù)據(jù)同步。
6.一種基于內(nèi)存映射文件的跨進(jìn)程異步任務(wù)處理系統(tǒng),其特征在于,包括:
任務(wù)存儲(chǔ)模塊:主交易進(jìn)程調(diào)用異步任務(wù)信息記錄模塊將需要處理的異步任務(wù)寫入任務(wù)存儲(chǔ)模塊中;
異步任務(wù)信息處理模塊:異步任務(wù)信息處理模塊從任務(wù)存儲(chǔ)模塊中讀取待處理的異步任務(wù)進(jìn)行處理。
7.根據(jù)權(quán)利要求6所述的基于內(nèi)存映射文件的跨進(jìn)程異步任務(wù)處理系統(tǒng),其特征在于,所述任務(wù)存儲(chǔ)模塊包括:N個(gè)存儲(chǔ)組,每個(gè)存儲(chǔ)組包括任務(wù)信息存儲(chǔ)文件和任務(wù)信息索引文件;
所述任務(wù)信息存儲(chǔ)文件被格式化成多個(gè)存儲(chǔ)單元,每個(gè)存儲(chǔ)單元存儲(chǔ)一個(gè)任務(wù)信息,占用固定的空間;
所述任務(wù)信息索引文件記錄每個(gè)存儲(chǔ)單元的狀態(tài),組成一個(gè)循環(huán)鏈表按順序存儲(chǔ);
所述任務(wù)存儲(chǔ)模塊包括:鎖定任務(wù)存儲(chǔ)模塊中一個(gè)存儲(chǔ)組,查找存儲(chǔ)組的任務(wù)信息索引文件的循環(huán)鏈表,在待處理單元后面最近的空閑存儲(chǔ)單元進(jìn)行記錄,記錄后將當(dāng)前存儲(chǔ)單元設(shè)置為待處理。
8.根據(jù)權(quán)利要求6所述的基于內(nèi)存映射文件的跨進(jìn)程異步任務(wù)處理系統(tǒng),其特征在于,所述異步任務(wù)信息處理模塊包括:在異步任務(wù)處理進(jìn)程中,當(dāng)前異步任務(wù)處理進(jìn)程與主交易進(jìn)程運(yùn)行在同一個(gè)服務(wù)器中;
所述異步任務(wù)信息處理模塊包括:針對(duì)任務(wù)存儲(chǔ)模塊中每一個(gè)存儲(chǔ)組創(chuàng)建一個(gè)線程,當(dāng)前線程負(fù)責(zé)順序讀取存儲(chǔ)組的任務(wù)信息索引文件的循環(huán)鏈表,查找最前面的狀態(tài)為待處理的任務(wù),任務(wù)處理線程池執(zhí)行最前面的狀態(tài)為待處理的任務(wù),在處理完成后將任務(wù)存儲(chǔ)單元狀態(tài)設(shè)置為空閑。
9.根據(jù)權(quán)利要求6所述的基于內(nèi)存映射文件的跨進(jìn)程異步任務(wù)處理系統(tǒng),其特征在于,還包括:異步任務(wù)信息記錄模塊和異步任務(wù)信息處理模塊均采用內(nèi)存映射文件技術(shù)獎(jiǎng)任務(wù)存儲(chǔ)模塊的存儲(chǔ)文件映射到內(nèi)存進(jìn)行讀寫。
該專利技術(shù)資料僅供研究查看技術(shù)是否侵權(quán)等信息,商用須獲得專利權(quán)人授權(quán)。該專利全部權(quán)利屬于興業(yè)數(shù)字金融服務(wù)(上海)股份有限公司,未經(jīng)興業(yè)數(shù)字金融服務(wù)(上海)股份有限公司許可,擅自商用是侵權(quán)行為。如果您想購(gòu)買此專利、獲得商業(yè)授權(quán)和技術(shù)合作,請(qǐng)聯(lián)系【客服】
本文鏈接:http://www.szxzyx.cn/pat/books/202110321934.5/1.html,轉(zhuǎn)載請(qǐng)聲明來(lái)源鉆瓜專利網(wǎng)。





