在Go语言中,sync.Cond
类型提供了条件变量的功能。要设置超时,你可以使用time.After
函数来创建一个定时器,当定时器到期时,sync.Cond
的Wait
方法将返回一个超时错误。下面是一个示例:
package main import ( "fmt" "sync" "time" ) func main() { var mu sync.Mutex cond := sync.NewCond(&mu) // 模拟一个耗时操作 go func() { time.Sleep(2 * time.Second) mu.Lock() fmt.Println("条件满足,通知等待的goroutine") cond.Signal() mu.Unlock() }() // 设置超时时间为1秒 timeout := time.After(1 * time.Second) // 等待条件满足或超时 mu.Lock() for !cond.WaitTimeout(timeout) { fmt.Println("等待条件满足...") } mu.Unlock() fmt.Println("操作完成") }
在这个示例中,我们创建了一个sync.Cond
类型的条件变量cond
,并模拟了一个耗时操作。我们设置了1秒的超时时间,然后使用WaitTimeout
方法等待条件满足或超时。如果条件在超时时间内满足,WaitTimeout
方法将返回nil
,否则返回一个超时错误。