登录
首页 >  Golang >  Go问答

当选定组中的通道在指定时间内没有收到信号时跳出循环

来源:stackoverflow

时间:2024-04-22 20:57:32 227浏览 收藏

你在学习Golang相关的知识吗?本文《当选定组中的通道在指定时间内没有收到信号时跳出循环》,主要介绍的内容就涉及到,如果你想提升自己的开发能力,就不要错过这篇文章,大家要知道编程理论基础和实战操作都是不可或缺的哦!

问题内容

当且仅当我在特定时间段内我的 select 语句正在侦听的任何通道上都没有收到信号时,如何打破包含 select 语句的惯用 go for 循环。

让我用一个例子来增强这个问题。

设置:

  1. 假设我有一个正在收听的频道 varlistench <-chan string
  2. 让我们假设其他一些 go 例程(不在我们的控制范围内)在此通道上发送不同的字符串。
  3. 我对给定的字符串进行一些处理,然后在 listench 上侦听下一个字符串。

要求:

在关闭操作(永久退出 for 循环)之前,我希望在 listench 上的两个连续信号之间最多等待 10 秒(精度不重要)。

代码存根:

func doingSomething(listenCh <-chan string) {
  var mystr string
  for {
    select {
      case mystr <-listenCh:
        //dosomething
      case /*more than 10 seconds since last signal on listenCh*/:
        return
    }
  }
}

我如何以最有效的方式实现我的要求。

通常使用 time.after(time.duration) 的退出通道技术似乎不会在一次循环后重置,因此即使存在连续的值流,整个程序也会在 10 秒内关闭。

我在 so 上找到了问题的变体(但不是我想要的),但我看到的没有一个能回答我的特定用例。


解决方案


前言:使用time.timer是推荐的方式,这里使用time.after()仅用于演示和推理。请使用第二种方法。

使用 time.after() (不推荐这样做)

如果您将 time.After() 放入 case 分支中,则会在每次迭代中“重置”,因为每次都会返回一个新通道,这样就可以了:

func doingsomething(listench <-chan string) {
    for {
        select {
        case mystr := <-listench:
            log.println("received", mystr)
        case <-time.after(1 * time.second):
            log.println("timeout")
            return
        }
    }
}

(我使用了 1 秒超时来实现演示中的可测试性。)

我们可以像这样测试它:

ch := make(chan string)
go func() {
    for i := 0; i < 3; i++ {
        ch <- fmt.sprint(i)
        time.sleep(500 * time.millisecond)
    }
}()
doingsomething(ch)

输出(在 Go Playground 上尝试):

2009/11/10 23:00:00 received 0
2009/11/10 23:00:00 received 1
2009/11/10 23:00:01 received 2
2009/11/10 23:00:02 timeout

使用time.timer(推荐解决方案)

如果从通道接收的速率很高,这可能会浪费一些资源,因为 time.after() 在后台创建并使用了一个新的计时器,它不会神奇地停止并获取如果您在超时之前从通道收到值,则不再需要时立即收集垃圾。

更资源友好的解决方案是在循环之前创建一个 time.Timer,并在超时之前收到值时重置它。

这就是它的样子:

func doingSomething(listenCh <-chan string) {
    d := 1 * time.Second
    t := time.NewTimer(d)
    for {
        select {
        case mystr := <-listenCh:
            log.Println("Received", mystr)
            if !t.Stop() {
                <-t.C
            }
            t.Reset(d)
        case <-t.C:
            log.Println("Timeout")
            return
        }
    }
}

测试和输出是相同的。在 Go Playground 上试试这个。

以上就是本文的全部内容了,是否有顺利帮助你解决问题?若是能给你带来学习上的帮助,请大家多多支持golang学习网!更多关于Golang的相关知识,也可关注golang学习网公众号。

声明:本文转载于:stackoverflow 如有侵犯,请联系study_golang@163.com删除
相关阅读
更多>
最新阅读
更多>
课程推荐
更多>