Go:在通道中使用超时
在 Go 中,超时和通道提供了一种方便的方法来控制 goroutine 的执行并同步其结果。但是,在某些情况下,超时情况可能不会按预期执行。
问题陈述
考虑以下 Go 代码:
import "fmt" import "time" func check(u string) bool { time.Sleep(4 * time.Second) return true } func IsReachable(urls []string) bool { ch := make(chan bool, 1) for _, url := range urls { go func(u string) { select { case ch <- check(u): case <-time.After(time.Second): ch <- false } }(url) } return <-ch } func main() { fmt.Println(IsReachable([]string{"url1"})) }
此代码的目标是检查提供的列表中的所有 URL 是否均可访问。如果任何 URL 在一秒内未能响应,该函数应该返回 false。
但是,执行此代码时,它将始终返回 true。超时情况未执行。
说明
问题是由于 check(u) 的执行方式而产生的。在 IsReachable 函数中,每个 goroutine 通过调用 check(u) 检查 URL 的可达性。然而, check(u) 在返回之前会在当前 goroutine 中休眠 4 秒。
在 select 语句中, case ch
解决方案
要解决此问题,应执行 check(u) 函数在一个单独的 goroutine 中。这使得 select 语句能够正确处理超时情况。
这是更新后的代码:
import "fmt" import "time" func check(u string, checked chan<- bool) { time.Sleep(4 * time.Second) checked <- true } func IsReachable(urls []string) bool { ch := make(chan bool, 1) for _, url := range urls { go func(u string) { checked := make(chan bool) go check(u, checked) select { case ret := <-checked: ch <- ret case <-time.After(1 * time.Second): ch <- false } }(url) } return <-ch } func main() { fmt.Println(IsReachable([]string{"url1"})) }
现在,如果任何 URL 无法在一秒钟内响应,该函数将返回错误的。此外,如果只有一个 URL 可用,该函数将返回 true。
以上是为什么我的 Go 超时在此通道示例中不起作用?的详细内容。更多信息请关注PHP中文网其他相关文章!