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

6. Выписка по счетам: WaitGroup и канал

Средняя

Go · 46 строк

У клиента от 1 до 12 счетов: карты, вклады, брокерский. Collect грузит операции по каждому счёту в своей горутине и собирает общий список для экрана «Выписка».

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

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

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

Источник: Т‑Банк: секция Go, асинхронность и примитивы синхронизации. Условие пересказано своими словами.

Давали на собеседовании? Ответов пока мало — ваш поможет.
  1. package statement
  3. import (
  4. "context"
  5. "sync"
  6. )
  8. type Operation struct {
  9. AccountID string
  10. Amount int64 // копейки
  11. }
  13. type Loader interface {
  14. Load(ctx context.Context, accountID string) ([]Operation, error)
  15. }
  17. // Collect собирает выписку по всем счетам клиента параллельно.
  18. func Collect(ctx context.Context, l Loader, accounts []string) []Operation {
  19. var wg sync.WaitGroup
  20. out := make(chan []Operation)
  22. for _, id := range accounts {
  23. wg.Add(1)
  24. go load(ctx, l, id, out, wg)
  25. }
  27. go func() {
  28. wg.Wait()
  29. close(out)
  30. }()
  32. var all []Operation
  33. for ops := range out {
  34. all = append(all, ops...)
  35. }
  36. return all
  37. }
  39. func load(ctx context.Context, l Loader, id string, out chan<- []Operation, wg sync.WaitGroup) {
  40. defer wg.Done()
  41. ops, err := l.Load(ctx, id)
  42. if err != nil {
  43. return
  44. }
  45. out <- ops
  46. }