zoukankan      html  css  js  c++  java
  • c 递归互斥量(recursive mutex)

    说递归互斥量前,说下互斥量都有哪些,apue第三版上说有下面4种:

    • PTHREAD_MUTEX_NORMAL:标准类型,不做任何特殊的错误检查或者死锁检测。

      在同一个线程里去锁一个还没有解锁的互斥量时,发生死锁。

    • PTHREAD_MUTEX_RECURSIVE:递归类型。

      此互斥量类型允许同一线程在互斥量解锁前对该互斥量进行多次加锁。递归互斥量维护锁的计数,在解锁次数和加锁次数不相同的情况下,不会释放锁,别的线程就无法加锁此互斥量。

    • PTHREAD_MUTEX_ERRORCHECK:提供错误检测。如果在同一个线程里去锁一个还没有解锁的互斥量,会报告错误。但在centos7(3.10.0-957.el7.x86_64),gcc (GCC) 4.8.5 20150623 (Red Hat 4.8.5-39)上测试过,发现:在同一个线程里去锁一个还没有解锁的互斥量,没有报告错误。

    • PTHREAD_MUTEX_DEFAULT

    gcc (GCC) 4.8.5 20150623 (Red Hat 4.8.5-39)环境里pthread.h里,互斥量类型的定义如下:

    /* Mutex types.  */
    enum
    {
      PTHREAD_MUTEX_TIMED_NP,
      PTHREAD_MUTEX_RECURSIVE_NP,
      PTHREAD_MUTEX_ERRORCHECK_NP,
      PTHREAD_MUTEX_ADAPTIVE_NP
    #if defined __USE_UNIX98 || defined __USE_XOPEN2K8
      ,
      PTHREAD_MUTEX_NORMAL = PTHREAD_MUTEX_TIMED_NP,
      PTHREAD_MUTEX_RECURSIVE = PTHREAD_MUTEX_RECURSIVE_NP,
      PTHREAD_MUTEX_ERRORCHECK = PTHREAD_MUTEX_ERRORCHECK_NP,
      PTHREAD_MUTEX_DEFAULT = PTHREAD_MUTEX_NORMAL
    #endif
    #ifdef __USE_GNU
      /* For compatibility.  */
      , PTHREAD_MUTEX_FAST_NP = PTHREAD_MUTEX_TIMED_NP
    #endif
    };
    
    

    下面的例子验证递归互斥量.

    例子很简单,在main函数里创建2个线程,在线程1的函数fn1,加锁互斥量2次,但是只解锁一次。线程fn2就无法给互斥量加锁,导致一直阻塞在①处。

    为了能够让线程fn1能够先给互斥量加锁,在fn2里调用了sleep函数,让fn2先睡眠1秒,所以fn1就能够先给互斥量加锁了。

    去掉②处的注释,fn2就能锁定mutex了,程序就不会出现死锁状态了。

    #include <stdio.h>
    #include <stdlib.h>
    #include <pthread.h>
    #include <string.h>
    #include <signal.h>
    
    pthread_mutex_t mt;
    int i = 0;
    
    void* fn1(void* agr)
    {
      int err;
    
      pthread_mutex_lock(&mt);
      if((err = pthread_mutex_lock(&mt)) < 0)
      {
        printf("%s
    ", strerror(err));
        exit(1);
      }
    
      ++i;
      printf("%d
    ", i);
    
      //pthread_mutex_unlock(&mt);//-------②
      pthread_mutex_unlock(&mt);
    }
    
    void* fn2(void* arg)
    {
      sleep(1);//目的是让线程fn1先执行。
      pthread_mutex_lock(&mt);//-----------①
      ++i;
      printf("second %d
    ", i);
      pthread_mutex_unlock(&mt);
    }
    
    int main()
    {
      pthread_t tid1, tid2;
    
      pthread_mutexattr_t mat;
      pthread_mutexattr_init(&mat);
    
      //设置锁的类型为递归锁
      pthread_mutexattr_settype(&mat, PTHREAD_MUTEX_RECURSIVE);
      pthread_mutex_init(&mt, &mat);
        
      pthread_create(&tid1, NULL, fn1, NULL);
      pthread_create(&tid2, NULL, fn2, NULL);
    
      pthread_join(tid1, NULL);
      pthread_join(tid2, NULL);
    
      pthread_mutex_destroy(&mt);
    }
    
    c/c++ 学习互助QQ群:877684253 本人微信:xiaoshitou5854

  • 相关阅读:
    Quartz
    WebService
    JavaMail
    安装phpnow服务[Apache_pn]提示失败的解决方法
    idea安装激活
    csdn下载
    java解析json串常识
    Oracle错误——ORA-03113:通信通道的文件结尾
    SSM(Maven集成)
    SpringMVC的拦截器
  • 原文地址:https://www.cnblogs.com/xiaoshiwang/p/12586549.html
Copyright © 2011-2022 走看看