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

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

在 for 循环中并发使用 goroutine 向切片追加元素时，出现异常数据中可能会出现。结果切片中可能会出现丢失或空白数据，这表明存在潜在的数据竞争。

发生这种情况是因为在 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 <- tmpObj
    }(myObject)
}
go func() {
    for {
        tmpObj := <-appendChan
        destSlice = append(destSlice, tmpObj)
    }
}()
wg.Wait()

以上是为什么 Go 中的'append”函数对于并发访问不是线程安全的？的详细内容。更多信息请关注PHP中文网其他相关文章！