分享
Go原子计数
kc87654321 · · 5198 次点击 · · 开始浏览这是一个创建于 的文章,其中的信息可能已经有所发展或是发生改变。
通过原子计数可以在多线程情况下,对同一个数值进行加减操作,一般用于状态同步。
先看代码:
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
31
32
33
34
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
31
32
33
34
package main
import "fmt"
import "time"
import "sync/atomic"
import "runtime"
func main() {
// 定义一个整数
var ops uint64 = 0
// 使用50个线程给ops累加数值
for i := 0; i < 50; i++ {
go func() {
for {
// 每次加1
atomic.AddUint64(&ops, 1)
// 这个函数用于时间片切换
//可以理解为高级版的time.Sleep()
//避免前面的for循环将CPU时间片都卡在一个线程里,使得其它线程没有执行机会
runtime.Gosched()
}
}()
}
//停一秒,上面50个线程有1秒的执行时间
time.Sleep(time.Second)
// 获取结果
opsFinal := atomic.LoadUint64(&ops)
fmt.Println("ops:", opsFinal)
}
import "fmt"
import "time"
import "sync/atomic"
import "runtime"
func main() {
// 定义一个整数
var ops uint64 = 0
// 使用50个线程给ops累加数值
for i := 0; i < 50; i++ {
go func() {
for {
// 每次加1
atomic.AddUint64(&ops, 1)
// 这个函数用于时间片切换
//可以理解为高级版的time.Sleep()
//避免前面的for循环将CPU时间片都卡在一个线程里,使得其它线程没有执行机会
runtime.Gosched()
}
}()
}
//停一秒,上面50个线程有1秒的执行时间
time.Sleep(time.Second)
// 获取结果
opsFinal := atomic.LoadUint64(&ops)
fmt.Println("ops:", opsFinal)
}
打印结果类似:
ops: 40200
如果不使用原子计数,直接使用ops =ops+1会导致多线程时计数不准确。
打开Go源码中的atomic包,可以看到相关算法都是用汇编语言写的。所以原子计数执行效率非常高。
文章导航
搜索本站文章
日志分类
最新文章
- 记一次诡异的win10 "丢失"文件事件
- 企业微信 查不到该手机号的所属企业 的解决办法
- gradle学习总结
- 关于swift中的强引用 弱引用 无主引用
- 连接aws ec2提示Operation timed out的解决办法
近期评论
- 捕鱼器 发表在《仿twitter的开源微型博客系统》
- 电子捕鱼器 发表在《仿twitter的开源微型博客系统》
- 捕鱼机 发表在《仿twitter的开源微型博客系统》
- 电鱼机 发表在《仿twitter的开源微型博客系统》
- 捕鱼器 发表在《仿twitter的开源微型博客系统》
日志索引
有疑问加站长微信联系(非本文作者)
入群交流(和以上内容无关):加入Go大咖交流群,或添加微信:liuxiaoyan-s 备注:入群;或加QQ群:692541889
关注微信5198 次点击
上一篇:Zr847t6XiF7Go
添加一条新回复
(您需要 后才能回复 没有账号 ?)
- 请尽量让自己的回复能够对别人有帮助
- 支持 Markdown 格式, **粗体**、~~删除线~~、
`单行代码` - 支持 @ 本站用户;支持表情(输入 : 提示),见 Emoji cheat sheet
- 图片支持拖拽、截图粘贴等方式上传
收入到我管理的专栏 新建专栏
通过原子计数可以在多线程情况下,对同一个数值进行加减操作,一般用于状态同步。
先看代码:
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
31
32
33
34
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
31
32
33
34
package main
import "fmt"
import "time"
import "sync/atomic"
import "runtime"
func main() {
// 定义一个整数
var ops uint64 = 0
// 使用50个线程给ops累加数值
for i := 0; i < 50; i++ {
go func() {
for {
// 每次加1
atomic.AddUint64(&ops, 1)
// 这个函数用于时间片切换
//可以理解为高级版的time.Sleep()
//避免前面的for循环将CPU时间片都卡在一个线程里,使得其它线程没有执行机会
runtime.Gosched()
}
}()
}
//停一秒,上面50个线程有1秒的执行时间
time.Sleep(time.Second)
// 获取结果
opsFinal := atomic.LoadUint64(&ops)
fmt.Println("ops:", opsFinal)
}
import "fmt"
import "time"
import "sync/atomic"
import "runtime"
func main() {
// 定义一个整数
var ops uint64 = 0
// 使用50个线程给ops累加数值
for i := 0; i < 50; i++ {
go func() {
for {
// 每次加1
atomic.AddUint64(&ops, 1)
// 这个函数用于时间片切换
//可以理解为高级版的time.Sleep()
//避免前面的for循环将CPU时间片都卡在一个线程里,使得其它线程没有执行机会
runtime.Gosched()
}
}()
}
//停一秒,上面50个线程有1秒的执行时间
time.Sleep(time.Second)
// 获取结果
opsFinal := atomic.LoadUint64(&ops)
fmt.Println("ops:", opsFinal)
}
打印结果类似:
ops: 40200
如果不使用原子计数,直接使用ops =ops+1会导致多线程时计数不准确。
打开Go源码中的atomic包,可以看到相关算法都是用汇编语言写的。所以原子计数执行效率非常高。
文章导航
搜索本站文章
日志分类
最新文章
- 记一次诡异的win10 "丢失"文件事件
- 企业微信 查不到该手机号的所属企业 的解决办法
- gradle学习总结
- 关于swift中的强引用 弱引用 无主引用
- 连接aws ec2提示Operation timed out的解决办法
近期评论
- 捕鱼器 发表在《仿twitter的开源微型博客系统》
- 电子捕鱼器 发表在《仿twitter的开源微型博客系统》
- 捕鱼机 发表在《仿twitter的开源微型博客系统》
- 电鱼机 发表在《仿twitter的开源微型博客系统》
- 捕鱼器 发表在《仿twitter的开源微型博客系统》