我正在使用 goroutines/channels。這是我的代碼。為什么超時情況沒有得到執行？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()}
1 回答
慕的地6264312
TA貢獻1817條經驗 獲得超6個贊
您的超時不會發生，因為您的一個 goroutinec1每隔 1.5 秒（左右）在您的頻道上重復發送一個值，并且只有c1在 2 秒內沒有收到任何值時才會發生超時。
一旦從 接收到一個值c1，在下一次迭代中select再次執行一個新的 time.After()調用，它將返回一個新的通道，該通道上的值將僅在 2 秒后發送。上次select執行的超時通道被丟棄，不再使用。
要在 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
...
- 1 回答
- 0 關注
- 169 瀏覽
添加回答
舉報
0/150
提交
取消