内容简介:由于 slice/map 是引用类型,golang函数是传值调用,所用参数副本依然是原来的 slice, 并发访问同一个资源会导致竟态条件。看下面这段代码:真实的输出并没有达到我们的预期,len(slice) < n。 问题出在哪?我们都知道slice是对数组一个连续片段的引用,当slice长度增加的时候,可能底层的数组会被换掉。当出在换底层数组之前,切片同时被多个goroutine拿到,并执行append操作。那么很多goroutine的append结果会被覆盖,导致n个gouroutine append
由于 slice/map 是引用类型,golang函数是传值调用,所用参数副本依然是原来的 slice, 并发访问同一个资源会导致竟态条件。
看下面这段代码:
package main import ( "fmt" "sync" ) func main() { var ( slc = []int{} n = 10000 wg sync.WaitGroup ) wg.Add(n) for i := 0; i < n; i++ { go func() { slc = append(slc, i) wg.Done() }() } wg.Wait() fmt.Println("len:", len(slc)) fmt.Println("done") } // Output: len: 8586 done 复制代码
真实的输出并没有达到我们的预期,len(slice) < n。 问题出在哪?我们都知道slice是对数组一个连续片段的引用,当slice长度增加的时候,可能底层的数组会被换掉。当出在换底层数组之前,切片同时被多个goroutine拿到,并执行append操作。那么很多goroutine的append结果会被覆盖,导致n个gouroutine append后,长度小于n。
那么如何解决这个问题呢? map 在 go 1.9 以后官方就给出了 sync.map 的解决方案,但是如果要并发访问 slice 就要自己好好设计一下了。下面提供两种方式,帮助你解决这个问题。
方案 1: 加锁 :closed_lock_with_key:
func main() { slc := make([]int, 0, 1000) var wg sync.WaitGroup var lock sync.Mutex for i := 0; i < 1000; i++ { wg.Add(1) go func(a int) { defer wg.Done() // 加:closed_lock_with_key: lock.Lock() defer lock.Unlock() slc = append(slc, a) }(i) wg.Wait() } fmt.Println(len(slc)) } 复制代码
优点是比较简单,适合对性能要求不高的场景。
方案 2: 使用 channel 串行化操作
type ServiceData struct { ch chan int // 用来 同步的channel data []int // 存储数据的slice } func (s *ServiceData) Schedule() { // 从 channel 接收数据 for i := range s.ch { s.data = append(s.data, i) } } func (s *ServiceData) Close() { // 最后关闭 channel close(s.ch) } func (s *ServiceData) AddData(v int) { s.ch <- v // 发送数据到 channel } func NewScheduleJob(size int, done func()) *ServiceData { s := &ServiceData{ ch: make(chan int, size), data: make([]int, 0), } go func() { // 并发地 append 数据到 slice s.Schedule() done() }() return s } func main() { var ( wg sync.WaitGroup n = 1000 ) c := make(chan struct{}) // new 了这个 job 后,该 job 就开始准备从 channel 接收数据了 s := NewScheduleJob(n, func() { c <- struct{}{} }) wg.Add(n) for i := 0; i < n; i++ { go func(v int) { defer wg.Done() s.AddData(v) }(i) } wg.Wait() s.Close() <-c fmt.Println(len(s.data)) } 复制代码
实现相对复杂,优点是性能很好,利用了channel的优势
以上代码都有比较详细的注释,就不展开讲了。
欢迎关注我们的微信公众号,每天学习Go知识
以上所述就是小编给大家介绍的《并发访问 slice 如何做到优雅和安全?》,希望对大家有所帮助,如果大家有任何疑问请给我留言,小编会及时回复大家的。在此也非常感谢大家对 码农网 的支持!
猜你喜欢:- 水平分库如何做到平滑扩展
- 如何做到测试场景不遗漏?
- 如何做到系统稳定——TL视角
- For OpenStack,Veritas做到了!
- 不在意他人评价,真的能做到吗?
- 如何做到每秒接收 100 万个数据包
本站部分资源来源于网络,本站转载出于传递更多信息之目的,版权归原作者或者来源机构所有,如转载稿涉及版权问题,请联系我们。
Modeling the Internet and the Web
Pierre Baldi、Paolo Frasconi、Padhraic Smyth / Wiley / 2003-7-7 / USD 115.00
Modeling the Internet and the Web covers the most important aspects of modeling the Web using a modern mathematical and probabilistic treatment. It focuses on the information and application layers, a......一起来看看 《Modeling the Internet and the Web》 这本书的介绍吧!