ta_shuo

Go by Example - Atomic Counters

翻译自 https://gobyexample.com/

Go by Example

Go is an open source programming language designed for building simple, fast, and reliable software.

Go by Example is a hands-on introduction to Go using annotated example programs. Check out the first example or browse the full list below.

Go by Example: Atomic Counters

golang管理状态的主要机制是通过channel的通信,可以通过之前的worker pools的例子看到。还有一些其他的管理状态的方式,这次我们探究一下sync/atomic包中的可以被多个goroutine访问的atomic counters.

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
package main
import "fmt"
import "time"
import "sync/atomic"
func main() {
// 使用无符号正整数用来表示计数
var ops uint64 = 0
// 为了模拟并发更新,我们启动50个goroutine,每个goroutine对计数自增1,大概1毫秒的耗时
for i := 0; i < 50; i++ {
go func() {
for {
// 使用AddUint64进行原子性的递增操作,将变量的地址作为参数传给该函数
atomic.AddUint64(&ops, 1)
// 睡眠1毫秒,模拟耗时
time.Sleep(time.Millisecond)
}
}()
}
// 睡眠1秒进行若干累加操作
time.Sleep(time.Second)
// 由于计数器可能正在被其他goroutine进行累加操作,为了安全的获取计数值,我们通过LoadUint64函数获取计数器的一个拷贝,将计数器的内存地址给该函数
opsFinal := atomic.LoadUint64(&ops)
fmt.Println("ops: ", opsFinal)
}
1
2
tashuo:golang ta_shuo$ go run atomic-counter.go
ops: 41280

运行该程序,通过返回值可得知计数器累加了大概40000多次

原文链接:Go by Example: Atomic Counters