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

使用atomic实现并发安全计数器,通过原子操作避免数据竞争。定义Counter结构体,利用atomic.AddInt64和atomic.LoadInt64方法实现安全的增减与读取,性能优于互斥锁。

在Go语言中实现并发安全的计数器,关键在于避免多个goroutine同时修改共享变量导致的数据竞争。虽然可以通过互斥锁(sync.Mutex)来保护计数操作,但更高效、更推荐的方式是使用sync/atomic包提供的原子操作。

使用 atomic 实现并发安全计数器

Go 的 sync/atomic 包支持对整型变量的原子增减、加载、存储等操作,适合轻量级计数场景,性能优于锁机制。

以下是一个基于 int64 的并发安全计数器实现:

package main

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

type Counter struct {
   count int64
}

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

func (c *Counter) Dec() {
   atomic.AddInt64(&c.count, -1)
}

func (c *Counter) Load() int64 {
   return atomic.LoadInt64(&c.count)
}

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

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

   wg.Wait()
   fmt.Println("最终计数值:", counter.Load()) // 输出: 1000
}

使用 Mutex 作为替代方案

当计数逻辑更复杂(如条件判断后才递增),或需要组合多个操作时,sync.Mutex 更合适。

示例:

type SafeCounter struct {
   mu sync.Mutex
   count int
}

func (sc *SafeCounter) Inc() {
   sc.mu.Lock()
   defer sc.mu.Unlock()
   sc.count++
}

func (sc *SafeCounter) Get() int {
   sc.mu.Lock()
   defer sc.mu.Unlock()
   return sc.count
}

这种方式开销略大,但在需要临界区保护多行代码时更灵活。

性能对比与选择建议

对于简单的计数场景,优先使用 atomic。它无锁、效率高,适用于高频读写。

  • atomic 操作通常比 Mutex 快几倍到一个数量级
  • atomic 只能用于基本类型(int32, int64, uint32 等)的简单操作
  • Mutex 更适合结构体字段组合操作或复杂逻辑控制

可通过 go test -race 检测数据竞争,确保并发安全。

基本上就这些。日常开发中,用 atomic 实现计数器是最简洁高效的实践方式。