关键词:
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 &CondL: l
Wait
等待自动解锁c.L和暂停执行调用goroutine。恢复执行后,等待锁c.L返回之前。与其他系统不同,等待不能返回,除非通过广播或信号唤醒。
因为c。当等待第一次恢复时,L并没有被锁定,调用者通常不能假定等待返回时的条件是正确的。相反,调用者应该在循环中等待:
func (c *Cond) Wait()
// 检查c是否是被复制的,如果是就panic
c.checker.check()
// 将当前goroutine加入等待队列
t := runtime_notifyListAdd(&c.notify)
// 解锁
c.L.Unlock()
// 等待队列中的所有的goroutine执行等待唤醒操作
runtime_notifyListWait(&c.notify, t)
c.L.Lock()
判断cond是否被复制。
type copyChecker uintptr
func (c *copyChecker) check()
if uintptr(*c) != uintptr(unsafe.Pointer(c)) &&
!atomic.CompareAndSwapUintptr((*uintptr)(c), 0, uintptr(unsafe.Pointer(c))) &&
uintptr(*c) != uintptr(unsafe.Pointer(c))
panic("sync.Cond is copied")
Signal
唤醒等待队列中的一个goroutine,一般都是任意唤醒队列中的一个goroutine,为什么没有选择FIFO的模式呢?这是因为FiFO模式效率不高,虽然支持,但是很少使用到。
func (c *Cond) Signal()
// 检查c是否是被复制的,如果是就panic
c.checker.check()
// 通知等待列表中的一个
runtime_notifyListNotifyOne(&c.notify)
Broadcast
唤醒等待队列中的所有goroutine。
func (c *Cond) Broadcast()
// 检查c是否是被复制的,如果是就panic
c.checker.check()
// 检查c是否是被复制的,如果是就panic
runtime_notifyListNotifyAll(&c.notify)
实例
package main
import (
"fmt"
"sync"
"time"
)
var locker = new(sync.Mutex)
var cond = sync.NewCond(locker)
func main()
for i := 0; i < 40; i++
go func(x int)
cond.L.Lock() //获取锁
defer cond.L.Unlock() //释放锁
cond.Wait() //等待通知,阻塞当前goroutine
fmt.Println(x)
time.Sleep(time.Second * 1)
(i)
time.Sleep(time.Second * 1)
fmt.Println("Signal...")
cond.Signal() // 下发一个通知给已经获取锁的goroutine
time.Sleep(time.Second * 1)
cond.Signal() // 3秒之后 下发一个通知给已经获取锁的goroutine
time.Sleep(time.Second * 3)
cond.Broadcast() //3秒之后 下发广播给所有等待的goroutine
fmt.Println("Broadcast...")
time.Sleep(time.Second * 60)
popupwindow源码分析(代码片段)
...1.2显示PopupWindow1.3最简单的创建1.4注意问题宽和高属性2.源码分析2.1setContentView(ViewcontentView)2.2showAsDropDown()源码2.3dismiss()源码分析2.4PopupDecorView源码分析3.经典总结3.1PopupWindow和Dialog有什么区别? 查看详情
vuex源码分析(代码片段)
VueX源码分析(4)/modulestore.js/module/module.jsimportforEachValuefrom‘../util‘//Basedatastructforstore‘smodule,packagewithsomeattributeandmethodexportdefaultclassModuleconstructor(rawModule,runtime)th 查看详情
android音频源码分析——audiotrack设备选择(代码片段)
Android音频源码分析——AndroidRecord录音(一)Android音频源码分析——AndroidRecord录音(二)Android音频源码分析——AndroidRecord音频数据传输流程Android音频源码分析——audioserver启动Android音频源码分析——AudioFlingerAnd... 查看详情
vuex源码分析(代码片段)
VueX源码分析(2)剩余内容/module/pluginshelpers.jsstore.jshelpers要从底部开始分析比较好。也即先从辅助函数开始再分析那4个map函数mapState。helpers.jsgetModuleByNamespace/***Searchaspecialmodulefromstorebynamespace.ifmodulenotexist,printerrorm 查看详情
arouter源码分析——provider源码分析(代码片段)
Arouter源码分析系列建议从最初开始阅读,全部文章请访问https://github.com/AlexMahao/ARouter在之前分析拦截器时,发现拦截器的基础服务InterceptorService是通过Providers的方式构造实例对象的。于是以下进行Providers的分析。首先看... 查看详情
netflixconductor源码分析--client层源码分析(代码片段)
一、Client层总体介绍在正式介绍Client层源码前,我们先来看一下如何在client端与server端通信,demo代码如下:TaskClienttaskClient=newTaskClient();taskClient.setRootURI("http://localhost:8080/api/");//Pointthist 查看详情
threadlocalmap源码分析(代码片段)
ThreadLocalMap的源码分析分析之前我们来看看ThreadLocalMap有哪些成员变量吧!staticclassEntryextendsWeakReference<ThreadLocal<?>>/**ThevalueassociatedwiththisThreadLocal.*/Objectvalue;Entry(ThreadLocal<?>k,O 查看详情
dialogfragment源码分析(代码片段)
目录介绍1.最简单的使用方法1.1官方建议1.2最简单的使用方法1.3DialogFragment做屏幕适配2.源码分析2.1DialogFragment继承Fragment2.2onCreate(@NullableBundlesavedInstanceState)源码分析2.3setStyle(@DialogStyleintstyle,@StyleResinttheme)2.4onActivit 查看详情
flinkparametertoolfromargs源码分析(代码片段)
一、源码路径java/org/apache/flink/streaming/examples/socket/SocketWindowWordCount.java二、源码/**LicensedtotheApacheSoftwareFoundation(ASF)underone*ormorecontributorlicenseagreements.SeetheNOTICEfile*distribute 查看详情
vscode源码分析加载第一个画面(代码片段)
第一篇: vscode源码分析【一】从源码运行vscode第二篇:vscode源码分析【二】程序的启动逻辑,第一个窗口是如何创建的第三篇:vscode源码分析【三】程序的启动逻辑,性能问题的追踪第四篇:vscode源码分析【四】程序启动的... 查看详情
reactnative源码分析——nativeview创建流程(代码片段)
1、ReactNative源码分析(一)——启动流程2、ReactNative源码分析(二)——通信机制3、ReactNative源码分析(三)——NativeView创建流程4、ReactNative源码分析(四)——任务调度5、ReactNative源码分析(... 查看详情
reactnative源码分析——nativeview创建流程(代码片段)
1、ReactNative源码分析(一)——启动流程2、ReactNative源码分析(二)——通信机制3、ReactNative源码分析(三)——NativeView创建流程4、ReactNative源码分析(四)——任务调度5、ReactNative源码分析(... 查看详情
locksupport源码分析(代码片段)
目录LockSupport源码分析LockSupport的实现1.内部重要的属性:2.getBlocker(Thread)与setBlocker(Threadt,Objectarg)源码3.park的其他几个方法4.park()/unpark()与wait()/notify()区别:LockSupport源码分析LockSupport是Java6引入的一个工具类,用于挂起和唤醒线程;LockS... 查看详情
androidsparsearray源码分析(代码片段)
文章目录SparseArray源码分析总结基本使用源码分析基本属性get()put()delete()gc()其他ContainerHelpers类GrowingArrayUtils类SparseArray源码分析总结在Android中,某些场景推荐使用SparseArray替代HashMap,其原因是SparseArray更加节省内存,... 查看详情
jdk源码分析通过源码分析cyclicbarrier(代码片段)
...要在中午聚个会,几个朋友全部到齐后才开始喝酒吃菜。源码CyclicBarrier属性和构造器publicclassCyclicBarrier//互斥锁privatefinalReentrantLocklock=newReentrantLock();//条件等待privatef 查看详情
spring源码分析之abstractapplicationcontext源码分析(代码片段)
首先我觉得分析ApplicationContext必须从它的实现类开始进行分析,AbstractApplicationContext我觉得是一个不错的选择,那我们就从这里开始逐一分析吧,首先我自己手画了一张图,作为索引吧,其中蓝色的为类,紫色的为接口,箭... 查看详情
android音频源码分析——audioserver启动(代码片段)
Android音频源码分析——AndroidRecord录音(一)Android音频源码分析——AndroidRecord录音(二)Android音频源码分析——AndroidRecord音频数据传输流程Android音频源码分析——audioserver启动该源码分析基于android9.0 Android音... 查看详情
09spring源码-分析篇-di源码分析(代码片段)
Spring源码-DI的过程 接下来我们分析下Spring源码中Bean初始化过程中的DI过程。也就是属性的依赖注入。一、构造参数依赖1.如何确定构造方法 在Spring中生成Bean实例的时候默认是调用对应的无参构造方法来处理。@Componentp... 查看详情