在Go语言中,我们可以使用sync.Cond
来实现条件变量的等待功能。sync.Cond
是一个条件变量,它可以帮助我们在满足某个条件时阻塞当前goroutine,直到其他goroutine通知它条件已经满足。
下面是一个简单的示例,展示了如何使用sync.Cond
实现等待功能:
package main
import (
"fmt"
"sync"
"time"
)
type Example struct {
cond *sync.Cond
data int
}
func NewExample() *Example {
return &Example{
cond: sync.NewCond(&sync.Mutex{}),
}
}
func (e *Example) WaitUntilDataGreaterThan(target int) {
e.cond.L.Lock() // 加锁
for e.data <= target {
e.cond.Wait() // 等待条件满足
}
e.cond.L.Unlock() // 解锁
}
func (e *Example) SetData(value int) {
e.cond.L.Lock() // 加锁
e.data = value
e.cond.Signal() // 通知等待的goroutine条件已经满足
e.cond.L.Unlock() // 解锁
}
func main() {
example := NewExample()
go func() {
time.Sleep(2 * time.Second) // 模拟一些工作
example.SetData(5) // 设置数据为5
}()
example.WaitUntilDataGreaterThan(4) // 等待数据大于4
fmt.Println("Data is greater than 4")
}
在这个示例中,我们创建了一个名为Example
的结构体,它包含一个sync.Cond
类型的字段cond
和一个整数字段data
。WaitUntilDataGreaterThan
方法用于等待数据大于指定值,SetData
方法用于设置数据并通知等待的goroutine条件已经满足。
在main
函数中,我们创建了一个Example
实例,并启动一个goroutine来模拟一些工作。在这个goroutine中,我们等待2秒后设置数据为5。在主goroutine中,我们调用WaitUntilDataGreaterThan
方法等待数据大于4。当数据被设置为5时,条件满足,WaitUntilDataGreaterThan
方法返回,程序输出"Data is greater than 4"。
辰迅云「云服务器」,即开即用、新一代英特尔至强铂金CPU、三副本存储NVMe SSD云盘,价格低至29元/月。点击查看>>
推荐阅读: Go语言中的包和导入机制是什么