Início / coding / Perguntas / 79333843
Accepted
pmoubed
Asked: 2025-01-07 01:24:40 +0800 CST

Este é um vazamento de goroutine usando Timer?

  • 772

Veja o exemplo de 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")
}

Pergunta: depois de parar o cronômetro fica go func()travado para sempre? E se sim, qual seria a maneira correta de lidar com esse caso?

go

2 respostas

  1. Best Answer

    Se o timer for parado antes de disparar, a goroutine continuará esperando. Você tem que pará-la usando outro canal ou um contexto:

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

  2. depois de parar o timer, go func() fica travado para sempre?

    Sim.

    e se sim, qual seria a maneira correta de lidar com esse caso?

    Você pode deixar o código como está; não há problema em uma goroutine bloquear indefinidamente, desde que isso não cause um deadlock ou vazamento.

    Se você quiser que a goroutine continue, veja a resposta de Burak Serdar . Se você quiser que a função apenas faça algo depois que o timer expirar (mas não depois que ele for parado), use 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")
    }

    Note que houve uma correção muito recente no Go 1.23. De time.Timer.Stop ...

    Para um timer baseado em chan criado com NewTimer(d), a partir do Go 1.23, qualquer recebimento de tC após Stop ter retornado é garantido para bloquear em vez de receber um valor de tempo obsoleto de antes de Stop; se o programa ainda não tiver recebido de tC e o timer estiver em execução, Stop tem a garantia de retornar true. Antes do Go 1.23, a única maneira segura de usar Stop era inserir um <-tC extra se Stop retornasse false para drenar um valor obsoleto potencial. Veja a documentação do NewTimer para mais detalhes.

    E de time.Timer.NewTimer ...

    Antes do Go 1.23, o canal associado a um Timer era assíncrono (bufferizado, capacidade 1), o que significava que valores de tempo obsoletos podiam ser recebidos mesmo após Timer.Stop ou Timer.Reset retornarem. A partir do Go 1.23, o canal é síncrono (sem buffer, capacidade 0), eliminando a possibilidade desses valores obsoletos.

    • 1

relate perguntas