1. 程式人生 > >Linux C 實現生產者消費者問題

Linux C 實現生產者消費者問題

分享一下我老師大神的人工智慧教程!零基礎,通俗易懂!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;}

           

給我老師的人工智慧教程打call!http://blog.csdn.net/jiangjunshow

這裡寫圖片描述