Golang 协程(goroutine) 运行过程 与 并发

首先咱们须要理解进程和线程的关系

当运行一个应用程序的时候，操做系统会为这个应用程序启动一个进程，该个进程包含了应用程序在运行中所用须要用到和维护的各类资源的容器

• 每一个进程至少包含一个线程
• 每一个进程的初始线程被称为主线程
• 执行线程的空间是应用程序自己的空间
• 主线程终止，应用程序也将终止

goroutine执行过程

前提， goroutine的执行主要依靠调度处理器来完成，如

// 建立了两个调度处理器
runtime.GOMAXPROCS(2)

一、建立一个goroutine
二、goroutine进入调度处理器全局运行队列（调度器）中
三、调度器分配一个调度处理器供goroutine使用
四、goroutine 执行

在其上述执行过程当中，咱们很容易会思考到一个问题，例如如今有 3 个goroutine等待执行，那么，goroutine是如何运行的呢

咱们来尝试执行一段代码

import (
"fmt"
"runtime"
"sync"
)

func main()  {
    // 建立一个调度处理器
    runtime.GOMAXPROCS(1)

    var wg sync.WaitGroup
    wg.Add(2)

    fmt.Println("协程开始 ...\n")

    go func() {
        defer wg.Done()

        for count :=0; count < 3; count++ {
            for char := 'a'; char < 'a' + 26; char ++ {
                fmt.Printf("%c", char)
            }
        }
    }()

    go func() {
        defer wg.Done()

        for count :=0; count < 3; count++ {
            for char := 'A'; char < 'A' + 26; char ++ {
                fmt.Printf("%c", char)
            }
        }
    }()

    fmt.Println("wait ...\n")
    wg.Wait()

    fmt.Println("\n结束...")
}

结果

协程开始 ...
wait ...
ABCDEFGHIJKLMNOPQRSTUVWXYZABCDEFGHIJKLMNOPQRSTUVWXYZABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyzabcdefghijklmnopqrstuvwxyzabcdefghijklmnopqrstuvwxyz
结束...

咱们会发现，是否是第二goroutine先执行完毕？是的，无论是尝试多少次，都会是这个结果

其实，致使这个问题的缘由来自于其管理goroutine寿命的行为

在goroutine中，为了防止某个goroutine运行时间过长，调度器会中止当前正在运行的goroutine，给其余goroutine运行的机会

继续查看代码

package main

import (
"fmt"
"runtime"
"sync"
)

func main()  {
    runtime.GOMAXPROCS(1)

    var wg sync.WaitGroup
    wg.Add(3)

    fmt.Println("协程开始 ...\n")

    go func() {
        defer wg.Done()

        fmt.Println(1)
    }()

    go func() {
        defer wg.Done()

        fmt.Println(2)
    }()
    go func() {
        defer wg.Done()

        fmt.Println(3)
    }()

    fmt.Println("wait ...\n")
    wg.Wait()

    fmt.Println("\n结束...")
}

结果则为 3 1 2

并发与并行

简而言之

• 并行

不用的程序在不一样的物理处理器上执行，关键的在于同时作不少事情

• 并发

使用较少的资源作更多的事情，即在go中为，用聪明的算法根据单个物理机器，调度一个个执行

在go中，如何实现并行

// 双核
runtime.GOMAXPROCS(2)

便可

以上，会触发2两调度处理器，并发运行，但实际上这种并发也其实就是 go 经过单个物理机器建立多个线程实现的伪并行

IO操做下的goroutine

IO下的goroutine都为阻塞性的goroutine

• 资源读写IO

调用时，线程将从逻辑处理器上分离，线程继续堵塞，处理器将绑定一个新的线程，并执行其余 goroutine ，IO goroutine 执行完毕后，占用线程进行回收，下次使用

• 网络IO

网络IO，将从逻辑处理器上分离，且将其放入到网络轮询器的运行中，当检测到改资源IO操做就绪，将取出并分配到逻辑处理器上从新运行

调度器配置

Go 默认支持最多建立10000个线程，若是使用的再多，可能会崩溃，能够经过runtime或者debug的包来完成这些配置