Войти Регистрация
Конкурентность

7. Отправка push о списаниях: select с default

Лёгкая

Go · 39 строк

Consumer получает события о списаниях по карте и шлёт клиенту push. Run работает в отдельной горутине, Stop вызывается при graceful shutdown пода.

Отметьте строки с ошибками.

В работе: Сервис уведомлений о списаниях по карте.

Как проверяем Нажмите на строку с ошибкой и коротко напишите, что не так. Баг засчитан, если отмечена хотя бы одна его строка. Зачёт — найдено не меньше 60 % багов с учётом серьёзности (критичный весит 3, обычный 2, мелкий 1), а лишних отметок не больше, чем багов в коде. Пустые строки, скобки и комментарии лишними не считаем. Плюс 1 вопрос про поведение программы — на зачёт не влияют. Ответ один на подход: после него показываем разбор.
selectbusy loopостановка горутиныгонка данных

Источник: на задачах Т‑Банка: уведомления о списаниях. Условие пересказано своими словами.

Давали на собеседовании? Ответов пока мало — ваш поможет.
  1. package notify
  3. import "log"
  5. type Event struct {
  6. ClientID string
  7. Text string
  8. }
  10. // Consumer отправляет push о списаниях по карте.
  11. type Consumer struct {
  12. events chan Event
  13. stopped bool
  14. }
  16. func NewConsumer() *Consumer {
  17. return &Consumer{events: make(chan Event, 1000)}
  18. }
  20. func (c *Consumer) Run(send func(Event) error) {
  21. for !c.stopped {
  22. select {
  23. case e := <-c.events:
  24. if err := send(e); err != nil {
  25. log.Printf("push %s: %v", e.ClientID, err)
  26. }
  27. default:
  28. }
  29. }
  30. }
  32. func (c *Consumer) Publish(e Event) {
  33. c.events <- e
  34. }
  36. // Stop вызывается из горутины graceful shutdown.
  37. func (c *Consumer) Stop() {
  38. c.stopped = true
  39. }