不使用通道执行Golang超时
发布时间:2020-12-16 19:22:45 所属栏目:大数据 来源:网络整理
导读:我正在使用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 -ti
我正在使用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 ... (编辑:李大同) 【声明】本站内容均来自网络,其相关言论仅代表作者个人观点,不代表本站立场。若无意侵犯到您的权利,请及时与联系站长删除相关内容! |