首页  >  文章  >  后端开发  >  为什么 Go Channel 使用 Goroutine 会超时失败?

为什么 Go Channel 使用 Goroutine 会超时失败?

Mary-Kate Olsen
Mary-Kate Olsen原创
2024-11-09 00:21:01761浏览

Why Does Timeout Fail in Go Channels When Using Goroutines?

在 Go 中使用超时和通道

在并发编程领域,Goroutines 和通道在实现异步通信模式中发挥着关键作用。然而,理解它们如何与超时交互可能有点棘手。

考虑以下代码片段:

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 无法访问,它始终返回 true。为什么超时情况没有被执行?

理解这个问题的关键在于 Goroutine 和 Channels 是如何交互的。当在外部 Goroutine 中调用 check(u) 时,它会暂停该 Goroutine 的执行 4 秒。但是,select 语句仅在 check(u) 返回后执行。到那时, check(u) 和 time.After 分支都已准备好运行。

为了解决这个问题,我们需要将 check(u) 隔离在它自己的 Goroutine 中:

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"}))
}

在此修改后的代码中,check(u) 在单独的 Goroutine 中调用。这允许 select 语句正确区分 check(u) 的完成和超时条件。

或者,我们可以通过对所有 URL 使用单个超时来简化代码:

import "fmt"
import "time"

func check(u string, ch chan<- bool) {
    time.Sleep(4 * time.Second)
    ch <- true
}

func IsReachable(urls []string) bool {
    ch := make(chan bool, len(urls))
    for _, url := range urls {
        go check(url, ch)
    }
    time.AfterFunc(time.Second, func() { ch <- false })
    return <-ch
}

func main() {
    fmt.Println(IsReachable([]string{"url1", "url2"}))
}

在此版本中,我们使用一个可以保存所有响应的通道。设置超时时间为一秒,返回通道中第一个到达的结果。如果在超时到期之前无法访问任何 URL,则通道将收到 false 值。

以上是为什么 Go Channel 使用 Goroutine 会超时失败?的详细内容。更多信息请关注PHP中文网其他相关文章!

声明:
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系admin@php.cn