我有一个看似无辜的软件包,它只能切成 slice 并用RWMutex保护它。但是,当我运行它时,它仍然提示种族状况。我究竟做错了什么? (playground)
type Ids struct {
e []int64
sync.RWMutex
}
func (i *Ids) Read() []int64 {
i.RLock()
defer i.RUnlock()
return i.e
}
func (i *Ids) Append(int int64) {
i.Lock()
defer i.Unlock()
i.e = append(i.e, int)
}
func main() {
t := &Ids{e: make([]int64, 1)}
for i := 0; i < 100; i++ {
go func() {
fmt.Printf("%v\n", t.Read())
}()
go func() {
t.Append(int64(i))
}()
}
time.Sleep(time.Second * 10)
}
当使用
-race
运行时,它返回(除其他外):==================
WARNING: DATA RACE
Read at 0x00c4200a0010 by goroutine 7:
main.main.func2()
.../main.go:38 +0x38
Previous write at 0x00c4200a0010 by main goroutine:
main.main()
.../main.go:32 +0x197
Goroutine 7 (running) created at:
main.main()
.../main.go:37 +0x173
==================
最佳答案
您正在多个goroutine中捕获相同的i
变量。
解决此问题的一种方法是像下面这样修改main for循环:
for i := 0; i < 100; i++ {
i := i # look here
go func() {
fmt.Printf("%v\n", t.Read())
}()
go func() {
t.Append(int64(i))
}()
}
这将确保您在for循环的每次迭代中都在第二个goroutine的闭包中捕获不同的变量。在您的示例中,传递给
i
的t.Append
是与for循环同时增加的i
。我还建议以后运行
go vet
来捕获此类错误。有关更多信息,请参阅Go FAQ中有关此问题的条目,以更详细地介绍:https://golang.org/doc/faq#closures_and_goroutines关于go - RWMutex仍会提高比赛条件吗?,我们在Stack Overflow上找到一个类似的问题:https://stackoverflow.com/questions/49397395/