”工欲善其事,必先利其器。“—孔子《论语.录灵公》
首页 > 编程 > 为什么 Go 中的“append”函数对于并发访问不是线程安全的?

为什么 Go 中的“append”函数对于并发访问不是线程安全的?

发布于2024-11-11
浏览:276

Why is `append` function not thread-safe for concurrent access in Go?

追加函数:并发访问不是线程安全的

当同时使用 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