Linux C 實現生產者消費者問題
阿新 • • 發佈:2018-11-16
分享一下我老師大神的人工智慧教程!零基礎,通俗易懂!http://blog.csdn.net/jiangjunshow
也歡迎大家轉載本篇文章。分享知識,造福人民,實現我們中華民族偉大復興!
//訊號量---執行緒間通訊//“生產者消費者” 問題#include<stdio.h>#include<stdlib.h>#include<unistd.h>#include <semaphore.h>#include<pthread.h>#define msleep(x) usleep(x*1000)#define PRODUCT_SPEED 3 //生產速度#define CONSUM_SPEED 1 //消費速度 #define INIT_NUM 3 //倉庫原有產品數#define TOTAL_NUM 10 //倉庫容量 sem_t p_sem, c_sem, sh_sem;int num=INIT_NUM; void product(void) //生產產品{ sleep(PRODUCT_SPEED);} int add_to_lib() //新增產品到倉庫{ num++;//倉庫中的產品增加一個 msleep(500); return num;} void consum() //消費{ sleep(CONSUM_SPEED);} int sub_from_lib() //從倉庫中取出產品{ num--; //倉庫中的產品數量減一 msleep(500); return num;} void *productor(void *arg) //生產者執行緒{ while(1) { sem_wait(&p_sem);//生產訊號量減一 product();// 生產延時 sem_wait(&sh_sem);//這個訊號量是用來互斥的 printf("push into! tatol_num=%d\n",add_to_lib()); sem_post(&sh_sem); sem_post(&c_sem); //消費訊號量加一 }} void *consumer(void *arg) //消費者執行緒{ while(1) { sem_wait(&c_sem); //消費者訊號量減一 sem_wait(&sh_sem); printf("pop out! tatol_num=%d\n",sub_from_lib()); sem_post(&sh_sem); sem_post(&p_sem);//生產者訊號量加一 consum();//消費延時 }} int main(){ pthread_t tid1,tid2; sem_init(&p_sem,0,TOTAL_NUM-INIT_NUM); sem_init(&c_sem,0,INIT_NUM); sem_init(&sh_sem,0,1); pthread_create(&tid1,NULL,productor,NULL); pthread_create(&tid2,NULL,consumer,NULL); pthread_join(tid1,NULL); pthread_join(tid2,NULL); return 0;}