Требуется распараллелить fetch функцию, в случае возврата ошибки одной из рутин, стопать все (сигнатуры fetch и Do менят

go · concurrencyWildberries / WB - 9 (Рекламная платформа)не решено

Условие

Требуется распараллелить fetch функцию, в случае возврата ошибки одной из рутин, стопать все (сигнатуры fetch и Do менять нельзя).

func main() {
  t := time.Now()
  names, err := Do(context.Background(), []User{
    {"Paul "}, {"Jack "}, {"Jack "}, {"Mike "},
  })
  if err != nil {
    fmt.Println("Error: ", err)
    os.Exit(1)
  }
  fmt.Println("Result: ", names)
  fmt.Println("Elapsed time: ", time.Since(t))
}

// fetch что-то делаем по сети.
func fetch(_ context.Context, u User) (string, error) {
  time.Sleep(time.Millisecond * 10) // имитация задержки
  return u.Name, nil
}

func Do(ctx context.Context, users []User) (map[string]int64, error) {
  names := make(map[string]int64, len(users))

  for _, u := range users {
    name, err := fetch(ctx, u)
    if err != nil {
      fmt.Println(err)
      os.Exit(1)
    }

    names[name] = names[name] + 1
  }

  return names, nil
}

Решение

Разбор

---

Источник: Wildberries / WB - 9 (Рекламная платформа)

← Задача на change pointer. · Все задачи · Go · Сделать ревью кода. →