linux互斥锁---一个简单的计程车线程

x33g5p2x  于2021-12-08 转载在 Linux  
字(2.9k)|赞(0)|评价(0)|浏览(209)

实现一个计程车的流程,打车,taxi,上车,到达

#include <stdio.h> 
#include <stdlib.h> 
#include <unistd.h> 
#include <pthread.h> //定义头文件

pthread_cond_t taxicond = PTHREAD_COND_INITIALIZER; 
  /*初始化条件变量*/
pthread_mutex_t taximutex = PTHREAD_MUTEX_INITIALIZER;
/*初始化互斥锁*/

先写main函数;创建线程

int main (int argc, char **argv)  
{  
    char *name;  
    pthread_t thread;  //线程号

    pthread_attr_t threadattr; /*线程属性*/ 
    pthread_attr_init(&threadattr);/*对线程属性变量进行初始化*/  
    
    name = "Susan";  
    pthread_create(&thread, &threadattr, traveler_arrive, name); 
/*创建一个thread进程,与traveler_arrive函数捆绑在一起,name为Susan*/
  sleep(1);  
  
    name = "Jack";  
    pthread_create(&thread,&threadattr,taxi_arrive,name);/*创建进程thread,taxi_arrive函数捆绑在一起name为Jack*/  
    sleep(1);  
    
    name = "Mike";  
    pthread_create(&thread,&threadattr,taxi_arrive,name); /*创建进程thread,taxi_arrive函数捆绑在一起name为Mike*/  
    sleep(1);  
  
    return 0;  
}

创建了一个name=Susan的用traveler_arrive函数
创建了一个Jack用taxi_arrive函数
创建了一个Mike用taxi_arrive函数

下面实现函数

void *traveler_arrive(void *name)  
{  

    char *p = (char *)name;  

    printf ("Travelr: %s need a taxi now!\n", p);  
    pthread_mutex_lock(&taximutex); /*拿到互斥锁,锁住互斥量*/ 
    pthread_cond_wait(&taxicond, &taximutex);/*令进程等待在条件变量上修改条件*/  
    pthread_mutex_unlock(&taximutex);/*释放互斥锁*/  

    printf ("traveler: %s now got a taxi!\n", p);  
    pthread_exit(NULL);/*退出*/  
}

传入void* name 给转换为char* 给 *p

输出谁需要taxi

上锁 锁住互斥量,令进程等待在条件变量上修改条件,解锁

输出谁got a taxi

上面的函数是乘车的人的函数

下面是taxi的人的函数

void *taxi_arrive(void *name)  
{  
    char *p = (char *)name;  
    printf ("Taxi: %s arrives.\n", p);  
    pthread_cond_signal(&taxicond); /*条件改变,发送信号,通知进程thread*/ 
    pthread_exit(NULL);  /*退出*/
}

转换为char *
输出taxi 谁 到达
发送信号,通知乘车人进程 进程thread

总代码:

#include <stdio.h> 
#include <stdlib.h> 
#include <unistd.h> 
#include <pthread.h> //定义头文件

pthread_cond_t taxicond = PTHREAD_COND_INITIALIZER; 
  /*初始化条件变量*/
pthread_mutex_t taximutex = PTHREAD_MUTEX_INITIALIZER;
/*初始化互斥锁*/  

void *traveler_arrive(void *name)  
{  

    char *p = (char *)name;  

    printf ("Travelr: %s need a taxi now!\n", p);  
    pthread_mutex_lock(&taximutex); /*拿到互斥锁,锁住互斥量*/ 
    pthread_cond_wait(&taxicond, &taximutex);/*令进程等待在条件变量上修改条件*/  
    pthread_mutex_unlock(&taximutex);/*释放互斥锁*/  

    printf ("traveler: %s now got a taxi!\n", p);  
    pthread_exit(NULL);/*退出*/  
}  
  
void *taxi_arrive(void *name)  
{  
    char *p = (char *)name;  
    printf ("Taxi: %s arrives.\n", p);  
    pthread_cond_signal(&taxicond); /*条件改变,发送信号,通知进程thread*/ 
    pthread_exit(NULL);  /*退出*/
}  

  
int main (int argc, char **argv)  
{  
    char *name;  
    pthread_t thread;  //线程号

    pthread_attr_t threadattr; /*线程属性*/ 
    pthread_attr_init(&threadattr);/*对线程属性变量进行初始化*/  
    
    name = "Susan";  
    pthread_create(&thread, &threadattr, traveler_arrive, name); 
/*创建一个thread进程,与traveler_arrive函数捆绑在一起,name为Susan*/
    sleep(1);  
    
    name = "Jack";  
    pthread_create(&thread,&threadattr,taxi_arrive,name);/*创建进程thread,taxi_arrive函数捆绑在一起name为Jack*/  
    sleep(1);  
    
    name = "Mike";  
    pthread_create(&thread,&threadattr,taxi_arrive,name); /*创建进程thread,taxi_arrive函数捆绑在一起name为Mike*/ 
    sleep(1);  
  
    return 0;  
}

相关文章

微信公众号