我怎麼能在FUNC

Question

我想寫這樣的函數聲明CHAN（通道）的片，但我不能申報渠道的片

func fanIn(set <-[]chan string) <-chan string { 
    c := make(chan string) 

    for i := range set { 
     go func() { for {c <-set[i]} }() 
    } 
    return c 
} 

是否有可能在進入有一小部分渠道作爲參數？

呼叫

set := [2]chan string{mylib.Boring("Joe"), mylib.Boring("Ann")} 
c := fanIn(set) 

的例子，如果我能做到這一點

func fanIn(input1, input2 <-chan string) <-chan string { 

我認爲它應該是可能有 「< -chan字符串」

的片或陣列已更新：

func fanIn(set []<-chan string) <-chan string { 
    c := make(chan string) 

    for i := range set { 
     go func() { 
      for { 
       x := <-set[i] 
       c <- x 
      } 
     }() 
    } 

    return c 
} 

func main() { 
    set := []<-chan string{mylib.Boring("Joe"), mylib.Boring("Ann"), mylib.Boring("Max")} 
    c := fanIn(set) 
    for i := 0; i < 10; i++ { 
     fmt.Println(<-c) 
    } 
    fmt.Println("You're boring: I'm leaving.") 
} 

Answer 1

我固定在你的函數的語法了一下，現在編譯：

func fanIn(set []<-chan string) <-chan string { 
    c := make(chan string) 


    for i := range set { 
     // here is the main change - you receive from one channel and send to one. 
     // the way you wrote it, you're sending the channel itself to the other channel 
     go func() { for {c <- <- set[i]} }() 
    } 
    return c 
} 

BTW爲可讀性起見，我會寫爲：

go func() { 
     for { 
      x := <-set[i] 
      c <- x 
     } 
    }() 

編輯：您原來的代碼存在在goroutine中使用set[i]的問題，導致它們全部從最後一個通道讀取。這裏有一個固定的版本：

func fanIn(set []<-chan string) <-chan string { 
    c := make(chan string) 

    for i := range set { 
     go func(in <-chan string) { 
      for { 
       x := <- in 
       c <- x 
      } 
     }(set[i]) 
    } 
    return c 
}