Producer-Consumer Problem Using Semphore

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

#define Buffer_Limit 10

int Buffer_Index_Value = -1;
char *Buffer_Queue;
sem_t mutex,empty_count,fill_count;

 void *Consumer()
{
      while(1)
      {
   sem_wait(&fill_count);
   sem_wait(&mutex);
   printf("Consumer:%d\t", Buffer_Index_Value--);       
   sem_post(&mutex);
   sem_post(&empty_count); 
 
      }   
}

void *Producer()
{   
      while(1)
      {
    sem_wait(&empty_count);
            sem_wait(&mutex);
            Buffer_Queue[++Buffer_Index_Value] = '@';
            printf("Producer:%d\t", Buffer_Index_Value);
    sem_post(&mutex);
    sem_post(&fill_count);
      }   
}

int main()
{   
      pthread_t producer_thread_id, consumer_thread_id;

      sem_init(&mutex,0,1); /*Binary Semaphore*/

      sem_init(&fill_count,0,0);
      sem_init(&empty_count,0,Buffer_Limit);

      Buffer_Queue = (char *) malloc(sizeof(char) * Buffer_Limit);           
      pthread_create(&producer_thread_id, NULL, Producer, NULL);
      pthread_create(&consumer_thread_id, NULL, Consumer, NULL);
      pthread_join(producer_thread_id, NULL);
      pthread_join(consumer_thread_id, NULL);
      return 0;
}

Comments

Post a Comment

Popular posts from this blog

STL Questions

1. Sorting a vector of custom objects     a)Using operator()         struct MyStruct {             int key;             std::string str;             MyStruct(int k, int s) : key(k), str(s) {}         };         struct less_than{             inline bool operator()(const MyStruct &s1, const MyStruct &b)             {                 return s1.key<s2.key;             }         };         std::vector<MyStruct> vec;         vec.push_back(MyStruct(4, "a")); ...
Read more

Producer Consumer problem using mutex

  #include<stdio.h> #include<pthread.h> #include<stdlib.h>   // Max buffer size user for producing #define buff_sz 10   // buffer index would be the current index volatile int buff_idx = -1; // buffer used to produce item volatile char *buff = NULL;;   // Initialization and declaration of muetxt and condition variables pthread_mutex_t mutex = PTHREAD_MUTEX_INITIALIZER; pthread_cond_t buff_not_full = PTHREAD_COND_INITIALIZER; pthread_cond_t buff_not_empty = PTHREAD_COND_INITIALIZER;   // Consumer thread void *Consumer() {          while (1)          {                  // Taking lock to avoid race condition                  pthread_mutex_ lock(&m...
Read more

Adapter Design Pattern

Image
This is one of structural design pattern. The adapter pattern is a design pattern that is used to allow two incompatible types to communicate. Example: In one user database system all information regarding user info like name, phone number, emailid, address etc are stored. But to call the user all information is not required, only user name & phone number is sufficient. In this case we can create a new class adapter. This class will provide only those information which is required and hide unrequired information. class User {     string name;     string phonenumber;     string emailId;     string address;     public:         User(string na, string ph, string email, string addr)         {             name = na;             phonenumber = ph; ...
Read more