如何将通道切片作为可变参数传递给函数？

Question

如果我有一个函数，它的一些只读渠道（例如用于信道集合），我为什么不能打电话与渠道的片这个功能，如

package main 
func f(in ...<-chan int) { 
    // do something 
} 

func main() { 
    chList := []chan int{make(chan int), make(chan int)} 
    f(make(chan int), make(chan int)) // works 
    f(chList...) // cannot use chList (type []chan int) as type []<-chan int in argument to f 
} 

看来我错过了一些基本的东西，但我无法弄清楚什么。如果该功能不能使用单向通道，为什么在第一种情况下不能使用它？

Answer 1

你错过了方向，

package main 
func f(in ...<-chan int) { 
    // do something 
} 

func main() { 
    chList := []<-chan int{make(<-chan int), make(<-chan int)} 
    f(make(<-chan int), make(<-chan int)) 
    f(chList...) 
} 

Answer 2

好了，现在看来，这具有的slice covariance in golack做。我的解决方案是将“非定向”通道切片转换为一段只读通道。下面是一个完整的例子：

package main 

import (
    "fmt" 
    "time" 
) 

func f(in ...<-chan int) chan int { 
    fmt.Println("number of channels:", len(in)) 
    out := make(chan int) 
    for _, ch := range in { 
     go func(ch <-chan int) { 
      for i := range ch { 
       out <- i 
      } 
     }(ch) 
    } 
    return out 
} 

func chConv(channels ...chan int) []<-chan int { 
    ret := make([]<-chan int, len(channels)) 
    for n, ch := range channels { 
     ret[n] = ch 
    } 
    return ret 
} 

func main() { 
    chList := []chan int{make(chan int), make(chan int)} 
    roChans := chConv(chList...) 
    agg := f(roChans...) 
    go func() { 
     for i := range agg { 
      fmt.Println("got:", i) 
     } 
    }() 
    for i := 0; i < 10; i++ { 
     for _, ch := range chList { 
      ch <- i 
     } 
    } 
    time.Sleep(1 * time.Second) 
}