为了账号安全,请及时绑定邮箱和手机立即绑定

混合 timer.Ticker 与 timer.Tick / timer.After;

混合 timer.Ticker 与 timer.Tick / timer.After;

Go
qq_笑_17 2023-02-06 19:05:52
我正在玩频道,我在这里遇到了一些事情。我有一个循环,我想在一段设定的时间后停止,比如 5 秒,我还想将迭代去抖动 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}虽然上面的内容似乎是去抖动的,但它永远不会触发达到 5 秒的情况。我有类似的结果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() {}以上对我有用;使用另一个代码。我不明白为什么这会在前者失败的地方起作用,尤其是当 time.Tick() 在文档中被描述为等同于 time.NewTicker() 时,只暴露了通道 C。我在这里错过了什么?代码片段有明显不同吗?
查看完整描述

1 回答

?
素胚勾勒不出你

TA贡献1827条经验 获得超9个赞

根据我的评论:


for {

   select {

      case <-time.After(time.Second * 5):

         ...

      default:

         ...

   }

}

time.After每次迭代都会创建一个新的计时器 ( )。这意味着计时器永远不会触发(因为default)情况将始终被选中。您可以通过在循环 ( playground )之外创建计时器来防止这种情况发生:


timer := time.After(time.Second * 5)


myLoop:

for {

   select {

      case <-timer:

         break myLoop

      default:

         ...

   }

}

你的第二个例子对我来说工作正常(见前面提到的游乐场)。请注意,我不确定这些中的任何一个是否会实现您正在寻找的结果,因为它没有真正定义。


查看完整回答
反对 回复 2023-02-06
  • 1 回答
  • 0 关注
  • 101 浏览
慕课专栏
更多

添加回答

举报

0/150
提交
取消
微信客服

购课补贴
联系客服咨询优惠详情

帮助反馈 APP下载

慕课网APP
您的移动学习伙伴

公众号

扫描二维码
关注慕课网微信公众号