线程同步之递归锁

LockMind.png

这是并发控制方案的系列文章,介绍了各种锁的使用及优缺点。

  1. 自旋锁
  2. os_unfair_lock
  3. 互斥锁
  4. 递归锁
  5. 条件锁
  6. 读写锁
  7. @synchronized

OSSpinLock、os_unfair_lock、pthread_mutex_t、pthread_cond_t、pthread_rwlock_t 是值类型,不是引用类型。这意味着使用 = 会进行复制,使用复制的可能导致闪退。pthread 函数认为其一直处于初始化的内存地址,将其移动到其他内存地址会产生问题。使用copy的OSSpinLock不会崩溃,但会得到一个全新的锁。

如果你对线程、进程、串行、并发、并行、锁等概念还不了解,建议先查看以下文章:

递归锁(Recursive Lock)也称为可重入互斥锁(reentrant mutex),是互斥锁的一种,同一线程对其多次加锁不会产生死锁。递归锁会使用引用计数机制,以便可以从同一线程多次加锁、解锁,当加锁、解锁次数相等时,锁才可以被其他线程获取。

上一篇文章介绍的pthread_mutex_tNSLock,在同一线程多次加锁,均会导致死锁。

这篇文章包含两种实现互斥锁的方案:pthread_mutex_tNSRecursiveLock

1. pthread_mutex_t

在上一篇文章互斥锁部分已经介绍过pthread_mutex_t。当 mutex type 为PTHREAD_MUTEX_RECURSIVE时,mutex 为递归锁。

如果你对pthread_mutex_t不了解,推荐查看:线程同步之互斥锁

当线程首次获取到锁时,锁计数为1。该线程每加锁一次,计数加一。该线程解锁一次,计数减一。当计数为0时,锁将可被其他线程获取。如果线程尝试解锁未加锁的锁,或者该线程未获取到的锁,会返回错误。

1.1 初始化锁pthread_mutex_init()

初始化锁前需先初始化pthread_mutexattr_t,并设定pthread_mutexattr_settype()

        // 初始化属性
        var attr = pthread_mutexattr_t()
        pthread_mutexattr_init(&attr)
        pthread_mutexattr_settype(&attr, PTHREAD_MUTEX_RECURSIVE)

初始化锁方法如下:

    private var recursiveMutex = pthread_mutex_t()
    
    override init() {        
        // 初始化锁
        pthread_mutex_init(&recursiveMutex, &attr)
    }

不再使用的属性需要销毁:

        // 销毁属性
        pthread_mutexattr_destroy(&attr)

1.2 加锁、解锁

这里的加锁、解锁方法与互斥锁一致。

    override func otherTest() {
        pthread_mutex_lock(&recursiveMutex)
        
        struct Holder {
            static var count = 0
        }
        Holder.count += 1
        print("count = \(Holder.count)")
        if Holder.count < 10 {
            self.otherTest()
        }
        
        pthread_mutex_unlock(&recursiveMutex)
    }

2.3 销毁锁pthread_mutex_destroy()

销毁递归锁与销毁互斥锁方法一致。

    deinit {
        pthread_mutex_destroy(&recursiveMutex)
    }

3. NSRecursiveLock

NSRecursiveLock使用 POSIX thread 实现锁,是对 pthread_mutex_t 的封装。NSRecursiveLock也遵守了NSLocking协议。

3.1 初始化锁NSRecursiveLock()

使用以下方法初始化锁:

    private var recursiveLock = NSRecursiveLock()

GNUstepNSLock.m文件中,其初始化代码如下:

- (id) init
{
  if (nil != (self = [super init]))
    {
      if (0 != pthread_mutex_init(&_mutex, &attr_recursive))
    {
      DESTROY(self);
    }
    }
  return self;
}

3.2 加锁lock()

NSRecursiveLock类有lock()lock(before:)try()三种方式初始化锁,与NSLock相同。

