Неблокирующая функция

package main
 
// this is a comment
func test(f func(int) int, in1 <-chan int, in2 <- chan int, out chan<- int, n int) {
 
    for i := 0; i < n; i++ {
        var x1 int = <- in1
        var x2 int = <- in2
        var res int = f(x1) + f(x2)
        out <- res
    }
}

func sum(out chan<- int, xs <-chan int, ys <-chan int, n int, f func(int) int) {
    go func() {
        for i := 0; i < n; i++ {
            x := <- xs
            y := <- ys
            out <- f(x) + f(y)
        }
    }()
}

func sum(out chan<- int, xs <-chan int, ys <-chan int, n int, f func(int) int) {
    go func() {
        for i := 0; i < n; i++ {
            x := <- xs
            y := <- ys
            out <- f(x) + f(y)
        }
    }()
}

func Merge2Channels(f func(int) int, in1 <-chan int, in2 <- chan int, out chan<- int, n int) {
    go func() { 
    var wg sync.WaitGroup
    for i := 0; i < n; i++ {
        wg.Add(1)
        go func() { 
                x1 := <- in1
                x2 := <- in2
                x3 := f(x1) + f(x2)
                out <- x3
        }()
        wg.Wait()
    }
    }()
}

func Merge2Channels(f func(int) int, in1 <-chan int, in2 <- chan int, out chan<- int, n int) {
    go func() { 
    var wg sync.WaitGroup
    for i := 0; i < n; i++ {
        wg.Add(1)
        go func() { 
                x1 := <- in1
                x2 := <- in2
                        x3 := f(x1) + f(x2)
                out <- x3
        }()
    }
    wg.Wait()
    }()
}

func Merge2Channels(f func(int) int, in1 <-chan int, in2 <-chan int, out chan int, n int) {
    go func() {
        defer close(out)
        for i := 0; i < n; i++ {
            select {
            case a := <-in1:
                out <- (f(a) + f(<-in2))
            case b := <-in2:
                out <- (f(b) + f(<-in1))
            default:
            }
        }
    }()
}