主页 / coding / 问题 / 79333843
Accepted
pmoubed
Asked: 2025-01-07 01:24:40 +0800 CST

这是一个使用 Timer 的 goroutine 泄漏吗？

  • 772

查看 gobyexample.com 的示例：https://gobyexample.com/timers

timer2 := time.NewTimer(time.Second)
go func() {
    <-timer2.C
    fmt.Println("Timer 2 fired")
}()
stop2 := timer2.Stop()
if stop2 {
    fmt.Println("Timer 2 stopped")
}

问题：停止后计时器会go func()永远卡住吗？如果是，处理这种情况的正确方法是什么？

go

2 个回答

  1. Best Answer

    如果计时器在触发之前停止，goroutine 将继续等待。您必须使用另一个通道或上下文来停止它：

    done:=make(chan struct{})
go func() {
    select {
        case <-timer2.C:
            fmt.Println("Timer 2 fired")
        case <-done:
    }
}()
stop2 := timer2.Stop()
close(done)
    • 2

  2. 停止计时器后，go func() 会永远卡住吗？

    是的。

    如果是，那么处理此案的正确方法是什么？

    您可以保留原样的代码；只要不会导致死锁或泄漏，goroutine 无限期阻塞也是可以的。

    如果您希望 goroutine 继续，请参阅Burak Serdar 的答案。如果您希望函数在计时器到期后（但不在停止后）执行某些操作，请使用AfterFunc。

        timer_func := func() { fmt.Println("Timer 2 After Func fired") }
    timer2 := time.AfterFunc(time.Second, timer_func)

    time.Sleep(2 * time.Second)

    stop2 := timer2.Stop()
    if stop2 {
        fmt.Println("Timer 2 stopped")
    }

    请注意，Go 1.23 中有一个最近的修复。从time.Timer.Stop ...

    对于使用 NewTimer(d) 创建的基于 chan 的计时器，从 Go 1.23 开始，在 Stop 返回后从 tC 接收的任何内容都保证会阻塞，而不是从 Stop 之前接收过时的时间值；如果程序尚未从 tC 接收并且计时器正在运行，则 Stop 保证返回 true。在 Go 1.23 之前，使用 Stop 的唯一安全方法是在 Stop 返回 false 时插入额外的 <-tC 以耗尽潜在的过时值。有关更多详细信息，请参阅 NewTimer 文档。

    并从time.Timer.NewTimer ...

    在 Go 1.23 之前，与 Timer 关联的通道是异步的（缓冲，容量为 1），这意味着即使在 Timer.Stop 或 Timer.Reset 返回后，仍可能会收到过时的时间值。从 Go 1.23 开始，通道是同步的（无缓冲，容量为 0），从而消除了这些过时值的可能性。

    • 1

相关问题