我正在使用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 ...
