👣 Как предотвратить "молчаливую смерть" горутин в Go?

В статье рассматривается, как реализовать механизм "сердцебиения" (heartbeat) для горутин в Go, чтобы отслеживать их активность и своевременно обнаруживать сбои.

🔍 Зачем нужны heartbeats?
Иногда горутина может завершиться неожиданно без явных ошибок или логов, что затрудняет диагностику. Механизм heartbeats позволяет периодически отправлять сигналы о том, что горутина все еще работает, даже если она ожидает задания. Это особенно полезно для:

Мониторинга состояния фоновых задач

Обнаружения и перезапуска "зависших" горутин

Улучшения надежности и отказоустойчивости систем

🛠 Как это реализовать?
Используя time.Ticker, можно настроить горутину на периодическую отправку сигналов активности через канал. Пример функции dowork:

func dowork(done <-chan interface{}, pulseInterval time.Duration) (<-chan interface{}, <-chan struct{}) {
    heartbeater := make(chan interface{})
    result := make(chan struct{})
    go func() {
        defer close(result)
        defer close(heartbeater)

        pulse := time.NewTicker(pulseInterval)
        workGen := time.NewTicker(3 * pulseInterval)

        defer pulse.Stop()
        defer workGen.Stop()

        sendPulse := func() {
            select {
            case heartbeater <- struct{}{}:
            default:
                // если никто не слушает, пропускаем
            }
        }

        sendResult := func(res struct{}) {
            for {
                select {
                case <-done:
                    return
                case <-pulse.C:
                    sendPulse()
                case result <- res:
                    return
                }
            }
        }

        for {
            select {
            case <-done:
                return
            case <-pulse.C:
                sendPulse()
            case <-workGen.C:
                sendResult(struct{}{})
            }
        }
    }()
    return heartbeater, result
}

    for {
        select {
        case <-heartbeat:
            log.Println("Still alive")
        case <-time.After(5 * time.Second):
            log.Println("Timeout! Goroutine might be dead")
        }
    }
}()