我希望以下功能的行為方式相同func fillChanTimeoutUsingTicker(maxDuration time.Duration, chanSize int) chan string { c := make(chan string, chanSize) ticker := time.NewTicker(maxDuration) for { select { case <-ticker.C: ticker.Stop() fmt.Println("Ticker:operation timedout") return c case c <- "Random message": default: fmt.Println("Ticker:chan is full") return c } }}func fillChanTimeoutUsingTimeAfter(maxDuration time.Duration, chanSize int) chan string { c := make(chan string, chanSize) for { select { case <-time.After(maxDuration): fmt.Println("time.After:operation timedout") return c case c <- "Random message": default: fmt.Println("time.After:chan is full") return c } }}稱他們?yōu)椋?nbsp; resWithTicker := fillChanTimeoutUsingTicker(time.Duration(1*time.Microsecond), 10000000) fmt.Println(len(resWithTicker)) resWithTimeAfter := fillChanTimeoutUsingTimeAfter(time.Duration(1*time.Microsecond), 10000000) fmt.Println(len(resWithTimeAfter))印刷：Ticker:operation timedout43979time.After:chan is full10000000我認(rèn)為他們會(huì)以完全相同的方式行事，我真的沒有得到巨大的差異，對(duì)此有什么想法嗎？請(qǐng)注意，還可以像在股票代碼功能中一樣使用計(jì)時(shí)器按預(yù)期工作。
1 回答
回首憶惘然
TA貢獻(xiàn)1847條經(jīng)驗(yàn) 獲得超11個(gè)贊
問題出在您的代碼中。
在您的第一個(gè)示例中，您正在創(chuàng)建一個(gè)股票代碼并將其用于超時(shí)。
在您的第二個(gè)示例中，您每次循環(huán)時(shí)都會(huì)創(chuàng)建一個(gè)計(jì)時(shí)器：
case <-time.After(maxDuration):
從庫(kù)源中可以看出，這相當(dāng)于
case <- time.NewTimer(maxDuration).C:
如果每次循環(huán)時(shí)都創(chuàng)建一個(gè)新的 Ticker/Timer（并丟棄舊的），它可能永遠(yuǎn)不會(huì)觸發(fā)。
因此，為了讓您的第二個(gè)示例正確運(yùn)行，請(qǐng)這樣做（未經(jīng)測(cè)試）：
func fillChanTimeoutUsingTimeAfter(maxDuration time.Duration, chanSize int) chan string {
c := make(chan string, chanSize)
t := time.After(maxDuration)
for {
select {
case <-t:
fmt.Println("time.After:operation timedout")
return c
case c <- "Random message":
default:
fmt.Println("time.After:chan is full")
return c
}
}
}
- 1 回答
- 0 關(guān)注
- 235 瀏覽
添加回答
舉報(bào)
0/150
提交
取消