当前位置： > > > > 当选定组中的通道在指定时间内没有收到信号时跳出循环
来源：stackoverflow
2024-04-22 20:57:32
0浏览
收藏
你在学习Golang相关的知识吗？本文《当选定组中的通道在指定时间内没有收到信号时跳出循环》，主要介绍的内容就涉及到，如果你想提升自己的开发能力，就不要错过这篇文章，大家要知道编程理论基础和实战操作都是不可或缺的哦！
问题内容
当且仅当我在特定时间段内我的 select 语句正在侦听的任何通道上都没有收到信号时，如何打破包含 select 语句的惯用 go for 循环。
让我用一个例子来增强这个问题。
设置：
- 假设我有一个正在收听的频道
varlistench <-chan string。 - 让我们假设其他一些 go 例程（不在我们的控制范围内）在此通道上发送不同的字符串。
- 我对给定的字符串进行一些处理，然后在
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() （不推荐这样做）
如果您将 放入 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)
输出（在 上尝试）：
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() 在后台创建并使用了一个新的计时器，它不会神奇地停止并获取如果您在超时之前从通道收到值，则不再需要时立即收集垃圾。
更资源友好的解决方案是在循环之前创建一个 ，并在超时之前收到值时重置它。
这就是它的样子：
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
}
}
}
测试和输出是相同的。在 上试试这个。
以上就是本文的全部内容了，是否有顺利帮助你解决问题？若是能给你带来学习上的帮助，请大家多多支持！更多关于Golang的相关知识，也可关注公众号。
