Ответ
В Go нет механизма для принудительного "убийства" горутины извне. Вместо этого используется принцип кооперативной отмены: горутина должна сама проверять сигнал о необходимости завершения и корректно останавливать свою работу.
Существует два основных подхода:
1. Использование канала (done channel)
Это классический способ. Создается отдельный канал, который закрывается, когда нужно дать сигнал горутинам на завершение.
// worker ожидает сигнала в канале done
func worker(done <-chan struct{}) {
fmt.Println("Worker запущен...")
select {
case <-done: // Если канал done закрыт, этот case сработает
fmt.Println("Worker останавливается.")
return
case <-time.After(5 * time.Second): // Пример таймаута
fmt.Println("Worker завершился по таймауту.")
return
}
}
func main() {
done := make(chan struct{})
go worker(done)
// Имитируем работу и даем сигнал на остановку через 2 секунды
time.Sleep(2 * time.Second)
close(done) // Закрытие канала рассылает сигнал всем слушающим горутинам
time.Sleep(1 * time.Second) // Даем время на завершение
}2. Использование пакета context (предпочтительный способ)
Пакет context — это идиоматичный и более мощный инструмент для управления отменой, таймаутами и передачей request-scoped данных.
// worker ожидает сигнала отмены через контекст
func worker(ctx context.Context) {
fmt.Println("Worker запущен...")
select {
case <-ctx.Done(): // Канал Done() закрывается при отмене контекста
// ctx.Err() возвращает причину отмены
fmt.Printf("Worker останавливается: %vn", ctx.Err())
return
}
}
func main() {
// Создаем контекст, который можно отменить
ctx, cancel := context.WithTimeout(context.Background(), 3*time.Second)
defer cancel() // Важно всегда вызывать cancel для освобождения ресурсов
go worker(ctx)
// Ждем, пока сработает таймаут (3 секунды)
time.Sleep(4 * time.Second)
}Ключевой вывод: Независимо от способа, горутина должна активно слушать сигнал о завершении (через select) и самостоятельно прекращать свою работу. Это предотвращает утечки горутин (goroutine leaks).