在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。