分享
golang append的并发问题
woodane · · 6429 次点击 · · 开始浏览这是一个创建于 的文章,其中的信息可能已经有所发展或是发生改变。
先看一段代码
ackage 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("%v\n", len(s))
}结果
第一次:928
第二次:945
第三次:986
......多运行几次你就会发现,slice长度并不是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("%v\n", len(s))
}运行一下这个例子就会发现,s的长度总是1000。
有疑问加站长微信联系(非本文作者)
入群交流(和以上内容无关):加入Go大咖交流群,或添加微信:liuxiaoyan-s 备注:入群;或加QQ群:692541889
关注微信6429 次点击
上一篇:设计模式(golang)
下一篇:go grpc安装
添加一条新回复
(您需要 后才能回复 没有账号 ?)
- 请尽量让自己的回复能够对别人有帮助
- 支持 Markdown 格式, **粗体**、~~删除线~~、
`单行代码` - 支持 @ 本站用户;支持表情(输入 : 提示),见 Emoji cheat sheet
- 图片支持拖拽、截图粘贴等方式上传
收入到我管理的专栏 新建专栏
先看一段代码
ackage 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("%v\n", len(s))
}结果
第一次:928
第二次:945
第三次:986
......多运行几次你就会发现,slice长度并不是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("%v\n", len(s))
}运行一下这个例子就会发现,s的长度总是1000。