> ### 條件鎖 ``` package main import ( "sync" "fmt" "time" ) func main() { cond := sync.NewCond(&sync.Mutex{}) for i := 0; i < 10; i++ { go func(n int) { cond.L.Lock() cond.Wait() fmt.Println(n) cond.L.Unlock() }(i) } time.Sleep(time.Second) //喚醒G(一般是喚醒最早等待的G) cond.Signal() //喚醒所有等待的G //cond.Broadcast() time.Sleep(time.Second * 2) } ``` > ### 其它例子 * 條件鎖 ``` package main import ( "sync" "fmt" "time" ) var mailbox uint var lock sync.RWMutex func main() { sendCond := sync.NewCond(&lock) reciverCond := sync.NewCond(lock.RLocker()) //接收方 go func(){ //因為條件變量的方法在阻塞當前的 goroutine 之前，會解鎖它基于的互斥鎖，所以在調用該方法之前，我們必須先鎖定那個互斥鎖，否則在調用這個方法時，就會引發一個不可恢復的 panic。 lock.RLock() //這主要是為了保險起見。如果一個 goroutine 因收到通知而被喚醒，但卻發現共享資源的狀態，依然不符合它的要求，那么就應該再次調用條件變量的Wait方法，并繼續等待下次通知的到來。 //在一些多 CPU 核心的計算機系統中，即使沒有收到條件變量的通知，調用其Wait方法的 goroutine 也是有可能被喚醒 for mailbox == 0 { //把調用它的 goroutine（也就是當前的 goroutine）加入到當前條件變量的通知隊列中。 //解鎖當前的條件變量基于的那個互斥鎖。 //讓當前的 goroutine 處于等待狀態，等到通知到來時再決定是否喚醒它。此時，這個 goroutine 就會阻塞在調用這個 //如果通知到來并且決定喚醒這個 goroutine，那么就在喚醒它之后重新鎖定當前條件變量基于的互斥鎖。自此之后，當前的 goroutine 就會繼續執行后面的代碼了。 reciverCond.Wait() } mailbox = 0 //如果當前的 goroutine 無法解鎖，別的 goroutine 也都不來解鎖，那么又由誰來進入臨界區，并改變共享資源的狀態呢？只要共享資源的狀態不變，即使當前的 goroutine 因收到通知而被喚醒，也依然會再次執行這個Wait方法，并再次被阻塞。 lock.RUnlock() //條件變量的Signal方法(喚醒的 goroutine 一般都是最早等待的那一個)和Broadcast都是被用來發送通知的，不同的是，前者的通知只會喚醒一個因此而等待的 goroutine，而后者的通知卻會喚醒所有為此等待的 goroutine。 //Broadcast //(1)多個讀操作可以同時進行。因此被喚醒時如果都是獲取讀鎖的請求，他們都是可以成功返回的。 //(2)但如果是WLock()寫鎖的情況，就會有等待最久的那個能完成獲取鎖的需求。 //最后，請注意，條件變量的通知具有即時性。也就是說，如果發送通知的時候沒有 goroutine 為此等待，那么該通知就會被直接丟棄。在這之后才開始等待的 goroutine 只可能被后面的通知喚醒。 sendCond.Signal() fmt.Println(2) }() //發送方 go func() { time.Sleep(time.Second) lock.Lock() for mailbox == 1 { sendCond.Wait() } mailbox = 1 lock.Unlock() reciverCond.Signal() fmt.Println(1) }() time.Sleep(time.Second * 10) } ```