在Go語言中,為了避免忙等(busy waiting),我們可以使用sync.Cond
來實現條件變量。sync.Cond
是一個基于sync.Mutex
的條件變量,它允許我們在特定條件下等待,同時釋放互斥鎖,讓其他goroutine繼續執行。當條件滿足時,sync.Cond
會自動喚醒等待的goroutine。
下面是一個使用sync.Cond
避免忙等的示例:
package main
import (
"fmt"
"sync"
"time"
)
type Data struct {
value int
cond *sync.Cond
}
func NewData() *Data {
return &Data{
cond: sync.NewCond(&sync.Mutex{}),
}
}
func (d *Data) WaitForValue(target int) {
d.cond.L.Lock() // 獲取互斥鎖
for d.value != target {
d.cond.Wait() // 等待條件滿足
}
fmt.Println("Condition met:", d.value)
d.cond.L.Unlock() // 釋放互斥鎖
}
func (d *Data) SetValue(value int) {
d.cond.L.Lock() // 獲取互斥鎖
d.value = value
d.cond.Signal() // 喚醒等待的goroutine
d.cond.L.Unlock() // 釋放互斥鎖
}
func main() {
data := NewData()
go func() {
time.Sleep(2 * time.Second) // 模擬一些初始化工作
data.SetValue(10)
}()
data.WaitForValue(10)
}
在這個示例中,我們創建了一個Data
結構體,它包含一個整數值和一個條件變量。WaitForValue
方法用于等待條件滿足,SetValue
方法用于設置條件值并喚醒等待的goroutine。通過使用sync.Cond
,我們可以避免忙等,因為cond.Wait()
會自動釋放互斥鎖,讓其他goroutine繼續執行。當條件滿足時,sync.Cond
會自動喚醒等待的goroutine。