Go原子计数

通过原子计数可以在多线程情况下,对同一个数值进行加减操作,一般用于状态同步。

先看代码:

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)

}

打印结果类似:

ops: 40200

如果不使用原子计数,直接使用ops =ops+1会导致多线程时计数不准确。

打开Go源码中的atomic包,可以看到相关算法都是用汇编语言写的。所以原子计数执行效率非常高。

时间: 2024-11-05 13:30:26

Go原子计数的相关文章

golang 原子计数,互斥锁,耗时

import "sync" import "sync/atomic" import "time" import "runtime" 1.runtime.Gosched()表示让CPU把时间片让给别人,下次某个时候继续恢复执行该goroutine,自己一般是阻塞了,这是一个很高级的sleep,我们经常会遇到要sleep多久的问题,这里不用考虑了,别人完成后,自然会通知你. 2.var mutex sync.Mutex 定义一个互

原子计数器 for Pthreads

在多线程环境下要计数,需要保证:计数变量的一致性和线程安全才能保证多线程环境下计数正确. 原子计数正是提供了此需求的功能,保证计数操作未执行完毕时绝不会被其他任何实务或事件打断,下面是原子计数器 for pthreads 缺点:使用锁的形式实现原子计数时锁的操作会比计数器的加减操作的消耗大很多,可以通过linux自带的性能检测工具perf命令查看哪些操作消耗多. #ifndef __ATOMICCOUNTER_H__ #define __ATOMICCOUNTER_H__ #if defined

YYAsyncLayer源代码解析

前言 简书地址:http://www.jianshu.com/p/a5baa43b71c8 本文的中文注释代码demo更新在我的github上. 在研究iOS UI性能优化上,异步绘制一直是一个离不开的话题.最近在研究Facebook的开源框架AsyncDisplayKit的时候,找到了YYKit作者所实现的YYAsyncLayer.从这个项目了解异步绘制的方法. 项目结构 YYAsyncLayer项目较为简单,一共就三个文件: YYSentinel:线程安全的计数器. YYTransactio

POCO库——Foundation组件之核心Core

核心Core: Version.h:版本控制信息,宏POCO_VERSION,值格式采用0xAABBCCDD,分别代表主版本.次版本.补丁版本.预发布版本: Poco.h:简单地包含了头文件Foundation.h: Foundation.h:使用其他任何Foundation模块前需要包含的头文件,主要定义库导出宏POCO_DLL.Foundation_API以及自动连接相应配置正确的库引用文件lib:包含库配置文件Config.h: 平台相关的Platform.h以及各个平台相应的文件Plat

[dpdk] 读开发指南(1)

该文档是随着对于文档的阅读进度,不断增加的阅读笔记.主要内容以大纲为主,以及记录帮助记忆的内容. 在之后的实际应用中,也不随着不断的深入理解,逐渐丰富各大纲下面的内容. 1. 前期准备:设置两个环境变量. export RTE_SDK=/home/user/DPDK export RTE_TARGET=x86_64-native-linuxapp-gcc 2. dpdk提供的环境抽象层: DPDK loading and launching                        DPDK

go sync.once用法

欢迎关注go语言微信公众号 每日go语言 golang_everyday sync.once可以控制函数只能被调用一次.不能多次重复调用.示例代码: package main import ( "fmt" "sync" "time" ) func main() { o := &sync.Once{} go do(o) go do(o) time.Sleep(time.Second * 2) } func do(o *sync.Once)

[转载] redis入门

原文: http://www.gamecbg.com/bc/db/redis/13852.html [本教程目录] 1.Redis是什么2.Redis的作者何许人也3.谁在使用redis4.学会安装redis5.学会启动redis6.使用redis客户端7.redis数据结构 – 简介8.redis数据结构 – strings9.redis数据结构 – lists10.redis数据结构 – 集合11.redis数据结构 – 有序集合12.redis数据结构 – 哈希13.聊聊redis持久化

超强、超详细Redis数据库入门教程

这篇文章主要介绍了超强.超详细Redis入门教程,本文详细介绍了Redis数据库各个方面的知识,需要的朋友可以参考下 [本教程目录] 1.redis是什么2.redis的作者何许人也3.谁在使用redis4.学会安装redis5.学会启动redis6.使用redis客户端7.redis数据结构 – 简介8.redis数据结构 – strings9.redis数据结构 – lists10.redis数据结构 – 集合11.redis数据结构 – 有序集合12.redis数据结构 – 哈希13.聊聊

redis 学习记录

http://www.yiibai.com/redis/redis_quick_guide.html Redis 是一款依据BSD开源协议发行的高性能Key-Value存储系统(cache and store).它通常被称为数据结构服务器,因为值(value)可以是 字符串(String), 哈希(hashes), 列表(list), 集合(sets) 和 有序集合(sorted sets)等类型. Redis是一个开源,先进的key-value存储,并用于构建高性能,可扩展的Web应用程序的完