前言：

協(xié)程（coroutine）是 Go 語言最大的特色之一，goroutine 的實現(xiàn)其實是通過協(xié)程。

協(xié)程的概念

協(xié)程一詞最早出現(xiàn)在 1963 年發(fā)表的論文中，該論文的作者為美國計算機(jī)科學(xué)家 Melvin E.Conway。著名的康威定律：“設(shè)計系統(tǒng)的架構(gòu)受制于產(chǎn)生這些設(shè)計的組織的溝通結(jié)構(gòu)。” 也是這個作者。

協(xié)程是一種用戶態(tài)的輕量級線程，可以想成一個線程里面可以有多個協(xié)程，而協(xié)程的調(diào)度完全由用戶控制，協(xié)程也會有自己的 registers、context、stack 等等，并且由協(xié)程的調(diào)度器來控制說目前由哪個協(xié)程執(zhí)行，哪個協(xié)程要被 block 住。

而相對于 Thread 及 Process 的調(diào)度，則是由 CPU 內(nèi)核去進(jìn)行調(diào)度，因此操作系統(tǒng)其實會有所謂許多的調(diào)度算法，并且可以進(jìn)行搶占式調(diào)度，可以主動搶奪執(zhí)行的控制權(quán)。

反之，協(xié)程是不行的，只能進(jìn)行非搶占式的調(diào)度。 可以理解成，如果 coroutine 被 block 住，則會在用戶態(tài)直接切換另外一個 coroutine 給此 thread 繼續(xù)執(zhí)行，這樣其他 coroutine 就不會被 block 住，讓資源能夠有效的被利用，借此實現(xiàn) Concurrent 的概念。

協(xié)程與線程

線程 是 CPU 調(diào)度的基本單位，多個線程可以通過共享進(jìn)程的資源，通過共享內(nèi)存等方式來進(jìn)行線程間通信。

協(xié)程 可理解為輕量級線程，與線程相比，協(xié)程不受操作系統(tǒng)系統(tǒng)調(diào)度，協(xié)程調(diào)度由用戶應(yīng)用程序提供，協(xié)程調(diào)度器按照調(diào)度策略把協(xié)程調(diào)度到線程中運(yùn)行。

• 協(xié)程只需花幾 KB 就可以被創(chuàng)立，線程則需要幾 MB 的內(nèi)存才能創(chuàng)立
• 切換開銷方面，協(xié)程遠(yuǎn)遠(yuǎn)低于線程，切換的速度也因此大幅提升

goroutine 的誕生

Golang 語言的 goroutine 其實就是協(xié)程，特別的是在語言層面直接原生支持創(chuàng)立協(xié)程，并在 runtime、系統(tǒng)調(diào)用等多方面對 goroutine 調(diào)度進(jìn)行封裝及處理。

相對于 Java 的建立線程，操作系統(tǒng)是會直接建立一個線程與其對應(yīng)，而多個線程的間互相切換需要通過內(nèi)核線程來進(jìn)行，會有較大的上下文切換開銷，造成的資源耗費(fèi)，而 goroutine 是在代碼上直接實現(xiàn)切換，不需要經(jīng)過內(nèi)核線程。

goroutine 的優(yōu)勢：

• 與線程相比, goroutine 非常便宜，可以根據(jù)應(yīng)用程序的需求自動分配， 但在線程的大小通常是固定的
• 使用 goroutine 訪問共享內(nèi)存的時候 透過 channel 可以避免競態(tài)條件的發(fā)生

比如，我們計算一個數(shù)字的質(zhì)數(shù)，可以寫出如下的代碼:

package main

import (
	"fmt"
	"time"
)

func main() {
	num := 300000
	start := time.Now()
	for i := 1; i <= num; i++ {
		if isPrime(i) {
			fmt.Println(i)
		}
	}
	end := time.Now()
	fmt.Println(end.Unix()-start.Unix(), "seconds")
}
func isPrime(num int) bool {
	if num == 1 {
		return false
	} else if num == 2 {
		return true
	} else {
		for i := 2; i < num; i++ {
			if num%i == 0 {
				return false
			}
		}
		return true
	}
}

上面的代碼用 num ：= 300000 來測試，也就是從 1~300000 之間來看那些數(shù)字會是質(zhì)數(shù)，如果是質(zhì)數(shù)的話就把質(zhì)數(shù)輸出，最后看到最終花費(fèi)了 37 秒。運(yùn)行結(jié)果如下：

使用 goroutine 加快速度

package main

import (
	"fmt"
	"time"
)

func main() {
	num := 300000
	start := time.Now()
	for i := 1; i <= num; i++ {
		go findPrimes(i)
	}

	end := time.Now()
	time.Sleep(5 * time.Second)
	fmt.Println(end.Unix()-start.Unix(), "seconds")
}

