Golang如何实现并发安全的计数器-Golang-PHP中文网

Golang如何实现并发安全的计数器

P粉602998670

发布： 2025-10-12 12:20:02

原创

816人浏览过

使用 atomic 或 Mutex 实现 Go 并发安全计数器：atomic 适用于简单增减，性能高；Mutex 适合复杂逻辑。示例中 AtomicCounter 通过 atomic.AddInt64 和 LoadInt64 实现无锁线程安全，最终输出 1000；MutexCounter 使用互斥锁保护 count 字段，支持条件判断等扩展操作。选择依据是场景复杂度：轻量操作选 atomic，复合逻辑选 Mutex。

golang如何实现并发安全的计数器

在Go语言中实现并发安全的计数器，关键在于避免多个goroutine同时修改共享变量导致的数据竞争。可以通过 sync/atomic 包或 sync.Mutex 来实现线程安全的操作。

使用 atomic 实现轻量级原子计数器

atomic 提供了对基本数据类型的原子操作，适合简单的递增、递减场景，性能高且无需锁。

以下是一个基于 int64 的并发安全计数器示例：

package main

import (
    "fmt"
    "sync"
    "sync/atomic"
)

type AtomicCounter struct {
    count int64
}

func (c *AtomicCounter) Inc() {
    atomic.AddInt64(&c.count, 1)
}

func (c *AtomicCounter) Value() int64 {
    return atomic.LoadInt64(&c.count)
}

func main() {
    var counter AtomicCounter
    var wg sync.WaitGroup

    for i := 0; i < 1000; i++ {
        wg.Add(1)
        go func() {
            defer wg.Done()
            counter.Inc()
        }()
    }

    wg.Wait()
    fmt.Println("Final count:", counter.Value()) // 输出: 1000
}

登录后复制

使用 Mutex 保护复杂逻辑

当计数器需要附加逻辑（如限制最大值、条件判断）时，Mutex 更加灵活。

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

腾讯智影-AI数字人

基于AI数字人能力，实现7*24小时AI数字人直播带货，低成本实现直播业务快速增增，全天智能在线直播

查看详情

示例如下：

package main

import (
    "fmt"
    "sync"
)

type MutexCounter struct {
    mu    sync.Mutex
    count int
}

func (c *MutexCounter) Inc() {
    c.mu.Lock()
    defer c.mu.Unlock()
    c.count++
}

func (c *MutexCounter) Value() int {
    c.mu.Lock()
    defer c.mu.Unlock()
    return c.count
}

func main() {
    var counter MutexCounter
    var wg sync.WaitGroup

    for i := 0; i < 1000; i++ {
        wg.Add(1)
        go func() {
            defer wg.Done()
            counter.Inc()
        }()
    }

    wg.Wait()
    fmt.Println("Final count:", counter.Value()) // 输出: 1000
}

登录后复制