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

8. Пул воркеров для рассылки push

Сложная

Go · 47 строк

SendAll получает пачку из 50 тысяч push и число воркеров, обычно 32. Каждый воркер вызывает send и пишет результат в канал.

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

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

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

Источник: на задачах Сбера: push-уведомления в СберБанк Онлайн. Условие пересказано своими словами.

Давали на собеседовании? Ответов пока мало — ваш поможет.
  1. package push
  3. import (
  4. "fmt"
  5. "sync"
  6. )
  8. type Push struct {
  9. Token string
  10. Text string
  11. }
  13. type Result struct {
  14. Token string
  15. Err error
  16. }
  18. // SendAll рассылает push клиентам через пул воркеров.
  19. func SendAll(pushes []Push, workers int, send func(Push) error) []Result {
  20. jobs := make(chan Push)
  21. results := make(chan Result)
  22. var wg sync.WaitGroup
  24. for i := 0; i < workers; i++ {
  25. go func() {
  26. wg.Add(1)
  27. defer wg.Done()
  28. for p := range jobs {
  29. results <- Result{Token: p.Token, Err: send(p)}
  30. }
  31. }()
  32. }
  34. for _, p := range pushes {
  35. jobs <- p
  36. }
  38. wg.Wait()
  39. close(results)
  41. var out []Result
  42. for r := range results {
  43. out = append(out, r)
  44. }
  45. fmt.Printf("отправлено %d из %d\n", len(out), len(pushes))
  46. return out
  47. }