代碼實(shí)現(xiàn)

如題，使用semaphore信號量和mutex互斥量實(shí)現(xiàn)多個(gè)生產(chǎn)者和消費(fèi)者模型。本來是想只用信號量實(shí)現(xiàn)生產(chǎn)者消費(fèi)者模型的，但是發(fā)現(xiàn) 只能在一個(gè)生產(chǎn)者和一個(gè)消費(fèi)者之間，要在多個(gè)生產(chǎn)者和消費(fèi)者模型必須和mutex互斥鎖搭配使用才行，sem信號量只是控制并發(fā)數(shù)的。采用數(shù)組模擬產(chǎn)品區(qū)，代碼中有一定的注釋。需要Linux下線程相關(guān)知識進(jìn)行支撐，這里不細(xì)說，直接看實(shí)現(xiàn)代碼。

#include <stdio.h> #include <stdlib.h> #include <string.h> #include <unistd.h> #include <fcntl.h> #include <error.h> #include <sys/errno.h> #include <pthread.h> #include <semaphore.h> #define NUM 10 //產(chǎn)品區(qū)容量 int queue[NUM] = {0};//數(shù)組模擬產(chǎn)品區(qū),生產(chǎn)者消費(fèi)者運(yùn)行模擬環(huán)形隊(duì)列進(jìn)行生產(chǎn)和消費(fèi) sem_t producer,customer;//信號量 int pro_i = 0;//生產(chǎn)者線程 訪問下標(biāo) int cus_i = 0;//消費(fèi)者線程 訪問下標(biāo) pthread_mutex_t pro_lock = PTHREAD_MUTEX_INITIALIZER; pthread_mutex_t cus_lock = PTHREAD_MUTEX_INITIALIZER;//生產(chǎn)者 void* produce(void* arg) {int tmp;//生產(chǎn)從下標(biāo) 0 -> Nwhile(1){sem_wait(&producer); //producer-- ,直到為0 產(chǎn)品區(qū)被填滿 進(jìn)行阻塞//并行的生產(chǎn)者線程生成產(chǎn)品pthread_mutex_lock(&pro_lock); tmp = queue[pro_i] = rand()%1000 ;pro_i = (pro_i+1)%NUM;pthread_mutex_unlock(&pro_lock);printf("%dth ###producer###:%d\n",(int)arg,tmp);sem_post(&customer);//customer++sleep(rand()%2);}return NULL; } //消費(fèi)者 void* custome(void* arg) {int tmp;//消費(fèi)從下標(biāo)0 -> N while(1){sem_wait(&customer); // customer-- ,直到為0 產(chǎn)品區(qū)為空 進(jìn)行阻塞//并行的消費(fèi)者線程訪問消費(fèi)產(chǎn)品pthread_mutex_lock(&cus_lock);tmp = queue[cus_i];queue[cus_i] = 0 ;cus_i = (cus_i+1)%NUM;pthread_mutex_unlock(&cus_lock);printf("%dth ***customer***:%d\n",(int)arg,tmp);sem_post(&producer);//producer++ sleep(rand()%2);}return NULL; } //使用信號量 實(shí)現(xiàn)生產(chǎn)者消費(fèi)者模型 int main(int argc,char* argv[]) {srand((unsigned int)time(NULL));//設(shè)置線程分離pthread_attr_t attr;pthread_attr_init(&attr);pthread_attr_setdetachstate(&attr,PTHREAD_CREATE_DETACHED);pthread_t pro[3],cus[5]; int i;//初始化信號量 起初產(chǎn)品區(qū)為空sem_init(&producer,0,NUM);//生產(chǎn)者 起初信號量為 NUM 產(chǎn)品區(qū)為空生產(chǎn)產(chǎn)品，當(dāng)信號量為0 也就是產(chǎn)品滿 阻塞等待消費(fèi)者消費(fèi)產(chǎn)品sem_init(&customer,0,0); //消費(fèi)者 起初信號量為 0 阻塞等待生產(chǎn)者生產(chǎn)產(chǎn)品for( i= 0; i< 3;i++ ){pthread_create(&pro[i],&attr,produce,(void*)i);}for( i= 0; i< 5;i++ ){pthread_create(&cus[i],&attr,custome,(void*)i);}//銷毀 信號量sem_destroy(&producer);sem_destroy(&customer);//銷毀 鎖pthread_mutex_destroy(&pro_lock);pthread_mutex_destroy(&cus_lock);//主線程退出pthread_exit(NULL);return 0; }

實(shí)現(xiàn)效果

總結(jié)

以上是生活随笔為你收集整理的Linux系统编程：使用semaphore信号量和mutex互斥量实现多个生产者和消费者模型的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。