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

在Go语言中实现并发安全的计数器,关键在于避免多个goroutine同时修改共享变量导致的数据竞争。虽然可以通过互斥锁(sync.Mutex)来保护计数操作,但更高效、更推荐的方式是使用sync/atomic包提供的原子操作。
使用 atomic 实现并发安全计数器
Go 的 sync/atomic 包支持对整型变量的原子增减、加载、存储等操作,适合轻量级计数场景,性能优于锁机制。
以下是一个基于 int64 的并发安全计数器实现:
package main
立即学习“go语言免费学习笔记(深入)”;
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 实现计数器是最简洁高效的实践方式。
以上就是Golang如何实现并发安全的计数器_Golang计数器并发安全实现实践的详细内容,更多请关注创想鸟其它相关文章!
版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。
如发现本站有涉嫌抄袭侵权/违法违规的内容, 请发送邮件至 chuangxiangniao@163.com 举报,一经查实,本站将立刻删除。
发布者:程序猿,转转请注明出处:https://www.chuangxiangniao.com/p/1421145.html
微信扫一扫
支付宝扫一扫