#include <stdio.h>
#include <pthread.h>

#define BUF_SIZE 10
#define NUM_PRODUCED 20

int count = 0;
int buf[10];

void * producerFunction (void *arg)
{
	int i, in = 0, nextProduced;
	for (i=0; i<NUM_PRODUCED; i++) {
		nextProduced = i;
		printf("Producing %d\n", nextProduced);
		fflush(NULL);
		while (count>=BUF_SIZE);
		buf[in] = nextProduced;
		in = (in + 1) % BUF_SIZE;
		++count;
	}
	return NULL;
}

void * consumerFunction (void *arg)
{
	int i, out = 0, nextConsumed;
	for (i=0; i<NUM_PRODUCED; i++) {
		while (count<=0);
		nextConsumed = buf[out];
		out = (out + 1) % BUF_SIZE;
		--count;
		printf("Consuming %d\n",i);
		fflush(NULL);
	}
	return NULL;
}


int main()
{
	pthread_t producer, consumer;
	pthread_attr_t attr;

	/* initialize and set the thread attributes */
	pthread_attr_init( &attr );
	pthread_attr_setdetachstate( &attr, PTHREAD_CREATE_JOINABLE );


	/* creating threads */
	if (pthread_create(&producer,&attr,producerFunction,NULL) != 0) {
		fprintf(stderr,"Creating producer thread failed!");
		return 1;
	}
	if (pthread_create(&consumer,&attr,consumerFunction,NULL) != 0) {
		fprintf(stderr,"Creating consumer thread failed!");
		return 1;
	}

	/* joining threads (== waiting for them to exit) */
	if ( pthread_join(producer,NULL) != 0 ) {
		fprintf(stderr,"Joining producer thread failed!");
		return 1;
	}
	if ( pthread_join(consumer,NULL) != 0 ) {
		fprintf(stderr,"Joining consumer thread failed!");
		return 1;
	}

	return 0;
}