func findPrimes(num int) {
	if num == 1 {
		return
	} else if num == 2 {
		fmt.Println(num)
	} else {
		for i := 2; i < num; i++ {
			if num%i == 0 {
				return
			}
		}
		fmt.Println(num)
	}
}

go findPrimes 這條語句就可以開啟一個 goroutine，因此以主程序來說這樣等于是開啟 300000 個 goroutine 來各自判斷自己拿到 num 是不是質(zhì)數(shù)這樣。

用 time. Sleep 來休息五秒來讓 main 主程序不要被關(guān)閉，否則由于開啟 goroutine 之后代碼會繼續(xù)往下執(zhí)行，如果沒做 sleep 的話會導(dǎo)致主程序關(guān)閉，主程序一關(guān)閉 goroutine 就跟著關(guān)閉了，我們就看不出效果了。

這邊運(yùn)行之后會發(fā)現(xiàn)輸出的質(zhì)數(shù)出現(xiàn)并不是從小到大的，這是因為這些 goroutine 是一起做事情的，所以誰先做完誰就先輸出這樣。

運(yùn)行結(jié)果如下，最后花費(fèi)了大概 11 秒：

goroutine 的機(jī)制原理

理解 goroutine 機(jī)制的原理，關(guān)鍵是理解 Go 語言是如何實現(xiàn)調(diào)度器模型的。

計算機(jī)科學(xué)領(lǐng)域的任何問題都可以通過添加間接中間層來解決。GPM 模型就是這一理論的實踐者。

Go 語言中支撐整個調(diào)度器實現(xiàn)的主要有 4 個重要結(jié)構(gòu)，分別是 machine（簡稱 M ）、goroutine（簡稱 G ）、processor（簡稱 P ）、Scheduler(簡稱 Sched）， 前三個定義在 runtime.h 中，Sched 定義在 proc.c 中。

• Sched 結(jié)構(gòu)就是調(diào)度器，它維護(hù)有存儲 M 和 G 的隊列以及調(diào)度器的一些狀態(tài)信息等
• M 結(jié)構(gòu)是 Machine，系統(tǒng)線程，它由操作系統(tǒng)管理和調(diào)度的，goroutine 就是跑在 M 之上的; M 是一個很大的結(jié)構(gòu)，里面維護(hù)小對象內(nèi)存 cache（mcache）、當(dāng)前執(zhí)行的 goroutine、隨機(jī)數(shù)發(fā)生器等等非常多的信息。
• P 結(jié)構(gòu)是 Processor，處理器，它的主要用途就是用來執(zhí)行 goroutine 的，它維護(hù)了一個 goroutine 隊列，即 runqueue。 Processor 是讓我們從 N:1 調(diào)度到 M:N 調(diào)度的重要部分。
• G 是 goroutine 實現(xiàn)的核心結(jié)構(gòu)，它包含了棧，指令指針，以及其他對調(diào)度 goroutine 很重要的信息，例如其阻塞的 channel。

我們分別用三角形，矩形和圓形表示 Machine Processor 和 Goroutine：

在單核處理器的場景下，所有 goroutine 運(yùn)行在同一個 M 系統(tǒng)線程中，每一個 M 系統(tǒng)線程維護(hù)一個 Processor，任何時刻，一個 Processor 中只有一個 goroutine，其他 goroutine 在 runqueue 中等待。

一個 goroutine 運(yùn)行完自己的時間片后，讓出上下文，回到 runqueue 中。 多核處理器的場景下，為了運(yùn)行 goroutines，每個 M 系統(tǒng)線程會持有一個 Processor 。

可以看到 Go 的并發(fā)用起來非常簡單，用了一個語法糖將內(nèi)部復(fù)雜的實現(xiàn)結(jié)結(jié)實實的包裝了起來。

其內(nèi)部可以用下面這張圖來概述：

在單核處理器的場景下，所有 goroutine 運(yùn)行在同一個 M 系統(tǒng)線程中，每一個 M 系統(tǒng)線程維護(hù)一個 Processor，任何時刻，一個 Processor 中只有一個 goroutine，其他 goroutine 在 runqueue 中等待。一個 goroutine 運(yùn)行完自己的時間片后，讓出上下文，回到 runqueue 中。 多核處理器的場景下，為了運(yùn)行 goroutines，每個 M 系統(tǒng)線程會持有一個 Processor 。

在正常情況下，scheduler 會按照上面的流程進(jìn)行調(diào)度，但是線程會發(fā)生阻塞等情況，看一下goroutine對線程阻塞等的處理。

到此這篇關(guān)于Go 并發(fā)編程協(xié)程及調(diào)度機(jī)制詳情的文章就介紹到這了,更多相關(guān)Go 調(diào)度機(jī)制內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

最新評論