hw mutex is used to synchronize threads

anubala331

**/A program to show mutex or binary semaphore imlementaion/**

//Actually MUTEX is a macro whose code is same as instruction of binary semaphore ..

//so it will work exactly like binary semaphore

#include<stdio.h>

#include<stdlib.h>

#include<string.h>

#include<pthread.h>

#include<semaphore.h>

void* thread_fun1(void*);

void* thread_fun2(void*);

void* thread_fun3(void*);

void* thread_fun4(void*);

char buff[24],set[20];

sem_t mutex;//variable is declared

int main()

{

int lv;

void* retval;

char *message="THIS IS LINUX";

pthread_t tid1,tid2,tid3,tid4;

if(!pthread_mutex_init(&lock,NULL))//INSTED OF null pointer there may be PTHREAD_MUTEX_INTIALISATION of type pthread_mutexattr_t pointer

printf("sem_init is initialised\n");

printf("lock=%p\n",&lock);

//sem_wait(&mutex);//commments

lv=pthread_create(&tid1,NULL,thread_fun1,(void*)message);

if(lv==0)

{

printf("thread 1 is created\n");

}

//sem_post(&mutex);

//pthread_join(tid1,&retval);

//printf("retval=%s\n",(char*)retval);

message="THIS IS WINDOWS";

//sem_wait(&mutex);

lv=pthread_create(&tid2,NULL,thread_fun2,(void*)message);

if(lv==0)

{

printf("thread 2 is created\n");

}

//pthread_cancel(tid2);

//sem_post(&mutex);

pthread_join(tid2,&retval);

//printf("retval=%s\n",(char*)retval);

message="THIS IS 8051";

//sem_wait(&mutex);

lv=pthread_create(&tid3,NULL,thread_fun3,(void*)message);

if(lv==0)

{

printf("thread 3 is created\n");

}

/sem_pos/t(&mutex);

//pthread_join(tid3,&retval);

//printf("retval=%s\n",(char*)retval);

message="THIS IS MAC";

//sem_wait(&mutex);

lv=pthread_create(&tid4,NULL,thread_fun4,(void*)message);

if(lv==0)

{

printf("thread 4 is created\n");

}

//sem_post(&mutex);

pthread_join(tid4,&retval);

printf("retval=%s\n",(char*)retval);

//sem_destroy(&mutex);

return 0;

}

anubala331

void* thread_fun1(void* arg)

{

if(!pthread_mutex_lock(&lock))//lock the mutex

printf("sem get in thread1 succesfully\n");

int a,b=2;

a=++b;

printf("arg=%s\n",(char*)arg);

sprintf(buff,"%s","hello there!");

printf("...whose priority is %d\n",a);

//pthread_exit("LINUX");

if(!pthread_mutex_unlock(&lock))//unlock the mutex

printf("sem release in thread1 succesfully\n");

}

void* thread_fun2(void* arg)

{

if(!pthread_mutex_lock(&lock))

printf("sem get in thread2 succesfully\n");

int c,d=2;

c=d--;

printf("arg=%s\n",(char*)arg );

printf("buff***************=%s\n",buff);

printf("...whose priority is %d\n",c);

//pthread_exit("WINDOWS");

if(!pthread_mutex_unlock(&lock))

printf("sem release in thread2 succesfully\n");

}

void* thread_fun3(void *arg)

{

if(!pthread_mutex_lock(&lock))

printf("sem get in thread3 succesfully\n");

int e,f=2;

e=--f;

printf("arg=%s\n",(char*)arg);

strcpy(buff,"anu");

printf(" ...whose priority is %d\n",e);

// pthread_exit("8051");

if(!pthread_mutex_unlock(&lock))

printf("sem release in thread3 succesfully\n");

}

void* thread_fun4(void* arg)

{

if(!pthread_mutex_lock(&lock))

printf("sem get in thread4 succesfully\n");

int g,h=1;

g=--h;

printf("arg=%s\n",(char*)arg);

printf("set*****************=%s\n",buff);

printf("...whose priority is %d\n",g);

pthread_exit("MAC");

if(!pthread_mutex_unlock(&lock))

printf("sem release in thread4 succesfully\n");

}

anubala331

**/Another program in which loop is executing in one thread & printing loop in one another thread//A program to show mutex or binary semaphore imlementaion/**

