运维开发网

不使用通道执行Golang超时

运维开发网 https://www.qedev.com 2020-05-17 16:21 出处:网络 作者:运维开发网整理
我正在使用goroutines /渠道. 这是我的代码. 为什么超时案例没有被执行? func main() { c1 := make(chan int, 1) go func() { for { time.Sleep(1500 * time.Millisecond) c1 <- 10 } }
我正在使用goroutines /渠道.

这是我的代码.

为什么超时案例没有被执行?

func main() {
    c1 := make(chan int, 1)

    go func() {
        for {
            time.Sleep(1500 * time.Millisecond)
            c1 <- 10
        }
    }()

    go func() {
        for {
            select {
            case i := <-c1:
                fmt.Println(i)
            case <-time.After(2000 * time.Millisecond):
                fmt.Println("TIMEOUT") // <-- Not Executed
            }
        }
    }()

    fmt.Scanln()
}
您的超时不会发生,因为您的goroutine中的一个会在1.5秒(或左右)内重复地在您的c1通道上发送一个值,并且只有在没有从c1接收到2秒的值时才会发生超时.

一旦从c1接收到一个值,在下一次迭代中执行再次选择一个新的time.After()调用将返回一个新的通道,在该通道上仅在另外2秒后发送一个值.来自先前选择执行的超时通道将被丢弃,不再使用.

要在2秒后接收超时,请仅创建一次超时通道,例如:

timeout := time.After(2000 * time.Millisecond)
for {
    select {
    case i := <-c1:
        fmt.Println(i)
    case <-timeout:
        fmt.Println("TIMEOUT") // Will get executed after 2 sec
    }
}

输出:

10
TIMEOUT
10
10
10
...
0

精彩评论

暂无评论...
验证码 换一张
取 消