#include <sys/time.h>
#include <stdio.h>
#include <pthread.h>
#include <errno.h>
#include <unistd.h>

pthread_mutex_t produce_mutex = PTHREAD_MUTEX_INITIALIZER;
pthread_mutex_t consume_mutex = PTHREAD_MUTEX_INITIALIZER;

int b;  /* buffer size = 1; */

main()
{
  pthread_t producer_thread;
  pthread_t consumer_thread;
  void *producer();
  void *consumer();

    pthread_mutex_lock(&consume_mutex);
    pthread_create(&consumer_thread,NULL,consumer,NULL);
    pthread_create(&producer_thread,NULL,producer,NULL);
    pthread_join(consumer_thread,NULL);
}

void add_buffer(int i){
  b = i;
}
int get_buffer(){
  return b ;
}

void *producer()
{
int i = 0;
printf("I'm a producer\n");
while (1) {
  pthread_mutex_lock(&produce_mutex);
  add_buffer(i);
  pthread_mutex_unlock(&consume_mutex);
  printf("put %d  \n", i);
  fflush(stdout);
  i = i + 1;
}
pthread_exit(NULL);
}

void *consumer()
{
int i,v;
printf("I'm a consumer\n");
for (i=0;i<100;i++) {
   pthread_mutex_lock(&consume_mutex);
   v = get_buffer();
   pthread_mutex_unlock(&produce_mutex);
   printf("got %d  \n",v);
   fflush(stdout);
   usleep(100000);
}
pthread_exit(NULL);
}