一篇文章带你入门Go语言基础之并发

mb6066e504cce6f · · 309 次点击 · · 开始浏览    
这是一个创建于 的文章,其中的信息可能已经有所发展或是发生改变。

前言

Hey,大家好,我是码农星期八,终于到了Go中最牛掰的地方,并发,这也是Go为什么能快速火的原因。

部署方便,不需要容器,随便跑一个都是相当于Nginx的存在,怎么肯能不火

所以,来看看扒!!!


引言

Go语言,专门为并发而生的语言,每启动一个微线程创建一个代价大概2KB起步

假设一个内存条大小4G,一个微线程2kb1G=1024M=1048576kb1048576/2=524288,五十多万个

但是你知道像Java,Python等语言,一个线程代价多大吗???,2MB起步,代价直接翻了千倍

所以,激动吧,随便用Go写一个web程序,基本都相当于Nginx


goroutine

Go中的微线程,也叫做goroutinegoroutine是并行处理任务的

就像我用两只手同时操作两个手机打游戏一样

而不是一个手玩玩这个,一个手玩玩那个,这样切换式玩法

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调用函数方式

函数还是上述的函数

main

func 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)}



有疑问加站长微信联系(非本文作者)

本文来自:51CTO博客

感谢作者:mb6066e504cce6f

查看原文:一篇文章带你入门Go语言基础之并发

入群交流(和以上内容无关):加入Go大咖交流群,或添加微信:liuxiaoyan-s 备注:入群;或加QQ群:692541889

309 次点击  
加入收藏 微博
暂无回复
添加一条新回复 (您需要 登录 后才能回复 没有账号 ?)
  • 请尽量让自己的回复能够对别人有帮助
  • 支持 Markdown 格式, **粗体**、~~删除线~~、`单行代码`
  • 支持 @ 本站用户;支持表情(输入 : 提示),见 Emoji cheat sheet
  • 图片支持拖拽、截图粘贴等方式上传