Перейти к содержимому

Необходимо закончить функцию processInParallel чтобы производилась параллельная работа processData в 5 потоков.

go · concurrencyEmploycityне решено

Необходимо закончить функцию processInParallel чтобы производилась параллельная работа processData в 5 потоков.

func main() {
in := make(chan int, 100)
out := make(chan int, 100)
// Generating input data
go func() {
for i := 0; i < 100; i++ {
in <- i
}
close(in)
}()
processInParallel(in, out, 5)
for result := range out {
fmt.Println("Processed:", result)
}
}
func processInParallel(in <-chan int, out chan<- int, workers int) {
panic("not implemented ")
}
func processData(data int) int {
time.Sleep(100 * time.Millisecond) // Simulate time-consuming task
return data * 2
}

Источник: Employcity

← (код без описания) · Все задачи · Go · Что будет в консоли и почему? →