Go append并发问题

ztime1 · · 1116 次点击 · · 开始浏览    
这是一个创建于 的文章,其中的信息可能已经有所发展或是发生改变。

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("%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。

有疑问加站长微信联系(非本文作者)

本文来自:简书

感谢作者:ztime1

查看原文:Go append并发问题

入群交流(和以上内容无关):加入Go大咖交流群,或添加微信:liuxiaoyan-s 备注:入群;或加QQ群:692541889

1116 次点击  
加入收藏 微博
暂无回复
添加一条新回复 (您需要 登录 后才能回复 没有账号 ?)
  • 请尽量让自己的回复能够对别人有帮助
  • 支持 Markdown 格式, **粗体**、~~删除线~~、`单行代码`
  • 支持 @ 本站用户;支持表情(输入 : 提示),见 Emoji cheat sheet
  • 图片支持拖拽、截图粘贴等方式上传