背景
假设我们要开发生产者-消费者模型的代码，一个routine负责生产数据，一个routine负责消费数据，具体代码如下：
错误代码
type MsgStru struct {
msg []int
}
var msgChan chan MsgStru
func sendMsg() {
buf := make([]int, 10)
for i := 0; i < 10; i++ {
buf[0] = i
tmp := MsgStru{msg: buf[:1]}
fmt.Printf("send:%+v\n",tmp)
msgChan <- tmp
}
fmt.Println("finish send")
}
func recvMsg() {
for {
tmp,_ := <-msgChan
fmt.Printf("recv:%+v\n",tmp)
}
}
func main() {
msgChan = make(chan MsgStru, 10)
go sendMsg()
time.Sleep(1 * time.Second)
recvMsg()
}
期望的输出应该是顺序打印0到9，但是实际打印呢？
send:{msg:[0]}
send:{msg:[1]}
send:{msg:[2]}
send:{msg:[3]}
send:{msg:[4]}
send:{msg:[5]}
send:{msg:[6]}
send:{msg:[7]}
send:{msg:[8]}
send:{msg:[9]}
finish send
recv:{msg:[9]}
recv:{msg:[9]}
recv:{msg:[9]}
recv:{msg:[9]}
recv:{msg:[9]}
recv:{msg:[9]}
recv:{msg:[9]}
recv:{msg:[9]}
recv:{msg:[9]}
recv:{msg:[9]}
接受到的数据都是数字9，这是为什么呢？
原因分析
首先看通道中数据的类型表示：
type MsgStru struct { msg []int }
msg是一个slice，slice在go中是一个指针加长度，也就是说传入到通道中的是指向buf的指针，buf是一个全局变量，所以通道中的10个msg的数据都是指向buf的指针，当recvMsg准备读取数据的时候，buf中的数据此时变为了9，所以从通道中读取的10个msg都是9.
修改方案1
将全局slice改为局部slice
func sendMsg() {
buf := make([]int,10)
for i := 0; i < 10; i++ {
buf[0] = i
tmpMsg := make([]int,0)
tmpMsg = append(tmpMsg,buf[:1]...)
tmp := MsgStru{msg: tmpMsg}
fmt.Printf("send:%+v\n",tmp)
msgChan <- tmp
}
fmt.Println("finish send")
}
结果
send:{msg:[0]}
send:{msg:[1]}
send:{msg:[2]}
send:{msg:[3]}
send:{msg:[4]}
send:{msg:[5]}
send:{msg:[6]}
send:{msg:[7]}
send:{msg:[8]}
send:{msg:[9]}
finish send
recv:{msg:[0]}
recv:{msg:[1]}
recv:{msg:[2]}
recv:{msg:[3]}
recv:{msg:[4]}
recv:{msg:[5]}
recv:{msg:[6]}
recv:{msg:[7]}
recv:{msg:[8]}
recv:{msg:[9]}
修改方案2
将slice 改为array
type MsgStru struct {
msg [2]int
}
var msgChan chan MsgStru
func sendMsg() {
var buf [2]int
for i := 0; i < 10; i++ {
buf[0] = i
tmp := MsgStru{msg: buf}
fmt.Printf("send:%+v\n",tmp)
msgChan <- tmp
}
fmt.Println("finish send")
}
结果
send:{msg:[0 0]}
send:{msg:[1 0]}
send:{msg:[2 0]}
send:{msg:[3 0]}
send:{msg:[4 0]}
send:{msg:[5 0]}
send:{msg:[6 0]}
send:{msg:[7 0]}
send:{msg:[8 0]}
send:{msg:[9 0]}
finish send
recv:{msg:[0 0]}
recv:{msg:[1 0]}
recv:{msg:[2 0]}
recv:{msg:[3 0]}
recv:{msg:[4 0]}
recv:{msg:[5 0]}
recv:{msg:[6 0]}
recv:{msg:[7 0]}
recv:{msg:[8 0]}
recv:{msg:[9 0]}
