利用信号量与互斥搭建出---生产者与消费者模型

 

/* ************************************************************************
 * Filename: proj.c
 * Description:
 * Version: 1.0
 * Created: 2012年06月21日 17时17分24秒
 * Revision: none
 * Compiler: gcc
 * Author: YOUR NAME (),
 * Company:
 * ************************************************************************/
#include <stdlib.h>
#include <semaphore.h>
#include <pthread.h>
#include <unistd.h>
#include <stdio.h>
#define P_TIME 1
#define C_TIME 3
pthread_mutex_t mutex;
sem_t sem_p,sem_c;
pthread_t tid_p,tid_r;
int count=4;
int make(void)
{
 pthread_mutex_lock(&mutex);
 if(pthread_self() == tid_p)
 {
  count++;
  printf("pop in!,the store=%d\n",count);
  //sleep(10);
 }
 else if(pthread_self() == tid_r)
 {
  count--;
  printf("pop out!,the store=%d\n",count);
  //sleep(R_TIME);
 }
 pthread_mutex_unlock(&mutex);
 return 0;
}
void * handler_p(void *a)
{
 while(1)
 {
 sem_wait(&sem_p);
 sleep(P_TIME);
 make();
 //sleep(P_TIME);
 sem_post(&sem_c);
 //sleep(P_TIME);
 }
}
void * handler_c(void *a)
{
 while(1)
 {
 sem_wait(&sem_c);
 make();
 //sleep(C_TIME);
 sem_post(&sem_p);
 sleep(C_TIME);
 }
}
int main(int argc, char *argv[])
{
 //pthread_t tid_p,tid_r;
 sem_init(&sem_p,0,6);
 sem_init(&sem_c,0,4);
 pthread_create(&tid_p,NULL,handler_p,NULL);
 pthread_create(&tid_r,NULL,handler_c,NULL);
 pthread_join(tid_p,NULL);
 pthread_join(tid_r,NULL);
 return 0;
}