參考Go的CSP并發(fā)模型實現(xiàn)：M, P, G

Go語言是為并發(fā)而生的語言，Go語言是為數(shù)不多的在語言層面實現(xiàn)并發(fā)的語言。

并發(fā)(concurrency)：多個任務(wù)在同一段時間內(nèi)運行。

并行(parallellism)：多個任務(wù)在同一時刻運行。

Go的CSP并發(fā)模型（goroutine + channel）

Go實現(xiàn)了兩種并發(fā)形式。

• 多線程共享內(nèi)存：Java或者C++等語言中的多線程開發(fā)。
• CSP（communicating sequential processes）并發(fā)模型：Go語言特有且推薦使用的。

不同于傳統(tǒng)的多線程通過共享內(nèi)存來通信，CSP講究的是“以通信的方式來共享內(nèi)存”。

普通的線程并發(fā)模型，就是像Java、C++、或者Python，他們線程間通信都是通過共享內(nèi)存的方式來進行的。非常典型的方式就是，在訪問共享數(shù)據(jù)（例如數(shù)組、Map、或者某個結(jié)構(gòu)體或?qū)ο螅┑臅r候，通過鎖來訪問，因此，在很多時候，衍生出一種方便操作的數(shù)據(jù)結(jié)構(gòu)，叫做“線程安全的數(shù)據(jù)結(jié)構(gòu)”。

Go的CSP并發(fā)模型，是通過goroutine和channel來實現(xiàn)的。

• goroutine 是Go語言中并發(fā)的執(zhí)行單位?？梢岳斫鉃橛脩艨臻g的線程。
• channel是Go語言中不同goroutine之間的通信機制，即各個goroutine之間通信的”管道“，有點類似于Linux中的管道。

1、goroutine

Go語言最大的特色就是從語言層面支持并發(fā)（goroutine），goroutine是Go中最基本的執(zhí)行單元。事實上每一個Go程序至少有一個goroutine：主goroutine。當程序啟動時，它會自動創(chuàng)建。我們在使用Go語言進行開發(fā)時，一般會使用goroutine來處理并發(fā)任務(wù)。

goroutine機制有點像線程池：

go 內(nèi)部有三個對象： P(processor) 代表上下文（M所需要的上下文環(huán)境，也就是處理用戶級代碼邏輯的處理器），M(work thread)代表內(nèi)核線程，G（goroutine）協(xié)程。

正常情況下一個cpu核運行一個內(nèi)核線程，一個內(nèi)核線程運行一個goroutine協(xié)程。當一個goroutine阻塞時，會啟動一個新的內(nèi)核線程來運行其他goroutine，以充分利用cpu資源。所以線程往往會比cpu核數(shù)更多。

example

在單核情況下，所有g(shù)oroutine運行在同一個內(nèi)核線程（M0）中，每一個內(nèi)核線程維護一個上下文（P），任何時刻，一個上下文中只有一個goroutine，其他goroutine在runqueue中等待。一個goroutine運行完自己的時間片后，讓出上下文，自己回到runqueue中。如下圖左邊所示，只有一個G0在運行，而其他goroutine都掛起了。

當正在運行的G0阻塞的時候（IO之類的），會再創(chuàng)建一個新的內(nèi)核線程（M1），P轉(zhuǎn)到新的內(nèi)核線程中去運行。

當M0返回時（不再阻塞），它會嘗試從其他線程中“偷”一個上下文（cpu）過來，如果沒有偷到，會把goroutine放到global runqueue中去，然后把自己放入線程緩存中。上下文會定時檢查global runqueue切換goroutine運行。

goroutine的優(yōu)點：

1、創(chuàng)建與銷毀的開銷小

線程創(chuàng)建時需要向操作系統(tǒng)申請資源，并且在銷毀時將資源歸還，因此它的創(chuàng)建和銷毀的開銷比較大。相比之下，goroutine的創(chuàng)建和銷毀是由go語言在運行時自己管理的，因此開銷更低。所以一個Golang的程序中可以支持10w級別的Goroutine。每個 goroutine (協(xié)程) 默認占用內(nèi)存遠比 Java 、C 的線程少（*goroutine：*2KB ，線程：8MB）

