[發(fā)明專利]一種基于無(wú)鎖緩沖區(qū)的數(shù)據(jù)采集方法

有效

• 申請(qǐng)?zhí)枺?/td>: 201510192246.8
• 申請(qǐng)日: 2015-04-21
• 公開(kāi)（公告）號(hào): CN104809027B
• 公開(kāi)（公告）日: 2018-03-16
• 發(fā)明（設(shè)計(jì)）人: 王友釗;黃靜
• 申請(qǐng)（專利權(quán)）人: 浙江大學(xué)
• 主分類號(hào): G06F9/52
• 分類號(hào): G06F9/52
• 代理公司: 杭州求是專利事務(wù)所有限公司33200
• 代理人: 邱啟旺

1.一種基于無(wú)鎖緩沖區(qū)的數(shù)據(jù)采集方法，其特征在于，包括以下步驟：

（1）建立生產(chǎn)者-消費(fèi)者數(shù)據(jù)采集模型；所述生產(chǎn)者-消費(fèi)者數(shù)據(jù)采集模型包括采集部分和處理部分，采集部分和處理部分并行進(jìn)行；

（2）建立數(shù)據(jù)生產(chǎn)者線程和測(cè)點(diǎn)數(shù)據(jù)消費(fèi)者線程；

（3）使用有序堆建立數(shù)據(jù)緩沖區(qū)，數(shù)據(jù)緩沖區(qū)中的數(shù)據(jù)按時(shí)間戳有序排放，數(shù)據(jù)緩沖區(qū)容量固定，數(shù)據(jù)節(jié)點(diǎn)在邏輯上是樹(shù)形結(jié)構(gòu)；

（4）數(shù)據(jù)生產(chǎn)者線程和測(cè)點(diǎn)數(shù)據(jù)消費(fèi)者線程對(duì)緩沖區(qū)進(jìn)行同步操作，操作完成后緩沖區(qū)恢復(fù)有序；

（5）使用CAS原子操作實(shí)現(xiàn)對(duì)緩沖區(qū)的無(wú)鎖增加、刪除和排序，實(shí)現(xiàn)線程同步操作，避免兩組工作線程阻塞。

2.根據(jù)權(quán)利要求1所述的一種基于無(wú)鎖緩沖區(qū)的數(shù)據(jù)采集方法，其特征在于，所述步驟（2）中，生產(chǎn)者和消費(fèi)者可能是單一線程也可能是一組工作線程，兩個(gè)線程單獨(dú)工作互不影響。

3.根據(jù)權(quán)利要求1所述的一種基于無(wú)鎖緩沖區(qū)的數(shù)據(jù)采集方法，其特征在于，所述步驟（4）具體為：生產(chǎn)者采集數(shù)據(jù)存入數(shù)據(jù)緩沖區(qū)，若緩沖區(qū)不滿，將生產(chǎn)者采集的數(shù)據(jù)直接放入緩沖區(qū)的末尾，并且對(duì)緩沖區(qū)中的數(shù)據(jù)按時(shí)間戳自動(dòng)排序；若緩沖區(qū)滿，生產(chǎn)者采集的數(shù)據(jù)與緩沖區(qū)中時(shí)間戳最舊的數(shù)據(jù)交換后按時(shí)間戳自動(dòng)排序；消費(fèi)者從數(shù)據(jù)緩沖區(qū)取數(shù)據(jù)，若緩沖區(qū)不空，將緩沖區(qū)中時(shí)間戳最新的數(shù)據(jù)取出，并且對(duì)緩沖區(qū)中剩余數(shù)據(jù)按時(shí)間戳自動(dòng)排序；若緩沖區(qū)空，則等待生產(chǎn)者采集的數(shù)據(jù)。