Implement producer-consumer algorithm using multi-threading concept

SOFTWARE LABORATORY

 
Code :
#include<stdio.h>
#include<stdlib.h>
#include<semaphore.h>
#include<pthread.h>

pthread_mutex_t mutex;
sem_t full,empty;

int buffer[5],cnt=0,data;

int produce()
{
    if(cnt<5)
    {
        buffer[cnt]=rand();
        cnt++;
    }
    else
        return(0);
    return(1);
}
int consume()
{
    if(cnt>0)
    {
        data=buffer[cnt-1];
        cnt--;
    }
    else
        return(0);
    return(1);
}
void * producer(void * no)
{
    int flag=0;
    printf("\n\t$$Wake up call to producer %d $$",(int)no);
    sem_wait(&empty);
    printf("\n\t\tWait by producer %d ",(int)no);
    pthread_mutex_lock(&mutex);
    printf("\n\t\tproducer %d is in critical section",(int)no);
    flag=produce();
    if(flag)
        printf("\n\t\tProducer %d has produce item =   %d",(int)no,buffer[cnt-1]);
    else
        printf("\n\t\t*****Buffer is full wait*****");
    //sleep(1);
    pthread_mutex_unlock(&mutex);
    printf("\n\t\tproducer %d Leaving critical section....",(int)no);
    sem_post(&full);
    printf("\n\t$$Signal by produce %d $$\n",(int)no);
   
}

void * consumer(void * no)
{
    int flag=0;
    printf("\n\t$$Wake up call to consumer %d $$",(int)no);
    sem_wait(&full);
    printf("\n\t\tWait by consumer %d ",(int)no);
    pthread_mutex_lock(&mutex);
    printf("\n\t\tEntering %d consumer in critical section",(int)no);
    flag=consume();
    if(flag)
        printf("\n\t\tConsumer %d consumed data =   %d ",(int)no,data);
    else
        printf("\n\t\t*****Wait buffer is empty***** ");
    //sleep(1);
    printf("\n\t\tConsumer %d leaving critical section",(int)no);
    pthread_mutex_unlock(&mutex);
    sem_post(&empty);
    printf("\n\t$$Signal by consumer %d $$\n",(int)no);
}

int main()
{
    int pno,cno,i,ch;
    printf("\n\tEntre no of producer to be generate : ");
    scanf("%d",&pno);
    printf("\n\tEntre no of consumer to be generate : ");
    scanf("%d",&cno);

    pthread_t p[pno],c[cno];
    sem_init(&full,0,0);
    sem_init(&empty,0,5);
   
    for(i=0;i<pno;i++)
    {
        pthread_create(&p[i],NULL,producer,(void *)i);
        sleep(1);
    }
    for(i=0;i<cno;i++)
    {
        pthread_create(&c[i],NULL,consumer,(void *)i);
        sleep(1);
    }

    sleep(5);
    printf("\n\t****FINISH****\n");
   
}
/*        op
root@prashant-HP-ENVY-4-Notebook-PC:~/SPOS Programs/producer consumer# gcc prcn.c -lpthread
root@prashant-HP-ENVY-4-Notebook-PC:~/SPOS Programs/producer consumer# ./a.out

    Entre no of producer to be generate : 3

    Entre no of consumer to be generate : 5

    $$Wake up call to producer 0 $$
        Wait by producer 0
        producer 0 is in critical section
        Producer 0 has produce item =   1804289383
        producer 0 Leaving critical section....
    $$Signal by produce 0 $$

    $$Wake up call to producer 1 $$
        Wait by producer 1
        producer 1 is in critical section
        Producer 1 has produce item =   846930886
        producer 1 Leaving critical section....
    $$Signal by produce 1 $$

    $$Wake up call to producer 2 $$
        Wait by producer 2
        producer 2 is in critical section
        Producer 2 has produce item =   1681692777
        producer 2 Leaving critical section....
    $$Signal by produce 2 $$

    $$Wake up call to consumer 0 $$
        Wait by consumer 0
        Entering 0 consumer in critical section
        Consumer 0 consumed data =   1681692777
        Consumer 0 leaving critical section
    $$Signal by consumer 0 $$

    $$Wake up call to consumer 1 $$
        Wait by consumer 1
        Entering 1 consumer in critical section
        Consumer 1 consumed data =   846930886
        Consumer 1 leaving critical section
    $$Signal by consumer 1 $$

    $$Wake up call to consumer 2 $$
        Wait by consumer 2
        Entering 2 consumer in critical section
        Consumer 2 consumed data =   1804289383
        Consumer 2 leaving critical section
    $$Signal by consumer 2 $$

    $$Wake up call to consumer 3 $$
    $$Wake up call to consumer 4 $$
    ****FINISH****
root@prashant-HP-ENVY-4-Notebook-PC:~/SPOS Programs/producer consumer#

*/