淺談生產(chǎn)者消費者模型(Linux系統(tǒng)下的兩種實現(xiàn)方法)
生產(chǎn)者消費者問題是同步問題中的一種常見情況，借用一下維基百科的話
生產(chǎn)者消費者問題（英語：Producer-consumer problem），也稱有限緩沖問題（英語：Bounded-buffer problem），是一個多線程同步問題的經(jīng)典案例。該問題描述了兩個共享固定大小緩沖區(qū)的線程——即所謂的“生產(chǎn)者”和“消費者”——在實際運行時會發(fā)生的問題。生產(chǎn)者的主要作用是生成一定量的數(shù)據(jù)放到緩沖區(qū)中，然后重復此過程。與此同時，消費者也在緩沖區(qū)消耗這些數(shù)據(jù)。該問題的關鍵就是要保證生產(chǎn)者不會在緩沖區(qū)滿時加入數(shù)據(jù)，消費者也不會在緩沖區(qū)中空時消耗數(shù)據(jù)。
第一種實現(xiàn)信號量配合互斥鎖實現(xiàn)，這種方法很清晰簡單
信號量：
信號量的特性如下：信號量是一個非負整數(shù)（車位數(shù)），所有通過它的線程/進程（車輛）都會將該整數(shù)減一（通過它當然是為了使用資源），當該整數(shù)值為零時，所有試圖通過它的線程都將處于等待狀態(tài)。在信號量上我們定義兩種操作： Wait（等待） 和 Release（釋放）。當一個線程調(diào)用Wait操作時，它要么得到資源然后將信號量減一，要么一直等下去（指放入阻塞隊列），直到信號量大于等于一時。Release（釋放）實際上是在信號量上執(zhí)行加操作，對應于車輛離開停車場，該操作之所以叫做“釋放”是因為釋放了由信號量守護的資源。
wait, release在Linux下
int sem_wait(sem_t * sem);
int sem_post(sem_t * sem);
設定兩個信號量，empty用來表示空槽的個數(shù)，full用來表示占有的個數(shù)
生產(chǎn)者在向任務隊列里放資源時，調(diào)用sem_wait(&full)來檢查隊列是否已滿，如果滿的話，就阻塞，直到有消費者從里面取資源再蘇醒，如果不滿，就放資源，并通知消費者來取。
消費者在從任務隊列里取資源時，調(diào)用sem_wait(&empty)來檢查隊列是否為空，如果空的話，就阻塞，直到有生產(chǎn)者向里面放資源再蘇醒，如果不空，就取資源，并通知生產(chǎn)者來放。
而互斥鎖僅僅是為了防止多個線程同時對隊列進行操作，造成未知的結(jié)果。
#include <stdio.h>
#include <pthread.h>
#include <semaphore.h>
#define MAX 5 //隊列長度
pthread_mutex_t mutex = PTHREAD_MUTEX_INITIALIZER;
sem_t full; //填充的個數(shù)
sem_t empty; //空槽的個數(shù)
int top = 0; //隊尾
int bottom = 0; //隊頭
void* produce(void* arg)
{
int i;
for ( i = 0; i < MAX*2; i++)
{
printf("producer is preparing data\n");
sem_wait(&empty);//若空槽個數(shù)低于0阻塞
pthread_mutex_lock(&mutex);
top = (top+1) % MAX;
printf("now top is %d\n", top);
pthread_mutex_unlock(&mutex);
sem_post(&full);
}
return (void*)1;
}
void* consume(void* arg)
{
int i;
for ( i = 0; i < MAX*2; i++)
{
printf("consumer is preparing data\n");
sem_wait(&full);//若填充個數(shù)低于0阻塞
pthread_mutex_lock(&mutex);
bottom = (bottom+1) % MAX;
printf("now bottom is %d\n", bottom);
pthread_mutex_unlock(&mutex);
sem_post(&empty);
}
return (void*)2;
}
int main(int argc, char *argv[])
{
pthread_t thid1;
pthread_t thid2;
pthread_t thid3;
pthread_t thid4;
int ret1;
int ret2;
int ret3;
int ret4;
sem_init(&full, 0, 0);
sem_init(&empty, 0, MAX);
pthread_create(&thid1, NULL, produce, NULL);
pthread_create(&thid2, NULL, consume, NULL);
pthread_create(&thid3, NULL, produce, NULL);
pthread_create(&thid4, NULL, consume, NULL);
pthread_join(thid1, (void**)&ret1);
pthread_join(thid2, (void**)&ret2);
pthread_join(thid3, (void**)&ret3);
pthread_join(thid4, (void**)&ret4);
return 0;
}
注：如果把sem_wait()和sem_post()放到pthread_mutex_lock()與pthread_mutex_unlock()之間會如何呢？
答案是：死鎖，因為我們不能預知線程進入共享區(qū)順序，如果消費者線程先對mutex加鎖，并進入，sem_wait()發(fā)現(xiàn)隊列為空，阻塞，而生產(chǎn)者在對mutex加鎖時，發(fā)現(xiàn)已上鎖也阻塞，雙方永遠無法喚醒對方。
第二種是條件變量配合互斥鎖實現(xiàn)
條件變量的常見用法是在不滿足某些條件時，阻塞自己，直到有線程通知自己醒來。
而互斥量在這里的作用依然還是防止多線程對共享資源同時操作，造成未知結(jié)果。
生產(chǎn)者消費者的行為與之前相同，只不過原來只調(diào)用sem_wait()可以完成兩步，1是檢查條件，2是阻塞，現(xiàn)在條件變量需要我們自己來設定條件(所以說條件變量配合互斥鎖比信號量的功能更強大，因為它可以自定義休眠條件，但是這對使用者的要求也提高了，必須理清邏輯關系避免死鎖)
#include <stdio.h>
#include <pthread.h>
#define MAX 5
pthread_mutex_t mutex = PTHREAD_MUTEX_INITIALIZER;
pthread_cond_t notfull = PTHREAD_COND_INITIALIZER; //是否隊滿
pthread_cond_t notempty = PTHREAD_COND_INITIALIZER; //是否隊空
int top = 0;
int bottom = 0;
void* produce(void* arg)
{
int i;
for ( i = 0; i < MAX*2; i++)
{
pthread_mutex_lock(&mutex);
while ((top+1)%MAX == bottom)
{
printf("full! producer is waiting\n");
pthread_cond_wait(¬full, &mutex);//等待隊不滿
}
top = (top+1) % MAX;
printf("now top is %d\n", top);
pthread_cond_signal(¬empty);//發(fā)出隊非空的消息
pthread_mutex_unlock(&mutex);
}
return (void*)1;
}
void* consume(void* arg)
{
int i;
for ( i = 0; i < MAX*2; i++)
{
pthread_mutex_lock(&mutex);
while ( top%MAX == bottom)
{
printf("empty! consumer is waiting\n");
pthread_cond_wait(¬empty, &mutex);//等待隊不空
}
bottom = (bottom+1) % MAX;
printf("now bottom is %d\n", bottom);
pthread_cond_signal(¬full);//發(fā)出隊不滿的消息
pthread_mutex_unlock(&mutex);
}
return (void*)2;
}
int main(int argc, char *argv[])
{
pthread_t thid1;
pthread_t thid2;
pthread_t thid3;
pthread_t thid4;
int ret1;
int ret2;
int ret3;
int ret4;
pthread_create(&thid1, NULL, produce, NULL);
pthread_create(&thid2, NULL, consume, NULL);
pthread_create(&thid3, NULL, produce, NULL);
pthread_create(&thid4, NULL, consume, NULL);
pthread_join(thid1, (void**)&ret1);
pthread_join(thid2, (void**)&ret2);
pthread_join(thid3, (void**)&ret3);
pthread_join(thid4, (void**)&ret4);
return 0;
}
注：
為什么信號量在互斥區(qū)外，而條件變量在互斥區(qū)內(nèi)呢？
因為互斥鎖本質(zhì)上是二元信號量，和信號量互斥的原理相同，而且放在互斥區(qū)會死鎖，而條件變量是和互斥鎖協(xié)同配合的，
我們從pthread_cond_wait()和pthread_cond_signal()的內(nèi)部實現(xiàn)就可以看出
pthread_cond_wait()是先將互斥鎖解開，并陷入阻塞，直到pthread_signal()發(fā)出信號后pthread_cond_wait()再加上鎖，然后退出，可以看到它們在設計時就是為了協(xié)同配合，而互斥鎖和信號量都是由Linux下的futex機制實現(xiàn)的，這里就不展開說了
這里貼出了pthread_wait()源碼圖
以上就是小編為大家?guī)淼臏\談生產(chǎn)者消費者模型(Linux系統(tǒng)下的兩種實現(xiàn)方法)全部內(nèi)容了，希望大家多多支持腳本之家~
相關文章
這篇文章主要介紹了Linux磁盤管理之LVM，文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧2020-01-01
centos最小化安裝系統(tǒng)后的基本調(diào)優(yōu)及安全設置
這篇文章主要介紹了centos最小化安裝系統(tǒng)后的一些基本調(diào)優(yōu)及安全設置，需要的朋友可以參考下2013-04-04
這篇文章主要介紹了Linux系統(tǒng)網(wǎng)卡的設置教程，具有一定的參考價值，感興趣的小伙伴們可以參考一下2017-06-06
JVM上高性能數(shù)據(jù)格式庫包Apache Arrow入門和架構詳解(Gkatziouras)
Apache Arrow是是各種大數(shù)據(jù)工具（包括BigQuery）使用的一種流行格式，它是平面和分層數(shù)據(jù)的存儲格式，今天給大家介紹JVM上高性能數(shù)據(jù)格式庫包Apache Arrow入門和架構介紹，感興趣的朋友一起看看吧2021-05-05
Ubuntu系統(tǒng)下安裝ImageMagick出錯的解決過程
由于項目需要, 所以要在Ubuntu下面安裝ImageMagick，但在安裝過程中遇到了些問題，通過查找相關的資料最終得以解決了，所以下面這篇文章主要給大家介紹了關于Ubuntu系統(tǒng)下安裝ImageMagick出錯的解決過程，需要的朋友可以參考借鑒，下面來一起看看吧。2017-07-07
火山互聯(lián)推出的免費VPS...拿來學習下還是不錯的.申請過幾次Liunx系統(tǒng)的.由于不是很熟悉.幾次都沒能配置好.下面介紹一下.前幾天又申請了一個.2009-12-12
下面小編就為大家分享一篇ubuntu14.04安裝opencv3.0.0的操作方法，具有很好的參考價值，希望對大家有所幫助。一起跟隨小編過來看看吧2017-12-12
本篇文章主要介紹了Ubuntu 下安裝和配置 FTP服務，小編覺得挺不錯的，現(xiàn)在分享給大家，也給大家做個參考。一起跟隨小編過來看看吧2017-04-04
這篇文章主要介紹了Linux在應用層讀寫寄存器的方法及實現(xiàn)實例的相關資料,需要的朋友可以參考下2017-02-02
這篇文章主要介紹了Linux網(wǎng)絡代理服務器的搭建及使用方式，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2023-06-06