在 go 的并发编程中,同步机制是确保共享数据完整性的关键。它提供了多种内置类型,包括:互斥锁(mutex):提供对共享数据的独占访问;读写锁:允许多个 goroutine 同时读取但只能一个 goroutine 写入数据;条件变量:用于协调 goroutine 间的等待和唤醒。
Go 函数并发编程中的同步机制
在 Go 的并发编程中,当多个 goroutine(Golang 中的轻量级线程)同时操作共享数据时,就需要同步机制来确保数据的完整性。Go 提供了多种内置的同步类型,用于协调 goroutine 的访问。
1. Mutex
Mutex(互斥锁)是一种最基本的同步机制,它提供了对共享数据的独占访问。一次只有一个 goroutine 可以持有 mutex,从而确保共享数据的原子操作。
import (
"fmt"
"sync"
)
func main() {
var count int
var mu sync.Mutex
for i := 0; i < 1000; i++ {
go func(i int) {
mu.Lock()
count++
mu.Unlock()
}(i)
}
fmt.Println("Count:", count) // 输出:1000
}
2. 读写锁
读写锁是一种高级的同步机制,它允许多个 goroutine 同时读取共享数据,但一次只能有一个 goroutine 写入共享数据。这可以提高并发性能,同时确保数据的完整性。
import (
"fmt"
"sync"
)
func main() {
var count int
var rw sync.RWMutex
for i := 0; i < 1000; i++ {
go func(i int) {
rw.RLock()
fmt.Println("Reading:", count)
rw.RUnlock()
}(i)
go func(i int) {
rw.Lock()
count++
fmt.Println("Writing:", count)
rw.Unlock()
}(i)
}
}
3. 条件变量
条件变量(cond)用于协调 goroutine 间的等待和唤醒。当某个 goroutine 满足特定条件时,它可以唤醒等待该条件的 goroutine。
import (
"fmt"
"sync"
)
func main() {
var cond sync.Cond
var signal bool
sync.Mutex.Lock(&l)
for !signal {
cond.Wait(&l)
}
// ... 执行需要信号的代码 ...
sync.Mutex.Unlock(&l)
}