go并发 - goroutine

概述

Go并发模型独树一帜，简洁、高效。Go语言最小执行单位称为协程(goroutine)，运行时可以创建成千万上个协程，这在Java、C等线程模型中是不可想象的，并发模型是Go的招牌能力之一。很多文章描述协程是轻量级的线程，并不准确，两者在底层有本质区别。线程是由操作系统维护，以Linux为例，系统调用创建线程，并由操作系统调度执行，在内核空间管理、与进程共享PCB对象、共享堆空间、独立调用栈和寄存器，是操作系统最小的调度对象，软中断触发操作系统切换调度。协程是由Go运行时维护，与操作系统线程不是对等关系，多个协程简共享堆栈空间，在用户空间维护，由Go运行时自行调度。不依赖系统中断可以做了非常轻量级。
调度可简单理解就是如何安排任务，合理高效的调度任务，可显著提升性能和降低复杂度。以Linux网络Io模型为例，经过多年的发展也就出现五种模型（阻塞 I/O、非阻塞 I/O、多路复用 I/O、信号驱动 I/O、异步 I/O）。传输层不变、TCP/IP协议栈不变、应用层协议不变、操作系统不变、硬件配置不变，不同Io模型性能差别非常大，这就是调度的威力。操作系统对线程的调度是自闭环的，不提供用户侧的控制接口，并行线程数与CPU数一致，线程切换是很重的操作，没有优化空间，完全寄托于操作系统进程管理能力。协程运行在线程之上，由go运行时维护，创建、同步、销毁、调度等，全部用户空间完成，可以做到和函数栈调用一样轻量级。在Go底层与操作系统交互还是线程模型，从操作系统视角根本看不到协程的存在，并行线程数也没有改变，复杂度也并没有降低，只是从用户侧转移到了Go运行时，总有人要负重前行。go并发模型并没有提升性能，更大作用是降低并发编程难度，降低开发人员心智。
Go的调度模型有专用名词：GPM

• G，表示协程，用户通过go指令创建，数量不受限制
  
• P，类似CPU，内部维护了队列，G只有加入到P队列后才能被调度，数量由Go自己维护，可通过GOMAXPROCS指定数量
  
• M，OS线程抽象，负责调度任务，和某个P绑定，从P的中不断取出G，切换堆栈并执行，数量不可指定，由Go Runtime调整
  

基本使用

一如既往的简洁，使用go指令就可以丝滑的创建一个协程，新协程将会由go运行时调度。

1. func main() {
2.     go func() {
3.         fmt.Println("hello world")
4.     }()
5. }

复制代码

注意，上面代码大概率无法正常工作，不能打印出字符串。匿名函数在新协程中调度执行，main函数在主协程继续执行，两者协程会并发执行。这引出了协程重要特性，go主协程有特权，当主协程执行完毕就退出程序，不管是否存在用户协程。main执行结束退出程序，此时匿名函数还没来得及打印字符串。Java主线程也有类似的特性，但是开放了daemon属性可控制，Go则没有提供控制API。
要顺利打印字出字符串，主协程需要等待用户协程执行结束，本质是协程之间协调问题。

1. func main() {
2.     go func() {
3.         fmt.Println("hello world")
4.     }()
5.     time.Sleep(time.Second)                // 主协程睡眠1秒
6. }

复制代码

主协程睡眠了1秒，好像很可以工作了，但这是很low的解决方法，极度不靠谱。只要涉及并发编程，就绕不开同步机制，这是并发编程的核心内容，也是并发编程的复杂度所在，独立章节介绍。
另一个方法可以阻塞主协程，等待通知后继续执行

1. func main() {
2.     wg := new(sync.WaitGroup)
3.     wg.Add(1)
5.     go func() {
6.         fmt.Println("hello world")
7.     }()
9.     wg.Wait()        // 进入等待
10. }

复制代码

程序会锁死并panic崩溃退出。主线程进入了等待，却没有收到通知，go运行时可以发现死锁状态，类似逻辑在Java中不会退出，将永远阻塞，因为通知底层依赖操作系统中断机制，Java编译器无法识别死锁问题。而go在用户空间调度，由自己处理调度、同步，大部分死锁问题在编译时候就可以发现。这也可以看出两种调度模型的区别，不过JDK20也支持了虚拟线程，与go协程类似在空间实现调度。
修正后代码如下

1. func main() {
2.     wg := new(sync.WaitGroup)
3.     wg.Add(1)
5.     go func() {
6.         fmt.Println("hello world")
7.         wg.Done()        // 通知
8.     }()
10.     wg.Wait()                // 进入等待
11. }

复制代码

使用管道也可以实现通知
[code]func main() {    notice := make(chan bool)    go func() {        fmt.Println("hello")        notice