我正在玩頻道，我在這里遇到了一些事情。我有一個(gè)循環(huán)，我想在一段設(shè)定的時(shí)間后停止，比如 5 秒，我還想將迭代去抖動(dòng) 300 毫秒。func pump() <-chan interface{} { c := make(chan interface{}) // use for loop // stop after 5 seconds d := time.NewTicker(time.Millisecond * 2000) go func() { myLoop: for { select { case <-time.After(time.Second * 5): fmt.Println("Its five seconds") close(c) d.Stop() break myLoop default: c <- rand.Int() <-d.C fmt.Println("After wait / debounce") } } }() return c}雖然上面的內(nèi)容似乎是去抖動(dòng)的，但它永遠(yuǎn)不會(huì)觸發(fā)達(dá)到 5 秒的情況。我有類似的結(jié)果time.Tick(time.Second * 5)func pump() <-chan interface{} { c := make(chan interface{}) // use for loop // stop after 5 seconds d := time.NewTicker(time.Millisecond * 2000) t := time.NewTicker(time.Second * 5) go func() { myLoop: for { select { case <-t.C: fmt.Println("Its five seconds") close(c) t.Stop() d.Stop() break myLoop // case <-d.C: // fmt.Println("its a sleep") default: c <- rand.Int() // // slow down <-d.C // fmt.Println("After 3000 milliseconds") } } }() return c}func pump() <-chan interface{} { c := make(chan interface{}) // use for loop // stop after 5 seconds d := time.NewTicker(time.Millisecond * 2000) t := time.NewTicker(time.Second * 5) go func() {}以上對(duì)我有用；使用另一個(gè)代碼。我不明白為什么這會(huì)在前者失敗的地方起作用，尤其是當(dāng) time.Tick() 在文檔中被描述為等同于 time.NewTicker() 時(shí)，只暴露了通道 C。我在這里錯(cuò)過了什么？代碼片段有明顯不同嗎？
1 回答
素胚勾勒不出你
TA貢獻(xiàn)1827條經(jīng)驗(yàn) 獲得超9個(gè)贊
根據(jù)我的評(píng)論：
for {
select {
case <-time.After(time.Second * 5):
...
default:
...
}
}
time.After每次迭代都會(huì)創(chuàng)建一個(gè)新的計(jì)時(shí)器 ( )。這意味著計(jì)時(shí)器永遠(yuǎn)不會(huì)觸發(fā)（因?yàn)閐efault）情況將始終被選中。您可以通過在循環(huán) ( playground )之外創(chuàng)建計(jì)時(shí)器來防止這種情況發(fā)生：
timer := time.After(time.Second * 5)
myLoop:
for {
select {
case <-timer:
break myLoop
default:
...
}
}
你的第二個(gè)例子對(duì)我來說工作正常（見前面提到的游樂場(chǎng)）。請(qǐng)注意，我不確定這些中的任何一個(gè)是否會(huì)實(shí)現(xiàn)您正在尋找的結(jié)果，因?yàn)樗鼪]有真正定義。
- 1 回答
- 0 關(guān)注
- 98 瀏覽
添加回答
舉報(bào)
0/150
提交
取消