如果通过Go中的通道发送大型结构,它是否真的在goroutines之间复制?
例如,在下面的代码中,Go实际上会复制goroutines生产者和消费者之间的所有largeStruct数据吗?
package main import ( "fmt" "sync" ) type largeStruct struct { buf [10000]int } func main() { ch := make(chan largeStruct) wg := &sync.WaitGroup{} wg.Add(2) go consumer(wg,ch) go producer(wg,ch) wg.Wait() } func producer(wg *sync.WaitGroup,output chan<- largeStruct) { defer wg.Done() for i := 0; i < 5; i++ { fmt.Printf("producer: %d\n",i) output <- largeStruct{} } close(output) } func consumer(wg *sync.WaitGroup,input <-chan largeStruct) { defer wg.Done() i := 0 LOOP: for { select { case _,ok := <-input: if !ok { break LOOP } fmt.Printf("consumer: %d\n",i) i++ } } }
是的,一切都是Go中的副本,您可以通过更改频道使用指针(aka chan * largeStruct)轻松解决这个问题.
// demo:http://play.golang.org/p/CANxwt8s2B
正如您所看到的,指向v.buf的指针在每种情况下都是不同的,但是如果将其更改为chan * largeStruct,则指针将是相同的.
@LucasJones提供了一个更容易理解的例子:https://play.golang.org/p/-VFWCgOnh0
正如@nos指出的那样,如果你在发送之后修改两个goroutine中的值,那么就有可能出现竞争.