golang中apend_golang append的并发问题 - Go语言中文社区

golang中apend_golang append的并发问题


先看一段代码

package main

import (

"fmt"

"sync"

)

func main() {

var wg sync.WaitGroup

s := make([]int, 0, 1000)

for i := 0; i < 1000; i++ {

v := i

wg.Add(1)

go func() {

s = append(s, v)

wg.Done()

}()

}

wg.Wait()

fmt.Printf("%vn", len(s))

}

结果

第一次:928

第二次:945

第三次:986

……

多运行几次你就会发现,slice长度并不是1000,而是不停的在变,为什么呢?(如果这个代码你无法重现,你可以尝试将1000改为更大的数字)

因为append并不是并发安全的。

我们举一个简单例子,比如,当A和B两个协程运行append的时候同时发现s[1]这个位置是空的,他们就都会把自己的值放在这个位置,这样他们两个的值就会覆盖,造成数据丢失。

那该怎么写?最简单的方式就是用锁,贴一个例子

package main

import (

"fmt"

"sync"

)

func main() {

var (

wg sync.WaitGroup

mutex sync.Mutex

)

s := make([]int, 0, 1000)

for i := 0; i < 1000; i++ {

v := i

wg.Add(1)

go func() {

mutex.Lock()

s = append(s, v)

mutex.Unlock()

wg.Done()

}()

}

wg.Wait()

fmt.Printf("%vn", len(s))

}

运行一下这个例子就会发现,s的长度总是1000。

更多架构、PHP、GO相关踩坑实践技巧请关注我的公众号:PHP架构师

版权声明:本文来源CSDN,感谢博主原创文章,遵循 CC 4.0 by-sa 版权协议,转载请附上原文出处链接和本声明。
原文链接:https://blog.csdn.net/weixin_39576149/article/details/111850150
站方申明:本站部分内容来自社区用户分享,若涉及侵权,请联系站方删除。
  • 发表于 2021-04-10 23:20:33
  • 阅读 ( 831 )
  • 分类:Go

0 条评论

请先 登录 后评论

官方社群

GO教程

猜你喜欢