追加函数:并发访问不是线程安全的
当同时使用 goroutine 将元素追加到 for 循环中的切片时,出现异常数据中可能会出现。结果切片中可能会出现丢失或空白数据,表明潜在的数据竞争。
发生这种情况是因为在 Go 中,没有值对于同时读写来说是天生安全的。由切片头表示的切片也不例外。提供的代码由于并发访问而出现数据争用:
destSlice := make([]myClass, 0) var wg sync.WaitGroup for _, myObject := range sourceSlice { wg.Add(1) go func(closureMyObject myClass) { defer wg.Done() var tmpObj myClass tmpObj.AttributeName = closureMyObject.AttributeName destSlice = append(destSlice, tmpObj) }(myObject) } wg.Wait()
要验证数据竞争是否存在,请执行以下命令:
go run -race play.go
输出将提醒您数据竞争竞赛:
WARNING: DATA RACE ...
解决并发问题
要解决此问题,请使用sync.Mutex 保护对 destSlice 的写入访问:
var ( mu = &sync.Mutex{} destSlice = make([]myClass, 0) ) var wg sync.WaitGroup for _, myObject := range sourceSlice { wg.Add(1) go func(closureMyObject myClass) { defer wg.Done() var tmpObj myClass tmpObj.AttributeName = closureMyObject.AttributeName mu.Lock() destSlice = append(destSlice, tmpObj) mu.Unlock() }(myObject) } wg.Wait()
或者,考虑使用通道异步处理追加:
var ( appendChan = make(chan myClass) destSlice = make([]myClass, 0) ) var wg sync.WaitGroup for _, myObject := range sourceSlice { wg.Add(1) go func(closureMyObject myClass) { defer wg.Done() var tmpObj myClass tmpObj.AttributeName = closureMyObject.AttributeName appendChan
免责声明: 提供的所有资源部分来自互联网,如果有侵犯您的版权或其他权益,请说明详细缘由并提供版权或权益证明然后发到邮箱:[email protected] 我们会第一时间内为您处理。
Copyright© 2022 湘ICP备2022001581号-3