如何在Golang中使用sync包实现并发控制-Golang-PHP中文网

如何在Golang中使用sync包实现并发控制

P粉602998670

发布： 2025-10-10 09:53:01

原创

151人浏览过

使用sync.Mutex可保护共享资源，防止多goroutine并发访问导致数据竞争，通过加锁确保同一时间仅一个goroutine操作变量。

如何在golang中使用sync包实现并发控制

在Golang中，sync 包是实现并发控制的核心工具之一。它提供了多种同步原语，帮助开发者安全地管理多个goroutine之间的资源共享与执行顺序。掌握这些机制，能有效避免竞态条件、数据竞争等问题。

使用 sync.Mutex 保护共享资源

当多个goroutine需要访问同一个变量或结构体时，必须通过互斥锁来保证同一时间只有一个goroutine可以操作该资源。

示例：多个goroutine同时增加计数器

var counter int
var mu sync.Mutex

func worker() {
    for i := 0; i < 1000; i++ {
        mu.Lock()
        counter++
        mu.Unlock()
    }
}

func main() {
    var wg sync.WaitGroup
    for i := 0; i < 5; i++ {
        wg.Add(1)
        go func() {
            defer wg.Done()
            worker()
        }()
    }
    wg.Wait()
    fmt.Println("最终计数:", counter) // 输出 5000
}

登录后复制

关键点：

立即学习“go语言免费学习笔记（深入）”；

每次修改 counter 前调用 mu.Lock()，操作完成后立即解锁
确保 Unlock 在 defer 中调用，防止死锁

使用 sync.RWMutex 提升读性能

对于读多写少的场景，RWMutex 允许多个读操作并发进行，仅在写时独占访问。

示例：缓存读写控制

android rtsp流媒体播放介绍中文WORD版

本文档主要讲述的是android rtsp流媒体播放介绍；实时流协议（RTSP）是应用级协议，控制实时数据的发送。RTSP提供了一个可扩展框架，使实时数据，如音频与视频，的受控、点播成为可能。数据源包括现场数据与存储在剪辑中数据。该协议目的在于控制多个数据发送连接，为选择发送通道，如UDP、组播UDP与TCP，提供途径，并为选择基于RTP上发送机制提供方法。希望本文档会给有需要的朋友带来帮助；感兴趣的朋友可以过来看看

查看详情

var config map[string]string
var rwMu sync.RWMutex

func readConfig(key string) string {
    rwMu.RLock()
    defer rwMu.RUnlock()
    return config[key]
}

func updateConfig(key, value string) {
    rwMu.Lock()
    defer rwMu.Unlock()
    config[key] = value
}

登录后复制

说明：

读操作使用 RLock/RLock
写操作仍需普通 Lock/Unlock
适用于配置加载、状态查询等高频读取场景

使用 sync.WaitGroup 等待所有任务完成

WaitGroup 用于等待一组并发任务结束，常配合goroutine使用。

典型结构：

var wg sync.WaitGroup

for _, item := range items {
    wg.Add(1)
    go func(val interface{}) {
        defer wg.Done()
        process(val)
    }(item)
}
wg.Wait() // 阻塞直到所有 Done 被调用

登录后复制

注意：

Add 必须在goroutine启动前调用，否则可能产生竞态
传递循环变量时要复制值或作为参数传入闭包

使用 sync.Once 确保初始化只执行一次

某些初始化操作（如加载配置、连接数据库）只需运行一次，Once.Do() 可保证线程安全的单次执行。

var once sync.Once
var instance *Database

func GetDB() *Database {
    once.Do(func() {
        instance = connectToDatabase()
    })
    return instance
}

登录后复制

无论多少goroutine同时调用 GetDB()，内部函数只会执行一次。

基本上就这些常用模式。合理组合 Mutex、WaitGroup 和 Once，就能应对大多数并发控制需求。关键是理解每种原语的设计目的，并避免过度同步影响性能。

以上就是如何在Golang中使用sync包实现并发控制的详细内容，更多请关注php中文网其它相关文章！