Go语言并发安全有哪些例子

avatar
作者
猴君
阅读量:0

Go语言的并发安全体现在多个方面,以下是一些并发安全的例子:

  1. sync.Mutex互斥锁:这是Go语言提供的用于保护共享资源的同步原语。当一个goroutine持有一个互斥锁时,其他goroutine不能获取该锁,从而保证了同一时间只有一个goroutine能够访问被保护的资源。例如:
var mu sync.Mutex var counter int  func increment() {     mu.Lock()     defer mu.Unlock()     counter++ } 
  1. sync.RWMutex读写锁:这是一种特殊的互斥锁,允许多个goroutine同时读取共享资源,但在写入时会阻塞其他goroutine的读取和写入操作。这在读操作远多于写操作的场景下非常有用。例如:
var rwMu sync.RWMutex var sharedData map[string]string  func readData(key string) string {     rwMu.RLock()     defer rwMu.RUnlock()     return sharedData[key] }  func writeData(key, value string) {     rwMu.Lock()     defer rwMu.Unlock()     sharedData[key] = value } 
  1. sync.WaitGroup等待组:用于等待一组goroutine完成执行。通过调用Add()方法增加等待的goroutine数量,每个goroutine在执行完毕前会调用Done()方法减少计数,而主goroutine可以通过Wait()方法阻塞等待所有goroutine完成。例如:
var wg sync.WaitGroup  func worker(id int) {     defer wg.Done()     // 执行任务 }  func main() {     for i := 0; i < 5; i++ {         wg.Add(1)         go worker(i)     }     wg.Wait() } 
  1. channel通道:Go语言的channel是一种内置的数据结构,用于在不同的goroutine之间安全地传递数据。channel内部处理了必要的锁定和同步,因此可以安全地在多个goroutine之间传递消息或数据。例如:
ch := make(chan int)  go func() {     ch <- 42 }()  value := <-ch fmt.Println(value) // 输出:42 

这些例子展示了Go语言中并发安全的常见实现方式。当然,Go语言还提供了许多其他并发原语和工具,如sync.Oncesync.Map等,可以根据具体需求选择使用。

广告一刻

为您即时展示最新活动产品广告消息,让您随时掌握产品活动新动态!