tg-me.com/golangtests/790
Last Update:
🐹 Задача для Go 1.21+: «Контекст отменён, но горутина продолжает работу»
📌 Актуально для: Go 1.21 и новее (введён `context.WithCancelCause`)
🎯 Цель: Понять, почему горутина не завершилась по отменённому контексту
📍 Ситуация:
Ты используешь контекст для управления жизненным циклом горутины. В Go 1.21 ты решил использовать context.WithCancelCause
:
package main
import (
"context"
"fmt"
"time"
)
func main() {
ctx, cancel := context.WithCancelCause(context.Background())
go worker(ctx)
time.Sleep(1 * time.Second)
cancel(fmt.Errorf("manual stop"))
time.Sleep(2 * time.Second)
}
func worker(ctx context.Context) {
<-ctx.Done()
fmt.Println("Worker stopped:", context.Cause(ctx))
}
🔍 Ты ожидаешь, что горутина завершится и выведет:
Worker stopped: manual stop
Но вместо этого — программа завершилась без вывода. Почему?
🧩 Вопросы:
1. Почему
worker
не печатает "Worker stopped: ..."
? 2. Что изменилось в
context.WithCancelCause
по сравнению с WithCancel
? 3. Как безопасно читать причину отмены?
4. Как изменить
worker
, чтобы он корректно завершался? 5. Почему важно не блокироваться на `ctx.Done()`, если возможна гонка?
🛠 Решение:
Но `context.Cause(ctx)` вернёт `nil`, **если ты используешь `context.WithCancel`**, либо, если `ctx.Done()` не был срабатывающим.
🔸 В этом коде `worker(ctx)` запускается и сразу блокируется на:
🔸 **Правильный способ:**
Убедись, что `context.WithCancelCause` действительно используется и `ctx.Done()` слушается вовремя.
Для Go 1.21+ пример рабочий:
func worker(ctx context.Context) {
for {
select {
case <-ctx.Done():
fmt.Println("Worker stopped:", context.Cause(ctx))
return
case <-time.After(100 * time.Millisecond):
fmt.Println("Working...")
}
}
}
🔸 Альтернатива для старых версий Go (<1.21):
...
fmt.Println("Worker stopped:", ctx.Err()) // вместо Cause
📌 Вывод:
BY Go tests
Warning: Undefined variable $i in /var/www/tg-me/post.php on line 283
Share with your friend now:
tg-me.com/golangtests/790