在Go语言中,处理切片并发访问的关键是使用同步原语,如互斥锁(Mutex)或读写锁(RWMutex)。这样可以确保在同一时间只有一个协程(goroutine)能够访问和修改切片。下面是一个使用互斥锁处理并发访问的示例:
package main
import (
"fmt"
"sync"
)
type SafeSlice struct {
slice []int
mu sync.Mutex
}
func (s *SafeSlice) Add(value int) {
s.mu.Lock()
defer s.mu.Unlock()
s.slice = append(s.slice, value)
}
func (s *SafeSlice) Get(index int) int {
s.mu.Lock()
defer s.mu.Unlock()
return s.slice[index]
}
func main() {
safeSlice := SafeSlice{
slice: []int{},
}
var wg sync.WaitGroup
wg.Add(3)
go func() {
defer wg.Done()
safeSlice.Add(1)
}()
go func() {
defer wg.Done()
safeSlice.Add(2)
}()
go func() {
defer wg.Done()
fmt.Println("Value at index 0:", safeSlice.Get(0))
}()
wg.Wait()
}
在这个示例中,我们创建了一个名为SafeSlice
的结构体,它包含一个整数切片和一个互斥锁。我们为Add
和Get
方法添加了互斥锁,以确保在并发访问时不会发生数据竞争。
在main
函数中,我们创建了三个协程:一个用于向切片添加元素,另外两个分别用于获取切片中的元素。通过使用互斥锁,我们可以确保在任何时候只有一个协程能够访问和修改切片。最后,我们使用sync.WaitGroup
等待所有协程完成。