• 互斥量解决线程同步问题


    目录

    1.互斥量简介

     2.互斥量的函数原型

    pthread_mutex_init

    pthread_mutex_destroy

    pthread_mutex_lock

    pthread_mutex_trylock

    pthread_mutex_unlock

    3.案例源码


    1.互斥量简介

    简介:使用互斥量来确保同时仅有一个线程可以访问某项共享资源。

    互斥量的两种状态:已锁定(locked)和未锁定(unlocked)

    一旦线程锁定互斥量,随即成为该互斥量的所有者,只有所有者才能给互斥量解锁。

    特殊情形:死锁

    当超过一个线程加锁同一组互斥量,就有可能发生死锁

    死锁的几种场景

    1.忘记释放锁

    2.重复加锁

    3.多线程多锁,抢占锁资源

     2.互斥量的函数原型

    互斥量的类型 pthread_mutex_t

    pthread_mutex_init

    int pthread_mutex_init(pthread_mutex_t *restrict mutex, const pthread_mutexattr_t *restrict attr);
    

    -功能:初始化互斥量

     - 参数 :
                - mutex : 需要初始化的互斥量变量
                - attr : 互斥量相关的属性,NULL
            - restrict : C语言的修饰符,被修饰的指针,不能由另外的一个指针进行操作。
                pthread_mutex_t *restrict mutex = xxx;
                pthread_mutex_t * mutex1 = mutex

    pthread_mutex_destroy

    int pthread_mutex_destroy(pthread_mutex_t *mutex);

    -功能:释放互斥量的资源

    pthread_mutex_lock

    int pthread_mutex_lock(pthread_mutex_t *mutex);

    -功能:加锁,阻塞的,如果有一个线程加锁了,那么其他的线程只能阻塞等待

    pthread_mutex_trylock

    int pthread_mutex_trylock(pthread_mutex_t *mutex);

    -功能:尝试加锁,如果加锁失败,不会阻塞,会直接返回

    pthread_mutex_unlock

    int pthread_mutex_unlock(pthread_mutex_t *mutex);

    -功能:解锁

    3.案例源码

    三个线程对票这个共享资源进行操作

    1. #include
    2. #include
    3. #include
    4. //全局变量,所有的线程都共享这一份资源
    5. int tickets=1000;
    6. //创建一个互斥量
    7. pthread_mutex_t mutex;
    8. void *sellticket(void *arg){
    9. while(1){
    10. //加锁
    11. pthread_mutex_lock(&mutex);
    12. if(tickets>0){
    13. usleep(60000);
    14. printf("%ld 正在卖第 %d 张门票\n",pthread_self(),tickets);
    15. tickets--;
    16. }else{
    17. //解锁
    18. pthread_mutex_unlock(&mutex);
    19. break;
    20. }
    21. //解锁
    22. pthread_mutex_unlock(&mutex);
    23. }
    24. return NULL;
    25. }
    26. int main(){
    27. //初始化互斥量
    28. pthread_mutex_init(&mutex,NULL);
    29. //创建3个子线程
    30. pthread_t tid1,tid2,tid3;
    31. pthread_create(&tid1,NULL,sellticket,NULL);
    32. pthread_create(&tid2,NULL,sellticket,NULL);
    33. pthread_create(&tid3,NULL,sellticket,NULL);
    34. //回收子线程的资源,阻塞函数
    35. pthread_join(tid1,NULL);
    36. pthread_join(tid2,NULL);
    37. pthread_join(tid3,NULL);
    38. //退出主线程
    39. pthread_exit(NULL);
    40. //回收互斥量资源
    41. pthread_mutex_destroy(&mutex);
    42. return 0;
    43. }

  • 相关阅读:
    mysql存储过程
    数据湖:OPPO的数据湖架构升级实践
    实现Traefik工具Dashboard远程访问:搭建便捷的远程管理平台
    C和指针 第10章 结构和联合 10.5 位段
    剑指 Offer 2022/7/1
    AI和人类,谁的钓鱼邮件更胜一筹?
    SpringCloud之服务发现
    美格智能出席无锡智能网联汽车生态大会,共话数字座舱新势力
    Linux网络:关于TCP / IP 五层协议栈的总结
    cmmi3认证需要企业具备什么条件?
  • 原文地址:https://blog.csdn.net/l_ethan/article/details/126016659