Golang sync.Cond源码分析

lhahhahakk · · 1846 次点击 · · 开始浏览    
这是一个创建于 的文章,其中的信息可能已经有所发展或是发生改变。

cond的主要作用就是获取锁之后,wait()方法会等待一个通知,来进行下一步锁释放等操作,以此控制锁合适释放,释放频率,适用于在并发环境下goroutine的等待和通知。

针对Golang 1.9的sync.Cond,与Golang 1.10一样。 源代码位置:sync\cond.go。

结构体

type Cond struct { noCopy noCopy // noCopy可以嵌入到结构中,在第一次使用后不可复制,使用go vet作为检测使用 // 根据需求初始化不同的锁,如*Mutex 和 *RWMutex L Locker notify notifyList // 通知列表,调用Wait()方法的goroutine会被放入list中,每次唤醒,从这里取出 checker copyChecker // 复制检查,检查cond实例是否被复制 }

再来看看等待队列notifyList结构体:

type notifyList struct { wait uint32 notify uint32 lock uintptr head unsafe.Pointer
	tail unsafe.Pointer
}

函数

NewCond

相当于Cond的构造函数,用于初始化Cond。

参数为Locker实例初始化,传参数的时候必须是引用或指针,比如&sync.Mutex{}或new(sync.Mutex),不然会报异常:cannot use lock (type sync.Mutex) as type sync.Locker in argument to sync.NewCond。
大家可以想想为什么一定要是指针呢? 知道的可以给我留言回答。

func NewCond(l Locker) *Cond { return &Cond{L: l}
}

Wait

等待自动解锁c.L和暂停执行调用goroutine。恢复执行后,等待锁c.L返回之前。与其他系统不同,等待不能返回,除非通过广播或信号唤醒。

因为c。当等待第一次恢复时,L并没有被锁定,调用者通常不能假定等待返回时的条件是正确的。相反,调用者应该在循环中等待:

为了容易理解,本文用一个简化的销售模型来阐述,如下图。图1显示了客户、卖家、商品、定价、订单的关系(这里省略支付、物流等其他元素)。

微服务开发中的数据架构设计


有疑问加站长微信联系(非本文作者)

本文来自:开源中国博客

感谢作者:lhahhahakk

查看原文:Golang sync.Cond源码分析

入群交流(和以上内容无关):加入Go大咖交流群,或添加微信:liuxiaoyan-s 备注:入群;或加QQ群:692541889

1846 次点击  
加入收藏 微博
1 回复  |  直到 2018-04-24 10:09:03
暂无回复
添加一条新回复 (您需要 登录 后才能回复 没有账号 ?)
  • 请尽量让自己的回复能够对别人有帮助
  • 支持 Markdown 格式, **粗体**、~~删除线~~、`单行代码`
  • 支持 @ 本站用户;支持表情(输入 : 提示),见 Emoji cheat sheet
  • 图片支持拖拽、截图粘贴等方式上传