c 递归互斥量(recursive mutex)

时间:2020-03-28 12:08:55   收藏:0   阅读:61

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

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\n", strerror(err));
    exit(1);
  }

  ++i;
  printf("%d\n", i);

  //pthread_mutex_unlock(&mt);//-------②
  pthread_mutex_unlock(&mt);
}

void* fn2(void* arg)
{
  sleep(1);//目的是让线程fn1先执行。
  pthread_mutex_lock(&mt);//-----------①
  ++i;
  printf("second %d\n", 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

技术分享图片

原文:https://www.cnblogs.com/xiaoshiwang/p/12586549.html

评论(0
© 2014 bubuko.com 版权所有 - 联系我们:wmxa8@hotmail.com
打开技术之扣,分享程序人生!