可以去通道为多次读取保留一个值[重复]

Question

我了解通道的常规行为是在读取后清空。有没有办法在不从通道中删除值的情况下为多次读取保留一个无缓冲的通道值？

例如，我有一个 goroutine，它生成单个数据供多个下游 go 例程使用。我不想创建多个通道或使用缓冲通道，这需要我复制源数据（我什至不知道我需要多少副本）。实际上，我希望能够执行以下操作：

main{
   ch := make(ch chan dType)

   ch <- sourceDataGenerator()
   for _,_ := range DynamicRange{
      go TargetGoRoutine(ch)
   }
   close(ch)       // would want this to remove the value and the channel
}
func(ch chan dType) TargetGoRoutine{
   targetCollection <- ch    // want to keep the channel value after read
}

编辑 有些人认为这是一个重复的问题。也许，但不确定。正如 n-canter 指出的那样，这里的解决方案最终看起来很简单。它所需要的只是让每个 go 例程通过在使用后将数据放回通道来“回收”数据。没有一个所谓的“重复”提供了这个解决方案。这是一个示例：

package main
import (
  "fmt"
  "sync"
)

func main() {
 c := make(chan string)
 var wg sync.WaitGroup
    wg.Add(5)

 for i := 0; i < 5; i++ {
    go func(i int) {
        wg.Done()
        msg := <-c
        fmt.Printf("Data:%s, From go:%d\n", msg, i)
        c <-msg

    }(i)
}

   c <- "Original"
   wg.Wait()
   fmt.Println(<-c)
}

https://play.golang.org/p/EXBbf1_icG

Answer 1

您可以在读取后将值读回通道，但是您的所有 gouroutine 将顺序读取共享值，并且您需要一些同步原语以使最后一个 goroutine 不阻塞。

据我所知，您可以使用单个频道进行广播的唯一情况是关闭它。在这种情况下，所有读者都会收到通知。

如果你不想复制大数据，也许你最好使用一些全局变量。但是要小心使用，因为它违反了 golang 规则：“不要通过共享内存进行通信；通过通信来共享内存。”

也看这个问题How to broadcast message using channel