条件等待和互斥锁有不同,互斥锁是不同协程公用一个锁,条件等待是不同协程各用一个锁,但 是wait()方法调用会等待(阻塞),直到有信号发过来,不同协程是共用信号。 可以看如下的代码来理解
代码语言:javascript复制func main() {
wg := sync.WaitGroup{}
cond := sync.NewCond(new(sync.Mutex))
for i:=0 ; i<3 ;i {
go func(i int) {
wg.Add(1)
fmt.Println("协程启动")
cond.L.Lock()//加锁
fmt.Println("协程 ",i,"加锁")
cond.Wait()
cond.L.Unlock()//解锁
fmt.Println("协程 ",i,"解锁")
defer wg.Done()
}(i)
}
time.Sleep(time.Second * 2)
//发送信号
cond.Signal()
fmt.Println("主协程发送信号")
time.Sleep(time.Second * 2)
//发送信号
cond.Signal()
fmt.Println("主协程发送信号")
time.Sleep(time.Second * 2)
//发送信号
cond.Signal()
fmt.Println("主协程发送信号")
wg.Wait()
}
我们可以多次运行得到多种结果。
代码语言:javascript复制协程启动
协程启动
协程启动
协程 0 加锁
协程 2 加锁
协程 1 加锁
主协程发送信号
协程 0 解锁
主协程发送信号
协程 2 解锁
主协程发送信号
协程 1 解锁
代码语言:javascript复制协程启动
协程启动
协程启动
协程 2 加锁
协程 0 加锁
协程 1 加锁
主协程发送信号
协程 2 解锁
主协程发送信号
协程 0 解锁
主协程发送信号
协程 1 解锁
三个协程都申请了锁,在没有发送信号之前,三个协程都无法获得锁,只有当发出信号后,三个协程中的其中一个线程将获得锁(随机)