Выбор ответа Middle Паттерны конкурентности обновлено
Остановка pipeline при раннем выходе
Вопрос
Потребитель берёт из pipeline первые 3 значения и выходит. Что случится со стадиями, которые пишут в небуферизованные каналы, если у них нет ctx или done?
Попробуйте сами
Выберите вариант, и откроется разбор.
Показать ответ и разбор
Коротко
Правильный ответ: Они повиснут на отправке навсегда: утечка горутин. Никто больше не читает, поэтому стадия-источник заблокирована на out <- v навсегда, и все её предки тоже.
Варианты ответа
- Они завершатся автоматически при выходе потребителя
- Будет panic: send on closed channel
- Каналы закроются сборщиком мусора
- Они повиснут на отправке навсегда: утечка горутинправильный ответ
Разбор
Никто больше не читает, поэтому стадия-источник заблокирована на out <- v навсегда, и все её предки тоже. GC не собирает заблокированные горутины. Паники не будет, ведь канал никто не закрывал. Решение: каждая стадия делает select по ctx.Done() при отправке, а потребитель отменяет контекст при выходе.
Ответьте сами, а не прочитайте
В тренажёре вопрос попадёт в повторения и вернётся, когда начнёт забываться. Плюс билеты с зачётом: 20 вопросов, не больше 2 ошибок.