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

实现一个计程车的流程，打车，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函数

注：上面已经初始化互斥锁和条件变量
不用写int函数了

下面实现函数

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;  
} 

标签：taxi,name,thread,linux,char,互斥,pthread,arrive,计程车
来源： https://blog.csdn.net/qq_35629971/article/details/121771213