Golang的sync包中的Cond实现了一种条件变量,主要用来解决多个读协程等待共享资源变成ready的场景。在使用Cond的时候,需要特别注意下:每个Cond都会关联一个Lock(*sync.Mutex or *sync.RWMutex),当修改条件或者调用Wait方法时,必须加锁,保护condition。
定义如下所示:
Cond相关API介绍, Cond主要有三个函数构成,Broadcast(), Signal(), Wait()。
1.1. Broadcast()
用来唤醒所有的处于等待c状态的协程,如果没有等待的协程,该函数也不会报错。
备注:使用该函数时,可以不加锁,也可以加锁,原因是该函数没有修改操作。
1.2. Signal()
通知单个等待c状态的协程,让它继续执行,如果此时有多个协程处于等待状态,会从等待列表中取出最开始等待的那个协程,来接收消息。
备注:使用该函数时,也可以不加锁,原因1.1 所示。
1.3. Wait()
主要由四步构成: Unlock()-> 阻塞等待通知(即等待Signal()或Broadcast()的通知)-> 收到通知-> Lock()
该函数在被调用之后,在没有收到Signal或者Broadcast的通知之前,协程处于阻塞状态。
备注:使用这个函数的时候,一定要加锁。
2.1. broadcast与wait配合的例子
结果分析:通过输出结果我们可以看出,处于wait状态的协程0和1,在收到broadcast之后,都会继续执行后续操作。
2.2 . signal与wait配合的例子
结果分析:通过输出结果可以看出,第一个signal触发的时候,就算已经有2个协程在wait状态,但是wait状态中的最开始等待的协程0会被先调用。
等到第二个sinal被触发之后,处于等待状态的协程1才会被调用。