#include<stdio.h>
#include<unistd.h>
#include<pthread.h>
#define buffSize 1000

struct{
pthread_mutex_t mutex;
int buff[buffSize];
int producedCount;
int consumedCount;
}shared={PTHREAD_MUTEX_INITIALIZER};


void *produce(void *arg){

while(1){

	pthread_mutex_lock(&shared.mutex);
	if(shared.producedCount<buffSize){

		shared.producedCount++;
		*((int *)arg) += 1;
		pthread_mutex_unlock(&shared.mutex);
	}
	else{
		pthread_mutex_unlock(&shared.mutex);
		return NULL;

}

}

}



void *consume(void *arg){

while(1){

	pthread_mutex_lock(&shared.mutex);
	if(shared.consumedCount<shared.producedCount){
		shared.consumedCount++;
		*((int *)arg) += 1;
		pthread_mutex_unlock(&shared.mutex);
	}
	else{

		pthread_mutex_unlock(&shared.mutex);
		if (shared.consumedCount>=buffSize){
			return NULL;
		}
}

}

}

int main(){
int prodThreads,consThreads,i;
printf("\nEnter the no of Producers: ");fflush(stdout);
scanf("%d",&prodThreads);
printf("\nEnter the no of Consumers: ");fflush(stdout);
scanf("%d",&consThreads);
int producerArr[prodThreads],consumerArr[consThreads];
pthread_t producer[prodThreads],consumer[consThreads];
pthread_setconcurrency(prodThreads+consThreads);

for(i=0;i<prodThreads;i++){
	producerArr[i]=0;
	pthread_create(&producer[i],NULL,produce,&producerArr[i]);

}

for(i=0;i<consThreads;i++){

	consumerArr[i]=0;
	pthread_create(&consumer[i],NULL,consume,&consumerArr[i]);

}

for(i=0;i<prodThreads;i++){
	pthread_join(producer[i],NULL);
	printf("\nThe Producer (%d) produced: [%d] Items",i,producerArr[i]);
	sleep(1);

}

printf("\n");
for(i=0;i<consThreads;i++){
	pthread_join(consumer[i],NULL);
	printf("\nThe Consumer (%d) Consumed: [%d] Items",i,consumerArr[i]);
	sleep(1);

}

}

no of Producers: 4
no of Consumers: 3

The Producer (0) produced: [0] Items
The Producer (1) produced: [881] Items
The Producer (2) produced: [0] Items
The Producer (3) produced: [119] Items

The Consumer (0) Consumed: [33] Items
The Consumer (1) Consumed: [0] Items
The Consumer (2) Consumed: [967] Items

 // in producer loop
                  :
		pthread_mutex_lock(&shared.mutex);
		if (shared.producedCount < buffSize) {
			shared.producedCount++;
			*((int*) arg) += 1;
			pthread_mutex_unlock(&shared.mutex);
			pthread_yield();  // <<<<---------------------
		} else {
                  :