一篇文章带你入门Go语言基础之并发
回复“Go语言”即可获赠从入门到进阶共10本电子书
今
日
鸡
汤
含光混世贵无名,何用孤高比云月?
前言Hey,大家好,我是码农星期八,终于到了Go中最牛掰的地方,并发,这也是Go为什么能快速火的原因。
部署方便,不需要容器,随便跑一个都是相当于Nginx的存在,怎么肯能不火
所以,来看看扒!!!
引言Go语言,专门为并发而生的语言,每启动一个微线程创建一个代价大概2KB起步
假设一个内存条大小4G,一个微线程2kb,1G=1024M=1048576kb,1048576/2=524288,五十多万个
但是你知道像Java,Python等语言,一个线程代价多大吗???,2MB起步,代价直接翻了千倍
所以,激动吧,随便用Go写一个web程序,基本都相当于Nginx
goroutineGo中的微线程,也叫做goroutine,goroutine是并行处理任务的
就像我用两只手同时操作两个手机打游戏一样
而不是一个手玩玩这个,一个手玩玩那个,这样切换式玩法
goroutine由Go的runtime完成调度,goroutine的本质是在代码(用户态)级别完成的切换,代价很小
像Java,Python等语言的线程,是在操作系统(内核态)级别完成的切花,所以代价非常大
由于goroutine是由runtime完成切换,并且runtime经过Google公司的数位大佬优化,已经很小母牛上山了,牛逼哄哄了。
使用goroutine在Go中使用goroutine很简单,只需要在想调用的函数前加一个go就行了,这就代表启动了一个goroutine
普通调用函数方式函数func Say() {time.Sleep(time.Second)fmt.Println("我在说话说了1s说完了...")}main
func main() {//开始时间var start_time = time.Now()//启动10个say说话for i := 0; i < 10; i++ {Say()}//结束时间var end_time = time.Now()//计算时间差fmt.Println(end_time.Sub(start_time))}执行结果
循环了10次,耗时10s,有点慢啊!
goroutine调用函数方式函数还是上述的函数
mainfunc main() {//开始时间var start_time = time.Now()//启动10个say说话for i := 0; i < 10; i++ {go Say()}//结束时间var end_time = time.Now()//计算时间差fmt.Println(end_time.Sub(start_time))}
注意:第6行,前面加了个go关键字,go关键字就表示以一个微线程的方式单独运行这个函数。
执行结果what??? 0s,什么情况?
为什么会出现0s这种情况这是因为,在Go中,我们采用的是守护线程的方式,什么意思呢?
在Go中,main函数只要执行完,其他微线程必凉。
就像有的怪兽,他们是互相依赖一个母体的,母体挂了,下面的娃也必挂。
所以该怎么解决这个问题呢???
sync.WaitGroup上述我们发现,启动了一些微线程,但是微线程还没来得及执行就挂了,是因为main函数跑的太快了,main跑完了,Go运行时自动将其他微线程关闭了。
那反过来想,我们如何让main在最后等一下,等我的孩子们都回来了,我在继续跑。
所以,有一个新的问题,那就是等,祭出法宝sync.WaitGroup
先看一下怎么用
函数func Say() {//函数结束时取消标记defer wg.Done()//每个函数在启动时加上一个标记wg.Add(1)//函数开始打上一个标记time.Sleep(time.Second*1)fmt.Println("我在说话说了1s说完了...")}main
var wg sync.WaitGroupfunc main() {//开始时间var start_time = time.Now()//启动10个say说话for i := 0; i < 10; i++ {go Say()}// 等待所有标记过的微线程执行完毕wg.Wait()//结束时间var end_time = time.Now()//计算时间差fmt.Println(end_time.Sub(start_time))}执行结果
可以看到,10个线程同时启动,1s就完了,并且代码相对简单,就算开启10w个,还是1s多一点
这也是为什么很多公司越来越青睐Go的原因。
runtime.GOMAXPROCS这个意思要使用多少个核,默认使用全部核心,性能跑满,但是也有意外的情况,
比如一个机器跑了很多其他任务,Go写的这个是不太重要的任务,但是是计算型的,这时候理论来说是不尽量挤兑别人的算力
所以要限制一下当前程序使用电脑的算力
代码
func main() {//本机的cpu个数var cpuNum = runtime.NumCPU()fmt.Println(cpuNum)//设置Go使用cpu个数runtime.GOMAXPROCS(4)}总结
上述我们学习了Go的并发,学习了
如何创建一个协程(goroutine)。
为什么需要sync.WaitGroup。
设置当前程序使用CPU核数。
在Go中,轻松实现一个高并发还是挺容易的,但是可能有些不是那么好理解。
如果在操作过程中有任何问题,记得下面留言,我们看到会第一时间解决问题。
我是码农星期八,如果觉得还不错,记得动手点赞一下哈。
感谢你的观看。
想了解更多关于Go的知识,请前往:http://pdcfighting.com/
-------------------End-------------------
往期精彩文章推荐:
一篇文章教会你Go语言基础之反射
Go语言基础之结构体(冬日篇)
一篇文章带你了解Go语言基础之map
欢迎大家点赞,留言,转发,转载,感谢大家的相伴与支持
想加入Go学习群请在后台回复【入群】
万水千山总是情,点个【在看】行不行
相关阅读
-
世界热推荐:今晚7:00直播丨下一个突破...
今晚19:00,Cocos视频号直播马上点击【预约】啦↓↓↓在运营了三年... -
NFT周刊|Magic Eden宣布支持Polygon网...
Block-986在NFT这样的市场,每周都会有相当多项目起起伏伏。在过去... -
环球今亮点!头条观察 | DeFi的兴衰与...
在比特币得到机构关注之后,许多财务专家预测世界将因为加密货币的... -
重新审视合作,体育Crypto的可靠关系才能双赢
Block-987即使在体育Crypto领域,人们的目光仍然集中在FTX上。随着... -
简讯:前端单元测试,更进一步
前端测试@2022如果从2014年Jest的第一个版本发布开始计算,前端开发... -
焦点热讯:刘强东这波操作秀
近日,刘强东发布京东全员信,信中提到:自2023年1月1日起,逐步为...