[發(fā)明專利]高并發(fā)數(shù)據(jù)存儲(chǔ)方法及計(jì)算機(jī)可讀存儲(chǔ)介質(zhì)

在審

• 申請(qǐng)?zhí)枺?/td>: 201711406104.2
• 申請(qǐng)日: 2017-12-22
• 公開(kāi)（公告）號(hào): CN108170758A
• 公開(kāi)（公告）日: 2018-06-15
• 發(fā)明（設(shè)計(jì)）人: 劉德建;陳來(lái)件;歐寧;李永均;郭玉湖
• 申請(qǐng)（專利權(quán)）人: 福建天泉教育科技有限公司
• 主分類號(hào): G06F17/30
• 分類號(hào): G06F17/30
• 代理公司: 福州市博深專利事務(wù)所(普通合伙) 35214
• 代理人: 林志崢

1.一種高并發(fā)數(shù)據(jù)存儲(chǔ)方法，其特征在于，包括：

創(chuàng)建多個(gè)無(wú)鎖并發(fā)隊(duì)列緩沖區(qū)；

創(chuàng)建空閑緩沖區(qū)隊(duì)列和待消費(fèi)緩沖區(qū)隊(duì)列，所述空閑緩沖區(qū)隊(duì)列用于存儲(chǔ)空閑的緩沖區(qū)，所述待消費(fèi)緩沖區(qū)隊(duì)列用于存儲(chǔ)待消費(fèi)的緩沖區(qū)；

從所述空閑緩沖區(qū)隊(duì)列中選取一緩沖區(qū)作為寫入緩沖區(qū)；

根據(jù)預(yù)設(shè)的周期時(shí)間查看所述寫入緩沖區(qū)，若有數(shù)據(jù)寫入，則將所述寫入緩沖區(qū)加入至待消費(fèi)緩沖區(qū)隊(duì)列；

繼續(xù)執(zhí)行所述從所述空閑緩沖區(qū)隊(duì)列中選取一緩沖區(qū)作為寫入緩沖區(qū)的步驟；

將待消費(fèi)緩沖區(qū)隊(duì)列中的緩沖區(qū)加入至線程池隊(duì)列；

線程池中的線程依次從所述線程池隊(duì)列中取出一緩沖區(qū)進(jìn)行消費(fèi)。

2.根據(jù)權(quán)利要求1所述的高并發(fā)數(shù)據(jù)存儲(chǔ)方法，其特征在于，所述“將待消費(fèi)緩沖區(qū)隊(duì)列中的緩沖區(qū)加入至線程池隊(duì)列”具體為：

監(jiān)聽(tīng)待消費(fèi)緩沖區(qū)隊(duì)列；

若待消費(fèi)緩沖區(qū)隊(duì)列不為空，則將待消費(fèi)緩沖區(qū)隊(duì)列中的緩沖區(qū)加入至線程池隊(duì)列。

3.根據(jù)權(quán)利要求1所述的高并發(fā)數(shù)據(jù)存儲(chǔ)方法，其特征在于，所述“線程池中的線程依次從所述線程池隊(duì)列中取出一緩沖區(qū)進(jìn)行消費(fèi)”具體為：

線程池中的一線程從所述線程池隊(duì)列中取出一緩沖區(qū)，并將所述一緩沖區(qū)中的數(shù)據(jù)批量更新到數(shù)據(jù)庫(kù)中或批量進(jìn)行傳輸。

4.根據(jù)權(quán)利要求1所述的高并發(fā)數(shù)據(jù)存儲(chǔ)方法，其特征在于，所述“線程池中的線程依次從所述線程池隊(duì)列中取出一緩沖區(qū)進(jìn)行消費(fèi)”之后，進(jìn)一步包括：

將消費(fèi)完后的緩沖區(qū)加入至空閑緩沖區(qū)隊(duì)列。

5.一種計(jì)算機(jī)可讀存儲(chǔ)介質(zhì)，其上存儲(chǔ)有計(jì)算機(jī)程序，其特征在于，所述程序被處理器執(zhí)行時(shí)實(shí)現(xiàn)以下步驟：

創(chuàng)建多個(gè)無(wú)鎖并發(fā)隊(duì)列緩沖區(qū)；

創(chuàng)建空閑緩沖區(qū)隊(duì)列和待消費(fèi)緩沖區(qū)隊(duì)列，所述空閑緩沖區(qū)隊(duì)列用于存儲(chǔ)空閑的緩沖區(qū)，所述待消費(fèi)緩沖區(qū)隊(duì)列用于存儲(chǔ)待消費(fèi)的緩沖區(qū)；

從所述空閑緩沖區(qū)隊(duì)列中選取一緩沖區(qū)作為寫入緩沖區(qū)；

根據(jù)預(yù)設(shè)的周期時(shí)間查看所述寫入緩沖區(qū)，若有數(shù)據(jù)寫入，則將所述寫入緩沖區(qū)加入至待消費(fèi)緩沖區(qū)隊(duì)列；

繼續(xù)執(zhí)行所述從所述空閑緩沖區(qū)隊(duì)列中選取一緩沖區(qū)作為寫入緩沖區(qū)的步驟；

將待消費(fèi)緩沖區(qū)隊(duì)列中的緩沖區(qū)加入至線程池隊(duì)列；

線程池中的線程依次從所述線程池隊(duì)列中取出一緩沖區(qū)進(jìn)行消費(fèi)。

6.根據(jù)權(quán)利要求5所述的計(jì)算機(jī)可讀存儲(chǔ)介質(zhì)，其特征在于，所述“將待消費(fèi)緩沖區(qū)隊(duì)列中的緩沖區(qū)加入至線程池隊(duì)列”具體為：

監(jiān)聽(tīng)待消費(fèi)緩沖區(qū)隊(duì)列；

若待消費(fèi)緩沖區(qū)隊(duì)列不為空，則將待消費(fèi)緩沖區(qū)隊(duì)列中的緩沖區(qū)加入至線程池隊(duì)列。

7.根據(jù)權(quán)利要求5所述的計(jì)算機(jī)可讀存儲(chǔ)介質(zhì)，其特征在于，所述“線程池中的線程依次從所述線程池隊(duì)列中取出一緩沖區(qū)進(jìn)行消費(fèi)”具體為：

線程池中的一線程從所述線程池隊(duì)列中取出一緩沖區(qū)，并將所述一緩沖區(qū)中的數(shù)據(jù)批量更新到數(shù)據(jù)庫(kù)中或批量進(jìn)行傳輸。

8.根據(jù)權(quán)利要求5所述的計(jì)算機(jī)可讀存儲(chǔ)介質(zhì)，其特征在于，所述“線程池中的線程依次從所述線程池隊(duì)列中取出一緩沖區(qū)進(jìn)行消費(fèi)”之后，進(jìn)一步包括：

將消費(fèi)完后的緩沖區(qū)加入至空閑緩沖區(qū)隊(duì)列。