Задача
Решение
Обсуждение

ProcessAll: минимальный пул

Пул на N воркеров разбирает пачку задач, результаты в исходном порядке. Реализуйте processAll: воркеры читают канал через range, пишут по индексу, производитель закрывает канал.

func processAll(items []int, workers int, fn func(int) int) []int {
	results := make([]int, len(items))
	ch := make(chan job)
	var wg sync.WaitGroup
	for i := 0; i < workers; i++ {
		wg.Add(1)
		go func() {
			defer wg.Done()
			for j := range ch {
				results[j.idx] = fn(j.val)
			}
		}()
	}
	for i, item := range items {
		ch <- job{idx: i, val: item}
	}
	close(ch)
	wg.Wait()
	return results
}

Добавить комментарий Отменить ответ

package main

import "sync"

type job struct {
	idx int
	val int
}

// processAll обрабатывает items пулом из workers воркеров.
func processAll(items []int, workers int, fn func(int) int) []int {
	results := make([]int, len(items))
	_ = sync.WaitGroup{}
	_ = fn
	// ваш код
	return results
}