golangcond源码分析(代码片段)

author author     2022-11-05     658

关键词:

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... 查看详情