2、切換開銷小

這是goroutine于線程的主要區(qū)別，也是golang能夠?qū)崿F(xiàn)高并發(fā)的主要原因。

線程的調(diào)度方式是搶占式的，如果一個線程的執(zhí)行時間超過了分配給它的時間片，就會被其它可執(zhí)行的線程搶占。在線程切換的過程中需要保存/恢復(fù)所有的寄存器信息，比如16個通用寄存器，PC（Program Counter），SP（Stack Pointer），段寄存器等等。

而goroutine的調(diào)度是協(xié)同式的，沒有時間片的概念，由Golang完成，它不會直接地與操作系統(tǒng)內(nèi)核打交道。當goroutine進行切換的時候，之后很少量的寄存器需要保存和恢復(fù)（PC和SP）。因此gouroutine的切換效率更高。

總的來說，操作系統(tǒng)的一個線程下可以并發(fā)執(zhí)行上千個goroutine，每個goroutine所占用的資源和切換開銷都很小，因此，goroutine是golang適合高并發(fā)場景的重要原因。

生成一個goroutine的方法十分簡單，直接使用go關(guān)鍵字即可：

go func();

2、channel

參考由淺入深剖析 go channel

channel的使用方法：聲明之后，傳數(shù)據(jù)用channel <- data，取數(shù)據(jù)用<-channel。channel分為無緩沖和有緩沖，無緩沖會同步阻塞，即每次生產(chǎn)消息都會阻塞到消費者將消息消費；有緩沖的不會立刻阻塞。

無緩存channel

ch := make(chan int)
// write to channel
ch <- x
// read from channel
x <- ch
// another way to read
x = <- ch

從無緩存的 channel 中讀取消息會阻塞，直到有 goroutine 向該 channel 中發(fā)送消息；同理，向無緩存的 channel 中發(fā)送消息也會阻塞，直到有 goroutine 從 channel 中讀取消息。

example

c := make(chan int)  // Allocate a channel.
// Start the sort in a goroutine; when it completes, signal on the channel.
go func() {
    list.Sort()
    c <- 1  // Send a signal; value does not matter.
}()
doSomethingForAWhile()
<-c

主goroutine定義一個無緩存的channel，然后開啟一個新的goroutine執(zhí)行排序任務(wù)，接著主goroutine繼續(xù)向下執(zhí)行doSomethingForAWhile，接著要從channel中取值，但是channel是空的，因此主goroutine阻塞。等到新goroutine排序完畢，向channel中寫值后，主goroutine從channel中取到值，然后才能繼續(xù)向下執(zhí)行。

有緩存channel

有緩存的 channel 的聲明方式為指定 make 函數(shù)的第二個參數(shù)，該參數(shù)為 channel 緩存的容量

ch := make(chan int, 10)

當緩存未滿時，向 channel 中發(fā)送消息時不會阻塞，當緩存滿時，發(fā)送操作將被阻塞，直到有其他 goroutine 從中讀取消息

ch := make(chan int, 3)
// blocked, read from empty buffered channel
<- ch

相應(yīng)的，當 channel 中消息不為空時，讀取消息不會出現(xiàn)阻塞，當 channel 為空時，讀取操作會造成阻塞，直到有 goroutine 向 channel 中寫入消息。

ch := make(chan int, 3)
ch <- 1
ch <- 2
ch <- 3
// blocked, send to full buffered channel
ch <- 4

通過 len 函數(shù)可以獲得 chan 中的元素個數(shù)，通過 cap 函數(shù)可以得到 channel 的緩存長度。

channel 也可以使用 range 取值，并且會一直從 channel 中讀取數(shù)據(jù)，直到有 goroutine 對改 channel 執(zhí)行 close 操作，循環(huán)才會結(jié)束。

// consumer worker
ch := make(chan int, 10)
for x := range ch{
    fmt.Println(x)
}

