#include <stdio.h>
#include <stdlib.h>
#include <pthread.h>
#include <semaphore.h>
#include <unistd.h>

#define SIZE 5

int buffer[SIZE];
int in = 0, out = 0;

sem_t empty, full;
pthread_mutex_t mutex;

void *producer(void *arg) {
int item;
for(int i=0;i<10;i++) {
item = rand()%100;
sem_wait(&empty);
pthread_mutex_lock(&mutex);

buffer[in] = item;
printf(“Produced: %d\n”, item);
in = (in+1)%SIZE;

pthread_mutex_unlock(&mutex);
sem_post(&full);
sleep(1);
}
}

void *consumer(void *arg) {
int item;
for(int i=0;i<10;i++) {
sem_wait(&full);
pthread_mutex_lock(&mutex);

item = buffer[out];
printf(“Consumed: %d\n”, item);
out = (out+1)%SIZE;

pthread_mutex_unlock(&mutex);
sem_post(&empty);
sleep(1);
}
}

int main() {
pthread_t p, c;
sem_init(&empty,0,SIZE);
sem_init(&full,0,0);
pthread_mutex_init(&mutex,NULL);

pthread_create(&p,NULL,producer,NULL);
pthread_create(&c,NULL,consumer,NULL);

pthread_join(p,NULL);
pthread_join(c,NULL);
return 0;
}