引 言

在對實時采集更新的數據進行處理時，往往會遇到數據更新速度與數據處理的速度不匹配的問題。這種情況下，會出現數據丟失而導致數據處理結果不準確，甚至會帶來不可預測的后果，因此需要一種機制來協調數據更新與數據處理，從而保證數據的完整性和處理結果的準確性。作為一個多任務、多用戶操作系統，Linux 支持多個進程在系統中并發運行，由于進程本身的動態特性，用來描述實時數據處理非常合適，因此，解決好Linux進程間的同步與通信問題就能解決實時數據處理的問題。

在Linux環境下，進程通常存在運行（running）、阻塞（blocked）、就緒（ready）、終止（terminated）四種狀態。當多個進程并發執行時，往往會出現進程間的競態。我們希望進程能協調彼此間的行為，使得一個進程只有在其他的進程執行到一個特定的點時才會執行一個動作，即控制同步；同時，當并發進程訪問共享數據時不應當出現競爭條件。這一點通過在訪問共享數據時執行互斥來確保，即數據訪問同步。

實現同步的基本技術是阻塞一個進程，直到一個特定條件滿足為止；實現數據訪問同步是通過阻塞一個進程直到另外的進程完成訪問共享數據。

1 有限長度緩沖區的生產者一消費者問題模型

當僅存在單個生產者和消費者時，生產進程和消費進程所對應的是同樣的數據結構，它們共享同一個數據空間。生產進程和消費進程如何進行相互協調，使得消費進程每次使用的數據都是生產進程新生產寫人的，又使生產進程新寫入的數據不會覆蓋還未被消費進程讀出使用的數據，是該問題模型實現的關鍵問題。

在生產者一消費者問題模型中，生產者進程不斷生產產品并把它們放入緩沖區，消費者進程不斷從緩沖區中取走產品進行消費。當緩沖區中產品已經放滿時，表示生產速度高于消費速度，出現了供過于求，此時生產者必須等待產品被消費；當緩沖區為空時，表示消費速度高于生產速度，出現了供不應求，此時消費者進程必須等待產品的生產。生產和消費的進程必須達到同步運行，才能實現供需平衡。

處理讀寫同步的兩種常見的策略被稱為“強讀者同步（strong reader synchronization）”和“強寫者同步（strongwriter synchronization）”。在強讀者同步中，總是給讀者以優先權，只要寫者當前沒有進行寫操作，讀者就可以獲得訪問權；在強寫者同步中，寫者總是獲得優先權，只要強讀者當前沒有進行讀操作，寫者就可以獲得訪問權。而生產者消費者同步與單純的讀寫同步又有不同，消費者可以通過訪問資源對資源進行刪除或銷毀。

一個有限長度緩沖區的生產者消費者問題模型，是由若干生產者和消費者進程以及一個有限的緩沖池構成的。每個緩沖區能夠存儲一個信息記錄，一個生產者一次生產一個信息記錄。產生一個記錄之后，等待單獨進入一個空的緩沖區后將記錄寫入緩沖區。一個消費者進程一次消費一個信息記錄。當它需要消費時，它等待單獨進入一個滿的緩沖區后將記錄讀出。

通過上面的描述可以得出，解決生產者一消費者問題模型的方案需要滿足以下幾個條件：

◇生產者不應覆蓋一個滿的緩沖區；

◇消費者不應使用一個空的緩沖區；

◇生產者和消費者應按互斥方式訪問數據緩沖區；

◇數據必須按照先進先出（FIFO）方式；

◇不能出現忙等待。

必須避免數據寫進程不斷、反復地檢查緩沖區直到找到一個空緩沖區為止，而讀進程也必須避免不斷檢查直到找到一個滿緩沖區為止。這相當于系統內部產生忙等待，是在僅使用臨界段（CS）算法實現進程同步時難以避免的問題。

針對問題模型解決方案的限制條件，采用信號量方式解決實時更新數據處理的進程同步問題，即上述的生產者一消費者問題模型。

