135-1821-9792

Go运行时中的 Mutex

我在极客时间上开了一门面向中高级Go程序员的课程：Go 并发编程实战课，有读者问Go channel中的实现中使用了mutex,这个mutex和标准库中的Mutex有什么不同?正好在百度厂内分享Go相关课程中有同事也提出了相同的问题，所以我专门写一篇文章介绍一下。

成都创新互联于2013年开始，先为忻城等服务建站，忻城等地企业，进行企业商务咨询服务。为忻城企业网站制作PC+手机+微官网三网同步一站式服务解决您的所有建站问题。

sync.Mutex是一个high level的同步原语，是为广大的Go开发者开发应用程序提供的一种数据结构，现在它的内部实现逻辑比较复杂了，包含spin和饥饿处理等逻辑，它底层使用了运行时的low level的一些函数和atomic的一些方法。

而运行时中的mutex是为运行时内部使用互斥锁而提供的一个同步原语，它提供了spin和等待队列，并没有去解决饥饿状态，而且它的实现和sync.Mutex的实现也是不一样的。它并没有以方法的方式提供Lock/Unlock,而是提供lock/unlock函数实现请求锁和释放锁。

Dan Scales 今年年初的时候又为运行时的锁增加了static locking rank的功能。他为运行时的架构无关的锁( architecture-independent locks)定义了rank,并且又定义了一些运行时的锁的偏序(此锁之前允许持有哪些锁)。这是运行时锁的一个巨大改变，但是很遗憾并没有一篇设计文档详细去描述这个功能的设计，你可以通过提交的comment(#0a820007)和代码中的注释去了解runtime内部锁的代码变化。

本质上来说，这个功能用来检查锁的顺序是不是按照文档设计的顺序执行的，如果有违反设定的顺序，就有可能死锁发生。因为缺乏准确的文档说明，并且这个功能主要是用来检查运行时锁的执行顺序的，所以在本文中我把这一段逻辑抹去不介绍了。实际Go运行时要开始这个检查的话，你需要设置变量GOEXPERIMENT=staticlockranking。

那么接下来我们看看运行时的mutex的数据结构的定义以及lock/unlock的实现。

运行时mutex数据结构

运行时的mutex数据结构很简单，如下所示，定义在runtime2.go中：

 
 
 
      
  
  
  1. type mutex struct { 
    2.   
  
  
  2.     lockRankStruct 
    3.   
  
  
  3.     // Futex-based impl treats it as uint32 key, 
    4.   
  
  
  4.     // while sema-based impl as M* waitm. 
    5.   
  
  
  5.     // Used to be a union, but unions break precise GC. 
    6.   
  
  
  6.     key uintptr 
    7.   
  
  
  7. } 
    8.

如果不启用lock ranking,其实lockRankStruct就是一个空结构：

 
 
 
      
  
  
  1. type lockRankStruct struct { 
    2.   
  
  
  2. } 
    3.

那么对于运行时的mutex,最重要的就是key字段了。这个字段针对不同的架构有不同的含义。

对于dragonfly、freebsd、linux架构，mutex会使用基于Futex的实现， key就是一个uint32的值。 Linux提供的Futex(Fast user-space mutexes)用来构建用户空间的锁和信号量。Go 运行时封装了两个方法，用来sleep和唤醒当前线程：

  • futexsleep(addr uint32, val uint32, ns int64)：原子操作`if addr == val { sleep }`。
  • futexwakeup(addr *uint32, cnt uint32)：唤醒地址addr上的线程最多cnt次。

对于其他的架构，比如aix、darwin、netbsd、openbsd、plan9、solaris、windows，mutex会使用基于sema的实现，key就是M* waitm。Go 运行时封装了三个方法，用来创建信号量和sleep/wakeup：

  • func semacreate(mp *m):创建信号量
  • func semasleep(ns int64) int32： 请求信号量，请求不到会休眠一段时间
  • func semawakeup(mp *m)：唤醒mp

基于这两种实现，分别有不同的lock和unlock方法的实现，主要逻辑都是类似的，所以接下来我们只看基于Futex的lock/unlock。

请求锁lock

如果不使用lock ranking特性，lock的逻辑主要是由lock2实现的。

 
 
 
      
  
  
  1. func lock(l *mutex) { 
    2.   
  
  
  2.     lockWithRank(l, getLockRank(l)) 
    3.   
  
  
  3. } 
    4.   
  
  
  4. func lockWithRank(l *mutex, rank lockRank) { 
    5.   
  
  
  5.     lock2(l) 
    6.   
  
  
  6. } 
    7.   
  
  
  7. func lock2(l *mutex) { 
    8.   
  
  
  8.     // 得到g对象 
    9.   
  
  
  9.     gp := getg() 
    10.   
  
  
  10.     // g绑定的m对象的lock计数加1 
    11.   
  
  
  11.     if gp.m.locks < 0 { 
    12.   
  
  
  12.         throw("runtime·lock: lock count") 
    13.   
  
  
  13.     } 
    14.   
  
  
  14.     gp.m.locks++ 
    15.   
  
  
  15.     // 如果有幸运光环，原来锁没有被持有，一把就获取到了锁，就快速返回了 
    16.   
  
  
  16.     v := atomic.Xchg(key32(&l.key), mutex_locked) 
    17.   
  
  
  17.     if v == mutex_unlocked { 
    18.   
  
  
  18.         return 
    19.   
  
  
  19.     } 
    20.   
  
  
  20.     // 否则原来的可能是MUTEX_LOCKED或者MUTEX_SLEEPING 
    21.   
  
  
  21.     wait := v 
    22.   
  
  
  22.     // 单核不进行spin,多核CPU情况下会尝试spin 
    23.   
  
  
  23.     spin := 0 
    24.   
  
  
  24.     if ncpu > 1 { 
    25.   
  
  
  25.         spin = active_spin 
    26.   
  
  
  26.     } 
    27.   
  
  
  27.      
    28.   
  
  
  28.     for { 
    29.   
  
  
  29.         // 尝试spin,如果锁已经释放，尝试抢锁 
    30.   
  
  
  30.         for i := 0; i < spin; i++ { 
    31.   
  
  
  31.             for l.key == mutex_unlocked { 
    32.   
  
  
  32.                 if atomic.Cas(key32(&l.key), mutex_unlocked, wait) { 
    33.   
  
  
  33.                     return 
    34.   
  
  
  34.                 } 
    35.   
  
  
  35.             } 
    36.   
  
  
  36.             // PAUSE 
    37.   
  
  
  37.             procyield(active_spin_cnt) 
    38.   
  
  
  38.         } 
    39.   
  
  
  39.         // 再尝试抢锁, rescheduling. 
    40.   
  
  
  40.         for i := 0; i < passive_spin; i++ { 
    41.   
  
  
  41.             for l.key == mutex_unlocked { 
    42.   
  
  
  42.                 if atomic.Cas(key32(&l.key), mutex_unlocked, wait) { 
    43.   
  
  
  43.                     return 
    44.   
  
  
  44.                 } 
    45.   
  
  
  45.             } 
    46.   
  
  
  46.             osyield() 
    47.   
  
  
  47.         } 
    48.   
  
  
  48.         // 再尝试抢锁，并把key设置为mutex_sleeping,如果抢锁成功，返回 
    49.   
  
  
  49.         v = atomic.Xchg(key32(&l.key), mutex_sleeping) 
    50.   
  
  
  50.         if v == mutex_unlocked { 
    51.   
  
  
  51.             return 
    52.   
  
  
  52.         } 
    53.   
  
  
  53.          
    54.   
  
  
  54.         // 否则sleep等待 
    55.   
  
  
  55.         wait = mutex_sleeping 
    56.   
  
  
  56.         futexsleep(key32(&l.key), mutex_sleeping, -1) 
    57.   
  
  
  57.     } 
    58.   
  
  
  58. } 
    59.

unlock

如果不使用lock ranking特性，unlock的逻辑主要是由unlock2实现的。

 
 
 
      
  
  
  1. func unlock(l *mutex) { 
    2.   
  
  
  2.     unlockWithRank(l) 
    3.   
  
  
  3. } 
    4.   
  
  
  4. func unlockWithRank(l *mutex) { 
    5.   
  
  
  5.     unlock2(l) 
    6.   
  
  
  6. } 
    7.   
  
  
  7. func unlock2(l *mutex) { 
    8.   
  
  
  8.     // 将key的值设置为mutex_unlocked 
    9.   
  
  
  9.     v := atomic.Xchg(key32(&l.key), mutex_unlocked) 
    10.   
  
  
  10.     if v == mutex_unlocked { 
    11.   
  
  
  11.         throw("unlock of unlocked lock") 
    12.   
  
  
  12.     } 
    13.   
  
  
  13.     // 如果原来有线程在sleep,唤醒它 
    14.   
  
  
  14.     if v == mutex_sleeping { 
    15.   
  
  
  15.         futexwakeup(key32(&l.key), 1) 
    16.   
  
  
  16.     } 
    17.   
  
  
  17.     //得到当前的goroutine以及和它关联的m,将锁的计数减1 
    18.   
  
  
  18.     gp := getg() 
    19.   
  
  
  19.     gp.m.locks-- 
    20.   
  
  
  20.     if gp.m.locks < 0 { 
    21.   
  
  
  21.         throw("runtime·unlock: lock count") 
    22.   
  
  
  22.     } 
    23.   
  
  
  23.     if gp.m.locks == 0 && gp.preempt { // restore the preemption request in case we've cleared it in newstack 
    24.   
  
  
  24.         gp.stackguard0 = stackPreempt 
    25.   
  
  
  25.     } 
    26.   
  
  
  26. } 
    27.

总体来说，运行时的mutex逻辑还不太复杂，主要是需要处理不同的架构的实现，它休眠唤醒的对象是m,而sync.Mutex休眠唤醒的对象是g。


网页题目：Go运行时中的 Mutex
文章分享：http://wtcwzsj.com/article/djdojhd.html

其他资讯


关于我们
我们的服务
网站建设案例
新闻动态
联系我们

135-1821-9792

公司服务热线
友情链接： 广汉箱式发电机维修   gyfdjwx.com   谷歌优化排名   sciotweb.com   成都服务器租赁   画册设计制作   xdwzjz.cn   成都微信开发   ssl数字证书   四川发电机维保   

Copyright © 2009-2022 www.wtcwzsj.com 青羊区广皓图文设计工作室（个体工商户） 版权所有　蜀ICP备19037934号