ломтика каналов и одновременно функция выполнение

Question

Как создать срез каналов и функцию запуска double(i) одновременно внутри кусочка итерации:

package main 

import (
    "fmt" 
    "time" 
) 

func double(i int) int { 
    result := 2 * i 
    fmt.Println(result) 
    time.Sleep(500000000) 
    return result 
} 

func notParallel(arr []int) (outArr []int) { 
    for _, i := range arr { 
     outArr = append(outArr, double(i)) 
    } 
    return 
} 

// how to do the same as notParallel func in parallel way. 
// For each element of array double func should evaluate concuruntly 
// without waiting each next element to eval 
func parallel(arr []int) (outArr []int) { 

    var chans []chan int 
    for i := 0; i < len(arr); i++ { 
     chans[i] = make(chan int) // i = 0 : panic: runtime error: index out of range 
    } 

    for counter, number := range arr { 
     go func() { 
      chans[counter] <- double(number) 
     }() 
    } 

    return 
} 

func main() { 
    arr := []int{7, 8, 9} 
    fmt.Printf("%d\n", notParallel(arr)) 
    fmt.Printf("%d\n", parallel(arr)) 
} 

playground

В функции double(i) спит в течение 500 мса функционирует notParallel(arr []int) работы на 1500 мс для 3 элементов arr []int, но функция parallel(arr []int) будет работать около 500 мс.

В моей реализации есть ошибка ...

panic: runtime error: index out of range 

... на линии ...

chans[i] = make(chan int) // i = 0 

Answer 1

В этом случае вам не нужно использовать чан.

package main 

import (
    "fmt" 
    "sync" 
    "time" 
) 

func double(i int) int { 
    result := 2 * i 
    fmt.Println(result) 
    time.Sleep(500000000) 
    return result 
} 

func notParallel(arr []int) (outArr []int) { 
    for _, i := range arr { 
     outArr = append(outArr, double(i)) 
    } 
    return 
} 

// how to do the same as notParallel func in parallel way. 
// For each element of array double func should evaluate concuruntly 
// without waiting each next element to eval 
func parallel(arr []int) (outArr []int) { 
    outArr = make([]int, len(arr)) 
    var wg sync.WaitGroup 
    for counter, number := range arr { 
     wg.Add(1) 
     go func(counter int, number int) { 
      outArr[counter] = double(number) 
      wg.Done() 
     }(counter, number) 
    } 
    wg.Wait() 

    return 
} 

func main() { 
    arr := []int{7, 8, 9} 
    fmt.Printf("%d\n", notParallel(arr)) 
    fmt.Printf("%d\n", parallel(arr)) 
} 

Потому что параллель должна дождаться окончания отделки гортани (ов).

И я замечаю, что ваш код не работает, потому что вы ссылаетесь counter, number в той же области действия.