//Actually MUTEX is a macro whose code is same as instruction of binary semaphore ..

//so it will work exactly like binary semaphore

#include<stdio.h>

#include<stdlib.h>

#include<string.h>

#include<pthread.h>

#include<semaphore.h>

**void* thread_fun1(void*);**

**void* thread_fun2(void*);**

**void* thread_fun3(void*);**

**void* thread_fun4(void*);**

char buff[24],set[20];//a global variable is taken

int a[100],i;//buff of 100

pthread_mutex_t lock;//variable is declared

int main()

{

int lv;

**void* retval;**

**char *message="THIS IS LINUX";**

pthread_t tid1,tid2,tid3,tid4;

if(!pthread_mutex_init(&lock,NULL))//INSTED OF null pointer there may be PTHREAD_MUTEX_INTIALISATION of type pthread_mutexattr_t pointer

printf("sem_init is initialised\n");

printf("lock=%p\n",&lock);

//sem_wait(&mutex);

**lv=pthread_create(&tid1,NULL,thread_fun1,(void*)message);**

if(lv==0)

{

printf("thread 1 is created\n");

}

//sem_post(&mutex);

//pthread_join(tid1,&retval);

**//printf("retval=%s\n",(char*)retval);**

message="THIS IS WINDOWS";

//sem_wait(&mutex);

**lv=pthread_create(&tid2,NULL,thread_fun2,(void*)message);**

if(lv==0)

{

printf("thread 2 is created\n");

}

//pthread_cancel(tid2);

//sem_post(&mutex);

pthread_join(tid2,&retval);

**//printf("retval=%s\n",(char*)retval);**

message="THIS IS 8051";

//sem_wait(&mutex);

**lv=pthread_create(&tid3,NULL,thread_fun3,(void*)message);**

if(lv==0)

{

printf("thread 3 is created\n");

}

//sem_post(&mutex);

//pthread_join(tid3,&retval);

**//printf("retval=%s\n",(char*)retval);**

message="THIS IS MAC";

//sem_wait(&mutex);

**lv=pthread_create(&tid4,NULL,thread_fun4,(void*)message);**

if(lv==0)

{

printf("thread 4 is created\n");

}

//sem_post(&mutex);

pthread_join(tid4,&retval);

**printf("retval=%s\n",(char*)retval);**

//sem_destroy(&mutex);

return 0;

}

anubala331

**void* thread_fun1(void* arg)**

{

if(!pthread_mutex_lock(&lock))//lock the mutex

printf("sem get in thread1 succesfully\n");

int a,b=2;

a=++b;

**printf("arg=%s\n",(char*)arg);**

sprintf(buff,"%s","hello there!");

printf("...whose priority is %d\n",a);

//pthread_exit("LINUX");

if(!pthread_mutex_unlock(&lock))//unlock the mutex

printf("sem release in thread1 succesfully\n");

}

**void* thread_fun2(void* arg)**

{

if(!pthread_mutex_lock(&lock))

printf("sem get in thread2 succesfully\n");

int c,d=2;

for(i=0;i<100;i++)//due to mutex ...program counter will tend to move loop continously

{

a[i]=i;//put every value of i in array a[i]

}

c=d--;

**printf("arg=%s\n",(char*)arg );**

printf("buff***********=%s\n",buff);

printf("...whose priority is %d\n",c);

//pthread_exit("WINDOWS");

if(!pthread_mutex_unlock(&lock))

printf("sem release in thread2 succesfully\n");

}

**void* thread_fun3(void *arg)**

