Search code examples
c++multithreadingpthreadsmutexmulticore

How mutex semaphore works?


I am trying multi-core programming, to implement Mutex semaphore for : Initialization; Request ownership; Release ownership; Try ownership; Destruction .

I've created 3 threads. Each thread operates on a global variable Answer. 9 out of 10 times threads execute sequentially. But sometimes thread 3 didn't execute. Is 2nd threads mutex didn't release ?

Here's My Code: thread_tasks.cc

void *task1(void *X)
{

    int MValue = pthread_mutex_init(&Mutex,NULL); //Initialization
    pthread_mutex_lock(&Mutex); //Request ownership
    Answer = Answer * 32; //critical section
    pthread_mutex_unlock(&Mutex); //Release ownership
    flag1=1;
    cout << "\nthread A Answer = " << Answer << endl;
    cout<<"\nthread 1 executed successfully";
}

 void *task2(void *X)
 {
    if(flag1==1)
 {
    int RC = pthread_mutex_trylock(&Mutex); //Try ownership
    cout<<"\nRC: "<<RC;
    Answer = Answer/2;
    flag2=1;
    cout<<"\nthread 2 executed successfully";
    pthread_mutex_unlock(&Mutex); //Release ownership
    pthread_mutex_destroy(&Mutex); //Destruction

}
}



void *task3(void *X)
{
    Answer = Answer+5;
    cout<<"\nthread 3 executed successfully";
}

Header file: thread_tasks.h

using namespace std;
#include <iostream>
#include <pthread.h>

void *task1(void *X);
void *task2(void *X);
void *task3(void *X);

mutex_example.cpp

int Answer = 10;
int flag1 = 0;
int flag2 = 0;
int main(int argc, char *argv[])
{

 pthread_t ThreadA, ThreadB, ThreadC;

 cout << "Answer = " << Answer << endl;
 pthread_create( &ThreadA,NULL,task1,NULL);
 pthread_create( &ThreadB,NULL,task2,NULL);
 pthread_create( &ThreadC,NULL,task3,NULL);
 pthread_join(ThreadA,NULL);
 pthread_join(ThreadB,NULL);
 pthread_join(ThreadC,NULL);

 cout << "Answer = " << Answer << endl;

 return(0);
}

Solution

  • Solved the issue: Used thread_1done and thread_2done for maintaining sequence.

    void *task1(void *X)
         {
            int MValue = pthread_mutex_init(&Mutex,NULL); //Initialization
            pthread_mutex_lock(&Mutex); //Request ownership
            Answer = Answer * 32; //critical section
            pthread_mutex_unlock(&Mutex); //Release ownership
            thread_1done=1;
            cout << "\nthread A Answer = " << Answer << endl;
            cout<<"thread 1 executed successfully"<<endl;
         }
    
    
        void *task2(void *X)
        {
            while(1)
                if(thread_1done==1)
                {
                    int RC = pthread_mutex_trylock(&Mutex); //Try ownership
                    Answer = Answer/2;
                    pthread_mutex_unlock(&Mutex);
                    thread_2done=1;
                    cout << "\nthread B Answer = " << Answer << endl;
                    cout<<"thread 2 executed successfully"<<endl;
                    break;
                }
        }
    
    
    
        void *task3(void *X)
        {
            while(1)
                if (thread_2done==1 && thread_1done == 1)
                {
                    int RC = pthread_mutex_trylock(&Mutex); //Try ownership
                    Answer = Answer+5;
                    pthread_mutex_unlock(&Mutex);
                    pthread_mutex_destroy(&Mutex); //Destruction
                    cout << "\nthread C Answer = " << Answer << endl;
                    cout<<"thread 3 executed successfully"<<endl;
                    break;
                }
        }