在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
等待所有协程完成。