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

2021-12-07 21:02:03 阅读：222 来源： 互联网

标签：taxi name thread linux char 互斥 pthread arrive 计程车

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

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

ICode9

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