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

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

sync.Mutex互斥锁：这是Go语言提供的用于保护共享资源的同步原语。当一个goroutine持有一个互斥锁时，其他goroutine不能获取该锁，从而保证了同一时间只有一个goroutine能够访问被保护的资源。例如：

var mu sync.Mutex
var counter int

func increment() {
    mu.Lock()
    defer mu.Unlock()
    counter++
}

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
}

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()
}

channel通道：Go语言的channel是一种内置的数据结构，用于在不同的goroutine之间安全地传递数据。channel内部处理了必要的锁定和同步，因此可以安全地在多个goroutine之间传递消息或数据。例如：

ch := make(chan int)

go func() {
    ch <- 42
}()

value := <-ch
fmt.Println(value) // 输出：42

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

0 赞

0 踩