当所有通道关闭时突然出现select语句

Question

我有两个独立产生数据的goroutine，每个goroutine将它们发送到一个通道。在我的主要例程中，我希望在输入时使用这些输出中的每一个，但不关心它们的输入顺序。每个通道在耗尽输出时都会关闭。尽管select语句是像这样独立消费输入的最好语法，但我还没有看到一个简洁的方式来循环每个通道，直到两个通道都关闭。

for { 
    select { 
    case p, ok := <-mins: 
     if ok { 
      fmt.Println("Min:", p) //consume output 
     } 
    case p, ok := <-maxs: 
     if ok { 
      fmt.Println("Max:", p) //consume output 
     } 
    //default: //can't guarantee this won't happen while channels are open 
    // break //ideally I would leave the infinite loop 
       //only when both channels are done 
    } 
} 

我能想到做到最好如下（只是勾勒，可能有编译错误）：

for { 
    minDone, maxDone := false, false 
    select { 
    case p, ok := <-mins: 
     if ok { 
      fmt.Println("Min:", p) //consume output 
     } else { 
      minDone = true 
     } 
    case p, ok := <-maxs: 
     if ok { 
      fmt.Println("Max:", p) //consume output 
     } else { 
      maxDone = true 
     } 
    } 
    if (minDone && maxDone) {break} 
} 

但这样子，如果你有超过它的工作会得到站不住脚两个或三个频道。我唯一知道的另一种方法是在switch语句中使用一个timout案例，该案例要么足够小，以避免提前退出，要么将太多停机时间注入最终的循环中。有没有更好的方法来测试select语句中的通道？

Answer 1

您的示例解决方案无法正常工作。一旦它们中的一个关闭，它将立即可用于通信。这意味着你的公司永远不会屈服，其他渠道可能永远不会准备好。你会有效地进入一个无限循环。我举了一个例子来说明这里的效果：http://play.golang.org/p/rOjdvnji49

那么，我该如何解决这个问题呢？一个零通道永远不会准备好进行通信。因此，每次遇到一个关闭的频道时，您都可以删除该频道，确保它不会再次被选中。这里可运行的例子：http://play.golang.org/p/8lkV_Hffyj

for { 
    select { 
    case x, ok := <-ch: 
     fmt.Println("ch1", x, ok) 
     if !ok { 
      ch = nil 
     } 
    case x, ok := <-ch2: 
     fmt.Println("ch2", x, ok) 
     if !ok { 
      ch2 = nil 
     } 
    } 

    if ch == nil && ch2 == nil { 
     break 
    } 
} 

至于害怕它变得笨拙，我不认为它会。你很少有频道一次去太多的地方。这很少会出现，我的第一个建议就是处理它。如果将10个通道与nil进行比较，那么很长的一条语句并不是尝试处理选择中的10个通道的最糟糕的部分。

Answer 2

在某些情况下关闭很好，但不是全部。我不会在这里使用它。相反，我只想用一个做渠道：

for n := 2; n > 0; { 
    select { 
    case p := <-mins: 
     fmt.Println("Min:", p) //consume output 
    case p := <-maxs: 
     fmt.Println("Max:", p) //consume output 
    case <-done: 
     n-- 
    } 
} 

完整的工作示例在操场：http://play.golang.org/p/Cqd3lg435y

Answer 3

为什么不使用够程？随着你的频道关闭，整个事情变成一个简单的范围循环。

func foo(c chan whatever, prefix s) { 
     for v := range c { 
       fmt.Println(prefix, v) 
     } 
} 

// ... 

go foo(mins, "Min:") 
go foo(maxs, "Max:") 

Answer 4

我写了一个包，它提供了解决这个问题的函数（其中数人）：

https://github.com/eapache/channels

https://godoc.org/github.com/eapache/channels

退房的Multiplex功能。它使用反射来缩放到任意数量的输入通道。