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

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

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

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

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

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

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

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

goroutine由Go的runtime完成调度，goroutine的本质是在代码(用户态)级别完成的切换，代价很小

像Java，Python等语言的线程，是在操作系统(内核态)级别完成的切花，所以代价非常大

由于goroutine是由runtime完成切换，并且runtime经过Google公司的数位大佬优化，已经很小母牛上山了，牛逼哄哄了。

在Go中使用goroutine很简单，只需要在想调用的函数前加一个go就行了，这就代表启动了一个goroutine

func Say() {
    time.Sleep(time.Second)
    fmt.Println("我在说话说了1s说完了...")
}

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，有点慢啊！

函数还是上述的函数

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，什么情况？

这是因为，在Go中，我们采用的是守护线程的方式，什么意思呢？

在Go中，main函数只要执行完，其他微线程必凉。

就像有的怪兽，他们是互相依赖一个母体的，母体挂了，下面的娃也必挂。

所以该怎么解决这个问题呢???

上述我们发现，启动了一些微线程，但是微线程还没来得及执行就挂了，是因为main函数跑的太快了，main跑完了，Go运行时自动将其他微线程关闭了。

那反过来想，我们如何让main在最后等一下，等我的孩子们都回来了，我在继续跑。

所以，有一个新的问题，那就是等，祭出法宝sync.WaitGroup

先看一下怎么用

func Say() {
    //函数结束时取消标记
    defer wg.Done()
    //每个函数在启动时加上一个标记
    wg.Add(1)
    //函数开始打上一个标记
    time.Sleep(time.Second*1)
    fmt.Println("我在说话说了1s说完了...")
}

var wg  sync.WaitGroup
func 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的原因。

这个意思要使用多少个核，默认使用全部核心，性能跑满，但是也有意外的情况，

比如一个机器跑了很多其他任务，Go写的这个是不太重要的任务，但是是计算型的，这时候理论来说是不尽量挤兑别人的算力

所以要限制一下当前程序使用电脑的算力

代码

func main() {
    //本机的cpu个数
    var cpuNum = runtime.NumCPU()
    fmt.Println(cpuNum)
    //设置Go使用cpu个数
    runtime.GOMAXPROCS(4)
}

上述我们学习了Go的并发，学习了

• 如何创建一个协程(goroutine)。

• 为什么需要sync.WaitGroup。

• 设置当前程序使用CPU核数。

【感谢: 龙石数据大数据分析平台技术支撑 http://www.longshidata.com/pages/government.html, 】