等價于

for {
    x, ok := <- ch
    if !ok {
        break
    }
    fmt.Println(x)
}

3、Go并發(fā)模型的底層實現(xiàn)原理

參考Golang CSP并發(fā)模型

無論在語言層面用的是何種并發(fā)模型，到了操作系統(tǒng)層面，一定是以線程的形態(tài)存在的。而操作系統(tǒng)根據(jù)資源訪問權(quán)限的不同，體系架構(gòu)可分為用戶空間和內(nèi)核空間。

• 內(nèi)核空間主要操作訪問CPU資源、I/O資源、內(nèi)存資源等硬件資源，為上層應(yīng)用程序提供最基本的基礎(chǔ)資源。
• 用戶空間就是上層應(yīng)用程序的固定活動空間，用戶空間不可以直接訪問資源，必須通過“系統(tǒng)調(diào)用”、“庫函數(shù)”或“Shell腳本”來調(diào)用內(nèi)核空間提供的資源。

golang使用goroutine做為最小的執(zhí)行單位，但是這個執(zhí)行單位還是在用戶空間，實際上最后被處理器執(zhí)行的還是內(nèi)核中的線程，用戶線程和內(nèi)核線程的調(diào)度方法有：

• 1:1，即一個內(nèi)核線程對應(yīng)一個用戶級線程（并發(fā)度低，浪費cpu資源，上下文切換需要消耗額外的資源）。
• 1:N，即一個內(nèi)核線程對應(yīng)N個用戶級線程（并發(fā)度高，但是只用一個內(nèi)核線程，不能有效利用多核CPU）。
• M:N，即M個內(nèi)核線程對應(yīng)N個用戶級線程（上述兩種方式的折中，缺點是線程調(diào)度會復(fù)雜一些）

golang 通過為goroutine提供語言層面的調(diào)度器，來實現(xiàn)了高效率的M:N線程對應(yīng)關(guān)系

M：是內(nèi)核線程

P : 是調(diào)度協(xié)調(diào)，用于協(xié)調(diào)M和G的執(zhí)行，內(nèi)核線程只有拿到了 P才能對goroutine繼續(xù)調(diào)度執(zhí)行，一般都是通過限定P的個數(shù)來控制golang的并發(fā)度

G : 是待執(zhí)行的goroutine，包含這個goroutine的棧空間

Gn : 灰色背景的Gn 是已經(jīng)掛起的goroutine，它們被添加到了執(zhí)行隊列中，然后需要等待網(wǎng)絡(luò)IO的goroutine，當P通過 epoll查詢到特定的fd的時候，會重新調(diào)度起對應(yīng)的，正在掛起的goroutine。

Golang為了調(diào)度的公平性，在調(diào)度器加入了steal working 算法 ，在一個P自己的執(zhí)行隊列，處理完之后，它會先到全局的執(zhí)行隊列中偷G進行處理，如果沒有的話，再會到其他P的執(zhí)行隊列中搶G來進行處理。

4、一個CSP例子

參考golang中的CSP并發(fā)模型

生產(chǎn)者-消費者Sample：

package main
import (
   "fmt" 
   "time"
)
// 生產(chǎn)者
func Producer (queue chan<- int){
        for i:= 0; i < 10; i++ {
                queue <- i
        }
}
// 消費者
func Consumer( queue <-chan int){
        for i :=0; i < 10; i++{
                v := <- queue
                fmt.Println("receive:", v)
        }
}
func main(){
        queue := make(chan int, 1)
        go Producer(queue)
        go Consumer(queue)
        time.Sleep(1e9) //讓Producer與Consumer完成
}

生產(chǎn)者goroutine往channel傳值，消費者goroutine往channel取值，這兩個goroutine通過channel完成通信。

以上就是Go語言CSP并發(fā)模型goroutine channel底層實現(xiàn)原理的詳細內(nèi)容，更多關(guān)于go CSP并發(fā)模型goroutine channel的資料請關(guān)注腳本之家其它相關(guān)文章！

最新評論