信號量是一個非負值的共享整數值，只能用于初始化和不可分操作。不可分操作是指在對一個數據D進行操作時不能與任何其他對D的操作重疊的操作。定義操作P 和V為不可分操作。P和V的不可分性意味著這些操作不能并發執行，避免了對信號量的競爭條件。定義P和V的操作語義為：

由上述定義的語義看，對一個信號量S的操作，P和V為改變S的值，或者掛起或喚醒一個對S進行P操作的進程。被掛起的進程為阻塞狀態，因而避免了忙等待問題。一個二進制的信號量只取0和1，用來實現互斥。

在P和V操作中，對進程的阻塞和喚醒需要操作系統的進程管理組件的參與，因此信號量會被操作系統實現而不是應用程序實現。

生產者一消費者問題模型描述：

2 結構設計

對于有限緩沖區的生產者消費者問題模型的執行包括以下部件：共享數據一緩沖區組、操作一緩沖區的訪問、進程一生產者消費者。

在生產者一消費者同步中，由生產者創建資源，與單純的讀程序不同，消費者可以通過訪問資源，將資源刪除或銷毀。由于生產者進程和消費者進程共享一個緩沖區，因此在插入和刪除條目時必須同步。實現中必須避免表l所列的同步異常問題。

生產者一消費者問題的傳統的信號量解決方案使用了2個信號量，分別用來表示緩沖區中的條目數和空閑槽的數目。當進程需要特定類型的資源時，它可以通過函數調用對相應的信號量進行減量操作；同樣，當進程釋放資源時，它可以通過函數調用來對相應的信號量進行增量操作。由于信號量永遠不會降到零以下，所以進程不能使用不存在的資源。因此，始終將計數信號量初始化為開始時可用的資源數。

定義循環隊列緩沖區存放待處理數據，控制臺數據處理進程從該循環隊列緩沖區中消費數據，并將該數據存儲位標記為“廢棄”。數據采集寫進程僅能將數據存放于標記為“廢棄”的循環隊列緩沖區中，如圖1所示。

在沒有多個生產者或消費者的情況下，如果仔細實現，循環緩沖區就不需要鎖。生產者是唯一允許修改寫入索引以及該索引指向的數組位置的進程。只要寫入者在更新寫入索引之前將新的值保存到緩沖區，則讀取者將始終看到一致的數據結構；同時，讀取者是唯一可以訪問讀取索引以及該索引指向位置的數據的進程。只要確保兩個指針不要互相重疊，生產者和消費者可以在無竟態的情況下訪問該緩沖區，如圖2所示。

對于只有單個生產者和消費者，通過使用修正的使用信號量方式的生產者一消費者問題模型解決方案來實現。

以上用信號量方式解決了優先緩沖區問題，信號量“empty”和“full”的值分別指示空和滿的緩沖區的數量，如圖3所示。緩沖區指針i和j用來確保緩沖區按先進先出的順序提供并使用。只要系統中存在一些滿的和空的緩沖區，數據更新進程和數據處理進程就能無競態并發執行。筆者在華恒ARM嵌入式平臺 HHARM2410-R5上按照上述方案成功實現了用例測試。

3 討論

以上的結構設計，將生產者與消費者分別簡化為一個。當存在多個生產者和消費者的情況時，可以上述修正的解決方案為基礎，設計多個計數器來統計并行讀者（reader）、并行寫者（writer）、讀者或待讀者（pre_reader）、寫者或待寫者（pre_writer）的數量。計數器的值在進程中的相應位置進行增減。讀者和寫者在被允許閱讀和寫入之前必須被阻塞，這可以通過P操作來完成。當讀者或寫者在進程被阻塞時控制開始閱讀或書寫的條件并未滿足。這些條件隨著任意一個計數器值的變化而改變，所以，進程在完成閱讀或書寫后必須執行相應的V操作。

在實行多讀、多寫進程同步解決方案時，必須要避免不同計數器的競爭條件，因而必須在臨界段（CS）中執行對允許讀或寫操作條件的檢查。