6 int MaxItems; // Maximum items a producer can produce or a consumer can consume
7 int BufferSize; // Size of the buffer
14 pthread_mutex_t mutex;
16 int DEBUG = 0; // Debug flag
18 static void *producer(void *pno)
21 for(int i = 0; i < MaxItems; i++) {
22 item = rand(); // Produce a random item
23 pthread_mutex_lock(&mutex);
26 if(DEBUG) printf("Producer %d: Insert Item %d at %d\n", *((int *)pno),buffer[in],in);
27 in = (in+1)%BufferSize;
28 pthread_mutex_unlock(&mutex);
34 static void *consumer(void *cno)
36 for(int i = 0; i < MaxItems; i++) {
37 pthread_mutex_lock(&mutex);
39 int item = buffer[out];
40 if(DEBUG) printf("Consumer %d: Remove Item %d from %d\n",*((int *)cno),item, out);
41 out = (out+1)%BufferSize;
42 pthread_mutex_unlock(&mutex);
48 int main(int argc, char* argv[]) {
50 printf("Usage: %s MAX_ITEMS BUFFER_SIZE DEBUG\n", argv[0]);
54 MaxItems = atoi(argv[1]);
55 BufferSize = atoi(argv[2]);
56 DEBUG = atoi(argv[3]);
58 buffer = (int*) malloc(BufferSize * sizeof(int));
60 pthread_t pro[5],con[5];
61 pthread_mutex_init(&mutex, NULL);
62 sem_init(&empty,0,BufferSize);
65 int a[5] = {1,2,3,4,5}; //Just used for numbering the producer and consumer
67 for(int i = 0; i < 5; i++) {
68 pthread_create(&pro[i], NULL, producer, (void *)&a[i]);
70 for(int i = 0; i < 5; i++) {
71 pthread_create(&con[i], NULL, consumer, (void *)&a[i]);
74 for(int i = 0; i < 5; i++) {
75 pthread_join(pro[i], NULL);
77 for(int i = 0; i < 5; i++) {
78 pthread_join(con[i], NULL);