在 Go 語言中，并發(fā)是最重要的特性之一。通過 goroutine 可以輕松啟動(dòng)成千上萬個(gè)并發(fā)任務(wù)，但隨之而來的問題是：如何安全地共享數(shù)據(jù)、控制執(zhí)行順序以及避免競(jìng)態(tài)條件。這正是 sync 包存在的意義。

sync 是 Go 標(biāo)準(zhǔn)庫中用于 并發(fā)控制與同步 的核心工具，它提供了一系列原語（primitives），用于協(xié)調(diào)多個(gè) goroutine 之間的執(zhí)行關(guān)系。常見組件包括：Mutex、RWMutex、WaitGroup、Once、Cond、Pool 等。

相比 channel，sync 更適合處理共享內(nèi)存并發(fā)模型，尤其是在需要高性能或細(xì)粒度控制時(shí)。

互斥鎖：sync.Mutex

最基礎(chǔ)的同步工具是 Mutex（互斥鎖），用于保證同一時(shí)間只有一個(gè) goroutine 可以訪問共享資源。

package main

import (
	"fmt"
	"sync"
)

var (
	count int
	mu    sync.Mutex
)

func add() {
	mu.Lock()
	count++
	mu.Unlock()
}

func main() {

	for i := 0; i < 1000; i++ {
		go add()
	}

	// 簡(jiǎn)單等待（真實(shí)項(xiàng)目應(yīng)使用 WaitGroup）
	fmt.Scanln()

	fmt.Println(count)
}

如果沒有加鎖，多個(gè) goroutine 同時(shí)修改 count，會(huì)導(dǎo)致數(shù)據(jù)錯(cuò)誤（競(jìng)態(tài)條件）。加鎖后可以保證數(shù)據(jù)安全。

需要注意的是：

• Lock() 和 Unlock() 必須成對(duì)出現(xiàn)
• 通常推薦使用 defer mu.Unlock() 防止遺漏

讀寫鎖：sync.RWMutex

當(dāng)讀操作遠(yuǎn)多于寫操作時(shí)，可以使用讀寫鎖優(yōu)化性能。

var rw sync.RWMutex

// 讀
rw.RLock()
value := count
rw.RUnlock()

// 寫
rw.Lock()
count++
rw.Unlock()

特點(diǎn)：

• 多個(gè)讀可以并發(fā)執(zhí)行
• 寫操作是獨(dú)占的

適用于：

• 緩存系統(tǒng)
• 配置讀取
• 高讀低寫場(chǎng)景

等待組：sync.WaitGroup

WaitGroup 用于等待一組 goroutine 執(zhí)行完成，是并發(fā)編程中最常用的工具之一。

package main

import (
	"fmt"
	"sync"
)

func worker(id int, wg *sync.WaitGroup) {
	defer wg.Done()
	fmt.Println("worker", id)
}

func main() {

	var wg sync.WaitGroup

	for i := 0; i < 5; i++ {
		wg.Add(1)
		go worker(i, &wg)
	}

	wg.Wait()

	fmt.Println("all done")
}

執(zhí)行流程：

• Add(n) 設(shè)置任務(wù)數(shù)量
• 每個(gè) goroutine 完成后調(diào)用 Done()
• Wait() 阻塞直到所有任務(wù)完成

這是 Go 中控制并發(fā)任務(wù)結(jié)束的標(biāo)準(zhǔn)方式。

只執(zhí)行一次：sync.Once

Once 用于保證某段代碼只執(zhí)行一次，常用于初始化操作。

var once sync.Once

func initConfig() {
	fmt.Println("初始化配置")
}

func main() {

	for i := 0; i < 3; i++ {
		go once.Do(initConfig)
	}

	fmt.Scanln()
}

無論調(diào)用多少次 Do()，函數(shù)只會(huì)執(zhí)行一次。

適用于：

• 單例模式
• 配置加載
• 資源初始化

條件變量：sync.Cond

Cond 用于在 goroutine 之間進(jìn)行條件通知，類似“等待-喚醒”機(jī)制。

var mu sync.Mutex
cond := sync.NewCond(&mu)

ready := false

go func() {
	cond.L.Lock()
	for !ready {
		cond.Wait()
	}
	fmt.Println("開始執(zhí)行")
	cond.L.Unlock()
}()

// 模擬準(zhǔn)備完成
cond.L.Lock()
ready = true
cond.Signal()
cond.L.Unlock()

