第9章：并发数据结构和同步原语
在GO语言中，除了基本的并发模型如Goroutines和通道（channels），还有一系列并发数据结构和同步原语可以帮助开发者更安全、高效地处理并发操作。本章将详细介绍这些并发工具的使用方法和最佳实践。
9.1 并发数据结构：Once
sync.Once是一个可以保证在多个Goroutine中只执行一次操作的同步原语。它常用于初始化资源或执行一次性设置。
var (
once sync.Once
result int
)
func calculateResult() {
result = 42 // 假设这是一些昂贵的计算或初始化过程
}
func SomeFunction() {
once.Do(calculateResult)
fmt.Println(result) // 输出: 42
}
9.2 并发数据结构：Cond
sync.Cond是一个条件变量，它可以让一组Goroutine在某个条件成立时被唤醒。
type Data struct {
sync.Mutex // 保护数据的互斥锁
value int
waiting int // 等待条件的Goroutine数量
}
func (d *Data) Set(val int) {
d.Lock()
for d.waiting > 0 {
d.value = val
d.Unlock()
return // 退出当前Goroutine
}
d.value = val
d.Unlock()
}
func (d *Data) Wait() int {
d.Lock()
for d.value == 0 {
d.waiting++
d.Unlock()
// 等待条件成立
}
d.Lock()
d.waiting--
d.Unlock()
return d.value
}
9.3 并发数据结构：Map
sync.Map是一个并发安全的映射数据结构，适用于高并发环境下的键值存储。
var m sync.Map
func main() {
// 并发安全的存储
m.Store("key1", "value1")
// 并发安全的加载
if value, ok := m.Load("key1"); ok {
fmt.Println(value) // 输出: value1
}
// 并发安全的删除
m.Delete("key1")
}
### 9.4 同步原语：WaitGroup
`sync.WaitGroup`是用于等待一组Goroutine完成的同步工具。
```go
var wg sync.WaitGroup
func worker(id int) {
defer wg.Done() // 通知WaitGroup该worker已完成
fmt.Println("Worker", id, "done")
}
func main() {
for i := 1; i <= 5; i++ {
wg.Add(1) // 增加WaitGroup的计数
go worker(i)
}
wg.Wait() // 等待所有worker完成
fmt.Println("All workers done")
}
9.5 并发编程的最佳实践
- 最小化锁的使用：尽量减少锁的使用，以避免不必要的性能开销。
- 使用通道进行通信：通道是Goroutines间通信的首选方式，它可以帮助避免复杂的锁机制。
- 合理使用并发数据结构：
sync.Map、sync.Once和sync.Cond等并发数据结构提供了无锁的并发操作，适用于不同的场景。 - 控制并发度：通过限制并发数来避免过度并发导致的资源竞争和系统过载。
- 错误处理：并发环境下的错误处理尤为重要，确保及时检测并处理错误，避免影响整个程序的运行。
通过本章的学习，你将掌握GO语言中并发数据结构和同步原语的使用方法，以及并发编程的最佳实践。这些工具和实践将帮助你编写出更安全、更高效的并发程序，充分利用GO语言在并发处理方面的优势。