{

if(!pthread_mutex_lock(&lock))

printf("sem get in thread3 succesfully\n");

int e,f=2;

e=--f;

for(i=0;i<100;i++)

{

printf("a[%d]=%d",i,a[i]);

}

**printf("arg=%s\n",(char*)arg);**

strcpy(buff,"anu");

printf(" ...whose priority is %d\n",e);

// pthread_exit("8051");

if(!pthread_mutex_unlock(&lock))

printf("sem release in thread3 succesfully\n");

}

**void* thread_fun4(void* arg)**

{

if(!pthread_mutex_lock(&lock))

printf("sem get in thread4 succesfully\n");

int g,h=1;

g=--h;

**printf("arg=%s\n",(char*)arg);**

printf("set*************=%s\n",buff);//print that value of buff in thread 4

printf("...whose priority is %d\n",g);

pthread_exit("MAC");

if(!pthread_mutex_unlock(&lock))

printf("sem release in thread4 succesfully\n");

}

hw mutex is used to synchronize threads

/*A program to show mutex or binary semaphore imlementaion*/

//Actually MUTEX is a macro whose code is same as instruction of binary semaphore ..

//so it will work exactly like binary semaphore

#include<stdio.h>

#include<stdlib.h>

#include<string.h>

#include<pthread.h>

#include<semaphore.h>

void* thread_fun1(void*);

void* thread_fun2(void*);

void* thread_fun3(void*);

void* thread_fun4(void*);

char buff[24],set[20];

sem_t mutex;//variable is declared

int main()

{

int lv;

void* retval;

char *message="THIS IS LINUX";

pthread_t tid1,tid2,tid3,tid4;

if(!pthread_mutex_init(&lock,NULL))//INSTED OF null pointer there may be PTHREAD_MUTEX_INTIALISATION of type pthread_mutexattr_t pointer

printf("sem_init is initialised\n");

printf("lock=%p\n",&lock);

//sem_wait(&mutex);//commments

lv=pthread_create(&tid1,NULL,thread_fun1,(void*)message);

if(lv==0)

{

printf("thread 1 is created\n");

}

//sem_post(&mutex);

//pthread_join(tid1,&retval);

//printf("retval=%s\n",(char*)retval);

message="THIS IS WINDOWS";

//sem_wait(&mutex);

lv=pthread_create(&tid2,NULL,thread_fun2,(void*)message);

if(lv==0)

{

printf("thread 2 is created\n");

}

//pthread_cancel(tid2);

//sem_post(&mutex);

pthread_join(tid2,&retval);

//printf("retval=%s\n",(char*)retval);

message="THIS IS 8051";

//sem_wait(&mutex);

lv=pthread_create(&tid3,NULL,thread_fun3,(void*)message);

if(lv==0)

{

printf("thread 3 is created\n");

}

/sem_pos/t(&mutex);

//pthread_join(tid3,&retval);

//printf("retval=%s\n",(char*)retval);

message="THIS IS MAC";

//sem_wait(&mutex);

lv=pthread_create(&tid4,NULL,thread_fun4,(void*)message);

if(lv==0)

{

printf("thread 4 is created\n");

}

//sem_post(&mutex);

pthread_join(tid4,&retval);

printf("retval=%s\n",(char*)retval);

//sem_destroy(&mutex);

return 0;

}

void* thread_fun1(void* arg)

{

if(!pthread_mutex_lock(&lock))//lock the mutex

printf("sem get in thread1 succesfully\n");

int a,b=2;

a=++b;

printf("arg=%s\n",(char*)arg);

sprintf(buff,"%s","hello there!");

printf("...whose priority is %d\n",a);

//pthread_exit("LINUX");

if(!pthread_mutex_unlock(&lock))//unlock the mutex

printf("sem release in thread1 succesfully\n");

}

**/A program to show mutex or binary semaphore imlementaion/**

**/Another program in which loop is executing in one thread & printing loop in one another thread//A program to show mutex or binary semaphore imlementaion/**

**void* thread_fun1(void*);**

**void* thread_fun2(void*);**

**void* thread_fun3(void*);**

**void* thread_fun4(void*);**

**void* retval;**

**char *message="THIS IS LINUX";**

**lv=pthread_create(&tid1,NULL,thread_fun1,(void*)message);**