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

12. Слияние событий складов в один канал

Лёгкая

Go · 41 строк

Аналитика получает события сборки заказов с трёх складов и сливает их в один поток через merge.

Отметьте строки с ошибками и ответьте, чем закончится запуск.

В работе: Поток событий складов для дашборда сборки заказов.

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

Источник: на данных Ozon: склады и заказы. Условие пересказано своими словами.

Давали на собеседовании? Ответов пока мало — ваш поможет.
  1. package main
  3. import "fmt"
  5. type Event struct {
  6. Warehouse string
  7. OrderID int64
  8. }
  10. func feed(name string, n int) <-chan Event {
  11. ch := make(chan Event)
  12. go func() {
  13. defer close(ch)
  14. for i := 1; i <= n; i++ {
  15. ch <- Event{Warehouse: name, OrderID: int64(i)}
  16. }
  17. }()
  18. return ch
  19. }
  21. // merge сливает события складов в один поток для аналитики.
  22. func merge(sources ...<-chan Event) <-chan Event {
  23. out := make(chan Event)
  24. for _, src := range sources {
  25. go func() {
  26. defer close(out)
  27. for e := range src {
  28. out <- e
  29. }
  30. }()
  31. }
  32. return out
  33. }
  35. func main() {
  36. events := merge(feed("Хоругвино", 3), feed("Пушкино", 2), feed("Казань", 4))
  37. for {
  38. e := <-events
  39. fmt.Println(e.Warehouse, e.OrderID)
  40. }
  41. }