常見方法：

Wait()    等待條件
Signal()  喚醒一個(gè)
Broadcast() 喚醒所有

適用于：

• 生產(chǎn)者消費(fèi)者模型
• 任務(wù)調(diào)度系統(tǒng)

對(duì)象池：sync.Pool

sync.Pool 用于緩存臨時(shí)對(duì)象，減少內(nèi)存分配，提高性能。

var pool = sync.Pool{
	New: func() interface{} {
		return make([]byte, 1024)
	},
}

func main() {

	buf := pool.Get().([]byte)

	// 使用 buf

	pool.Put(buf)
}

特點(diǎn)：

• 自動(dòng)回收（受 GC 管理）
• 減少頻繁分配內(nèi)存

適用于：

• 高頻創(chuàng)建銷毀對(duì)象
• 日志系統(tǒng)
• 序列化處理

Map 并發(fā)安全：sync.Map

Go 原生 map 不是并發(fā)安全的，sync.Map 提供了并發(fā)安全的 map。

var m sync.Map

m.Store("key", "value")

v, ok := m.Load("key")

fmt.Println(v, ok)

常用方法：

Store
Load
Delete
Range

適用于：

• 讀多寫少場(chǎng)景
• 緩存系統(tǒng)

sync 與 channel 對(duì)比

Go 并發(fā)有兩種主流方式：

channel sync

對(duì)比：

簡(jiǎn)單理解：

• channel：通過通信共享數(shù)據(jù)
• sync：通過共享內(nèi)存同步數(shù)據(jù)

實(shí)際開發(fā)中，兩者通常結(jié)合使用。

常見使用場(chǎng)景

在實(shí)際項(xiàng)目中，sync 廣泛應(yīng)用于：

• 并發(fā)計(jì)數(shù)器（Mutex）
• 任務(wù)調(diào)度（WaitGroup）
• 單例初始化（Once）
• 緩存系統(tǒng)（RWMutex / sync.Map）
• 高性能對(duì)象復(fù)用（Pool）

例如實(shí)現(xiàn)一個(gè)并發(fā)安全計(jì)數(shù)器：

type Counter struct {
	mu sync.Mutex
	n  int
}

func (c *Counter) Add() {
	c.mu.Lock()
	defer c.mu.Unlock()
	c.n++
}

常見錯(cuò)誤

忘記 Unlock：

mu.Lock()
// 沒有 Unlock

導(dǎo)致死鎖。

WaitGroup 使用錯(cuò)誤：

wg.Add(1)
wg.Wait()
go func() {
	wg.Done()
}()

可能 panic。

復(fù)制 sync 對(duì)象：

mu2 := mu // 錯(cuò)誤

sync 類型不能復(fù)制。

使用建議

實(shí)際開發(fā)中推薦：

• 簡(jiǎn)單同步用 Mutex
• 讀多寫少用 RWMutex
• 等待任務(wù)用 WaitGroup
• 初始化用 Once
• 高性能緩存用 Pool
• 并發(fā) map 用 sync.Map

同時(shí)注意：

• 盡量避免鎖粒度過大
• 避免死鎖
• 合理設(shè)計(jì)并發(fā)結(jié)構(gòu)

總結(jié)

sync 是 Go 并發(fā)編程的核心工具庫，它提供了一整套用于 協(xié)調(diào) goroutine、保護(hù)共享數(shù)據(jù)、控制執(zhí)行順序 的機(jī)制。

核心組件包括：

• Mutex / RWMutex：數(shù)據(jù)安全
• WaitGroup：任務(wù)同步
• Once：?jiǎn)未螆?zhí)行
• Cond：條件通知
• Pool：性能優(yōu)化
• sync.Map：并發(fā) map

在高并發(fā)系統(tǒng)、Web 服務(wù)、任務(wù)調(diào)度器、緩存系統(tǒng)等場(chǎng)景中，sync 都是不可或缺的基礎(chǔ)工具。熟練掌握 sync，可以讓你的 Go 程序在并發(fā)安全和性能方面達(dá)到更高水平。

以上就是Go并發(fā)同步核心庫syn包的使用深度指南的詳細(xì)內(nèi)容，更多關(guān)于Go syn并發(fā)同步的資料請(qǐng)關(guān)注腳本之家其它相關(guān)文章！

最新評(píng)論