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

23. Зоны доставки Лавки через sync.Once

Средняя

Go · 39 строк

Zone вызывается на каждый новый заказ, около 3 000 раз в секунду. Файл с полигонами весит 2 МБ, автор рассчитывал прочитать его один раз за жизнь процесса.

После выката профилировщик показал, что 40 % CPU уходит в json.Unmarshal, а заказы во всех районах получают «адрес вне зоны доставки». Отметьте строки с ошибками.

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

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

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

  1. package zones
  3. import (
  4. "encoding/json"
  5. "os"
  6. "sync"
  7. )
  9. type Polygon [][2]float64
  11. type ZoneStore struct {
  12. once sync.Once
  13. zones map[string]Polygon
  14. err error
  15. }
  17. // Load читает полигоны 450 дарксторов один раз за жизнь процесса.
  18. func (s ZoneStore) Load(path string) error {
  19. var err error
  20. s.once.Do(func() {
  21. raw, e := os.ReadFile(path)
  22. if e != nil {
  23. err = e
  24. return
  25. }
  26. s.zones = make(map[string]Polygon)
  27. err = json.Unmarshal(raw, &s.zones)
  28. })
  29. return err
  30. }
  32. // Zone вызывается на каждый заказ, 3000 RPS.
  33. func (s *ZoneStore) Zone(storeID string) (Polygon, bool) {
  34. if s.zones == nil {
  35. s.Load("/etc/lavka/zones.json")
  36. }
  37. p, ok := s.zones[storeID]
  38. return p, ok
  39. }