生产者、消费者问题（C语言、POSIX）

利用C语言编写，使用POSIX线程，利用条件变量和互斥锁来完成资源调用和实现线程同步。代码如下：

//生产者和消费者问题
#include<stdio.h>
#include<stdlib.h>
#include<unistd.h>
#include<pthread.h>
char g_storage[10];//仓库
int g_stock = 0;//库存量
pthread_mutex_t mutex = PTHREAD_MUTEX_INITIALIZER;//互斥锁
pthread_cond_t pcond = PTHREAD_COND_INITIALIZER;//全局条件变量并初始化（生产者卧室） 
pthread_cond_t ccond = PTHREAD_COND_INITIALIZER;//全局条件变量并初始化（消费者卧室） 
//显示生产消费过程 生产者:ABC<--X   消费者:ABC-->X
void show(char* who,char* op,char prod){printf("%s:",who);for(int i = 0;i < g_stock;i++){printf("%c",g_storage[i]);}printf("%s%c\n",op,prod);
}
//生产者线程
void* producer(void* arg){char* who = (char*)arg;//生产者for(;;){//加锁pthread_mutex_lock(&mutex);//判满if(g_stock == 10){printf("%s:已满仓\n",who);pthread_cond_wait(&pcond,&mutex);}//生产char prod = 'A' + rand() % 26;show(who,"<--",prod);g_storage[g_stock] = prod;g_stock++;//唤醒pthread_cond_signal(&ccond);//解锁pthread_mutex_unlock(&mutex);usleep((rand() % 100) * 1000);}return NULL;
}
//消费者线程
void* consumer(void* arg){char* who = (char*)arg;//消费者for(;;){//加锁pthread_mutex_lock(&mutex);//判空if(g_stock == 0){printf("%s:空仓\n",who);pthread_cond_wait(&ccond,&mutex);}//消费char prod = g_storage[--g_stock];show(who,"-->",prod);//唤醒pthread_cond_signal(&pcond);//解锁pthread_mutex_unlock(&mutex);usleep((rand() % 100) * 1000);}return NULL;
}
int main(void){srand(getpid());pthread_t t1,t2;pthread_create(&t1,NULL,producer,"生产者");pthread_create(&t2,NULL,consumer,"消费者");getchar();//不按回车键就不结束 return 0;
}