Fan-Out: параллельная обработка чисел

Средняя

Concurrency

Условие задачи

Реализуй fan-out: у тебя есть канал с числами от 1 до 100. Нужно создать N воркеров (например, 5), каждый из которых будет возводить число в квадрат и печатать результат. Воркеры должны работать параллельно. После обработки всех чисел — завершить программу.

func worker(id int, jobs <-chan int, results chan<- int) {
    // TODO: реализуй обработку
}

func main() {
    jobs := make(chan int, 100)
    results := make(chan int, 100)

    // TODO: запусти 5 воркеров

    // TODO: отправь в канал числа от 1 до 100

    // TODO: собери и выведи результаты
}

func worker(id int, jobs <-chan int, results chan<- int) {
    // TODO: реализуй обработку
}

func main() {
    jobs := make(chan int, 100)
    results := make(chan int, 100)

    // TODO: запусти 5 воркеров

    // TODO: отправь в канал числа от 1 до 100

    // TODO: собери и выведи результаты
}

Подсказка

Используй go worker(...) для запуска горутин. Не забудь закрыть канал jobs. Для ожидания результатов можно использовать sync.WaitGroup или просто считать их вручную.

Решение

Fan-Out помогает параллельно обрабатывать независимые задачи. Все воркеры читают из общего канала jobs и пишут в results.

func worker(id int, jobs <-chan int, results chan<- int) {
    for n := range jobs {
        results <- n * n
    }
}

func main() {
    jobs := make(chan int, 100)
    results := make(chan int, 100)

    for w := 1; w <= 5; w++ {
        go worker(w, jobs, results)
    }

    for j := 1; j <= 100; j++ {
        jobs <- j
    }
    close(jobs)

    for a := 1; a <= 100; a++ {
        fmt.Println(<-results)
    }
}

func worker(id int, jobs <-chan int, results chan<- int) {
    for n := range jobs {
        results <- n * n
    }
}

func main() {
    jobs := make(chan int, 100)
    results := make(chan int, 100)

    for w := 1; w <= 5; w++ {
        go worker(w, jobs, results)
    }

    for j := 1; j <= 100; j++ {
        jobs <- j
    }
    close(jobs)

    for a := 1; a <= 100; a++ {
        fmt.Println(<-results)
    }
}