这里使用lock()加锁:

        recursiveLock.lock()

在 GNUstep 的NSLock.m文件中,上述三种加锁方法代码如下:

#define MLOCK \
- (void) lock\
{\
  int err = pthread_mutex_lock(&_mutex);\
  if (EDEADLK == err)\
    {\
      (*_NSLock_error_handler)(self, _cmd, YES, @"deadlock");\
    }\
  else if (err != 0)\
    {\
      [NSException raise: NSLockException format: @"failed to lock mutex"];\
    }\
}

#define MLOCKBEFOREDATE \
- (BOOL) lockBeforeDate: (NSDate*)limit\
{\
  do\
    {\
      int err = pthread_mutex_trylock(&_mutex);\
      if (0 == err)\
    {\
          CHK(Hold) \
      return YES;\
    }\
      sched_yield();\
    } while ([limit timeIntervalSinceNow] > 0);\
  return NO;\
}

#define MTRYLOCK \
- (BOOL) tryLock\
{\
  int err = pthread_mutex_trylock(&_mutex);\
  if (0 == err) \
    { \
      CHK(Hold) \
      return YES; \
    } \
  else \
    { \
      return NO;\
    } \
}

3.3 解锁unlock()

必须在加锁的线程调用unlock()解锁,在其他线程解锁会产生无法预期的错误,解锁未获取到的锁也会产生错误。

    override func otherTest() {
        recursiveLock.lock()
        
        struct Holder {
            static var count = 0
        }
        Holder.count += 1
        print("count = \(Holder.count)")
        if Holder.count < 10 {
            self.otherTest()
        }
        
        recursiveLock.unlock()
    }

在 GNUstep 的NSLock.m文件中,unlock()代码如下:

#define MUNLOCK \
- (void) unlock\
{\
  if (0 != pthread_mutex_unlock(&_mutex))\
    {\
      [NSException raise: NSLockException\
        format: @"failed to unlock mutex"];\
    }\
  CHK(Drop) \
}

上述加锁、解锁方式与NSLock完全一致,只是锁不同。

Demo名称:Synchronization
源码地址:https://github.com/pro648/BasicDemos-iOS/tree/master/Synchronization

上一篇:线程同步之互斥锁

下一篇:线程同步之条件锁

参考资料:

  1. Recursive Locks Will Kill You!

  2. Recursive (Re-entrant) Locks

欢迎更多指正:https://github.com/pro648/tips

本文地址:https://github.com/pro648/tips/blob/master/sources/线程同步之递归锁.md

©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 204,684评论 6 478
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 87,143评论 2 381
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 151,214评论 0 337
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 54,788评论 1 277
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 63,796评论 5 368
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 48,665评论 1 281
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 38,027评论 3 399
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 36,679评论 0 258
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 41,346评论 1 299
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 35,664评论 2 321
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 37,766评论 1 331
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 33,412评论 4 321
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 39,015评论 3 307
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 29,974评论 0 19
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 31,203评论 1 260
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 45,073评论 2 350
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 42,501评论 2 343

推荐阅读更多精彩内容

  • 这是并发控制方案的系列文章,介绍了各种锁的使用及优缺点。自旋锁[https://github.com/pro648...
    pro648阅读 842评论 0 2
  • 这是并发控制方案的系列文章,介绍了各种锁的使用及优缺点。自旋锁[https://github.com/pro648...
    pro648阅读 4,976评论 0 6
  • 这是并发控制方案的系列文章,介绍了各种锁的使用及优缺点。自旋锁[https://github.com/pro648...
    pro648阅读 495评论 0 0
  • 这是多线程、并发控制系列文章第二篇,本文内容主要来自Introduction to thread synchron...
    pro648阅读 665评论 0 0
  • iOS、macOS 设备一般为多核,也就是可以同时执行多项任务。将代码分为多块,并发(Concurrency)执行...
    pro648阅读 844评论 1 3