当前位置：首页 > 文章列表 > Golang > Go问答 > Go 定时器停止时死锁

Go 定时器停止时死锁

来源：stackoverflow 2024-03-08 18:27:24 0浏览收藏

从现在开始，努力学习吧！本文《Go 定时器停止时死锁》主要讲解了等等相关知识点，我会在golang学习网中持续更新相关的系列文章，欢迎大家关注并积极留言建议。下面就先一起来看一下本篇正文内容吧，希望能帮到你！

问题内容

我试图通过停止和重置计时器来重用它们。我遵循文档提供的模式。这是一个可以在 go 演示中运行的简单示例，演示了我遇到的问题。

是否有正确的方法来停止和重置计时器，而不涉及死锁或竞争条件？我知道使用默认的选择会涉及通道消息传递时间的竞争条件，并且不能依赖。

package main

import (
    "fmt"
    "time"
    "sync"
)

func main() {
    fmt.Println("Hello, playground")

    timer := time.NewTimer(1 * time.Second)
    wg := &sync.WaitGroup{}
    wg.Add(1)

    go func(_wg *sync.WaitGroup) {
        <- timer.C
        fmt.Println("Timer done")
        _wg.Done()
    }(wg)

    wg.Wait()
    fmt.Println("Checking timer")
    if !timer.Stop() {
        <- timer.C
    }

    fmt.Println("Done")
}

解决方案

根据 timer.Stop 文档，有一个关于排空通道的警告：

假设该程序尚未从 t.c 收到...

这不能与来自计时器的其他接收同时完成频道。

由于通道已经耗尽 - 并且永远不会再次触发，因此第二个 <-timer.c 将永远阻塞。

问题首先询问为什么计时器挂起。这是一个很好的问题，因为即使用户程序中没有错误，这个名为 time.timer 的东西在 go 中的工作方式至少也存在一些奇怪的歧义。规范特别指出：

有非常简短和精确的单词，但可能不太容易理解（至少对我来说）。我尝试在一段代码中重复使用计时器，并在每次使用之前重置它。每次我这样做时，我可能想要 stop() 它——只是为了确定。上面的规范暗示了您应该如何做到这一点，并提供了一个示例 - 它可能不起作用！这取决于您尝试在何处应用“停止”习惯用法。如果您在这个计时器上已经处于选择情况后执行此操作，那么它将挂起程序。

具体来说，我没有任何并发接收器，只有一个 goroutine。那么让我们制作一个简单的测试程序，并尝试使用它（https://play.golang.org/p/d7BlNReE9Jz）：

package main

import (
    "fmt"
    "time"
)

func main() {
    i := 0
    d2s := time.second * 1
    
    i++; fmt.println(i)
    
    t := time.newtimer(d2s)
    <-t.c
    i++; fmt.println(i)

    t.reset(d2s)
    <-t.c
    i++; fmt.println(i)

//  if !t.stop() { <-t.c }
//  if !t.stop() { select { case <-t.c: default: } }
    t.reset(d2s)
    <-t.c
    i++; fmt.println(i)

}

这段代码可以工作。它打印 1,2,3,4，延迟 1 秒，这就是它预期打印的内容。到目前为止一切顺利。

现在，尝试取消注释第一行注释。现在的事情是：根据规范，它是 100% 正确的（是吗？），并且必须工作，但它不工作，并且挂起。为什么？因为，根据规范，它必须悬挂！我已经读取了该通道，并且计时器已停止，因此 if 触发，并且通道排出操作挂起。

这是一个错误吗？不，规格有误吗？不，这是正确的。但是，这与典型的计时器用户想要的相反。（也许是 go 提案的主题？）。我们所需要的只是：