欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

Go語言CSP并發(fā)模型goroutine及channel底層實現(xiàn)原理

 更新時間:2022年05月25日 16:43:49   作者:正則化  
這篇文章主要為大家介紹了Go語言CSP并發(fā)模型goroutine?channel底層實現(xiàn)原理,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進(jìn)步,早日升職加薪

參考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)存的方式來進(jìn)行的。非常典型的方式就是,在訪問共享數(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之間的通信機(jī)制,即各個goroutine之間通信的”管道“,有點類似于Linux中的管道。

1、goroutine

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

goroutine機(jī)制有點像線程池:

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

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

example

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

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

當(dāng)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é)程) 默認(rèn)占用內(nèi)存遠(yuǎn)比 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)核打交道。當(dāng)goroutine進(jìn)行切換的時候,之后很少量的寄存器需要保存和恢復(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)

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

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

相應(yīng)的,當(dāng) channel 中消息不為空時,讀取消息不會出現(xiàn)阻塞,當(dāng) 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的??臻g

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

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

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)原理的詳細(xì)內(nèi)容,更多關(guān)于go CSP并發(fā)模型goroutine channel的資料請關(guān)注腳本之家其它相關(guān)文章!

相關(guān)文章

  • 構(gòu)建Golang應(yīng)用最小Docker鏡像的實現(xiàn)

    構(gòu)建Golang應(yīng)用最小Docker鏡像的實現(xiàn)

    這篇文章主要介紹了構(gòu)建Golang應(yīng)用最小Docker鏡像的實現(xiàn),文中通過示例代碼介紹的非常詳細(xì),對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧
    2020-05-05
  • Golang內(nèi)存管理之垃圾收集器詳解

    Golang內(nèi)存管理之垃圾收集器詳解

    這篇文章我們主要介紹垃圾收集器的設(shè)計原理以及Golang垃圾收集器的實現(xiàn)原理,文中有詳細(xì)的代碼示例及圖文介紹,感興趣的小伙伴跟著小編一起來學(xué)習(xí)吧
    2023-06-06
  • 詳解golang channel有無緩沖區(qū)的區(qū)別

    詳解golang channel有無緩沖區(qū)的區(qū)別

    這篇文章主要給大家介紹了golang channel有無緩沖區(qū)的區(qū)別,無緩沖是同步的,有緩沖是異步的,文中通過代碼示例給大家講解的非常詳細(xì),需要的朋友可以參考下
    2024-01-01
  • GoRoutines高性能同時進(jìn)行多個Api調(diào)用實現(xiàn)

    GoRoutines高性能同時進(jìn)行多個Api調(diào)用實現(xiàn)

    這篇文章主要為大家介紹了GoRoutines高性能同時進(jìn)行多個Api調(diào)用實現(xiàn)示例,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進(jìn)步,早日升職加薪
    2023-03-03
  • 深入了解Golang官方container/list原理

    深入了解Golang官方container/list原理

    在?Golang?的標(biāo)準(zhǔn)庫?container?中,包含了幾種常見的數(shù)據(jù)結(jié)構(gòu)的實現(xiàn),其實是非常好的學(xué)習(xí)材料,本文主要為大家介紹了container/list的原理與使用,感興趣的可以了解一下
    2023-08-08
  • golang微服務(wù)框架基礎(chǔ)Gin基本路由使用詳解

    golang微服務(wù)框架基礎(chǔ)Gin基本路由使用詳解

    這篇文章主要為大家介紹了golang微服務(wù)框架Gin基本路由的使用示例詳解,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進(jìn)步
    2021-11-11
  • 探索Golang?Redis實現(xiàn)發(fā)布訂閱功能實例

    探索Golang?Redis實現(xiàn)發(fā)布訂閱功能實例

    這篇文章主要介紹了Golang?Redis發(fā)布訂閱功能實例探索,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進(jìn)步,早日升職加薪
    2024-01-01
  • Golang實現(xiàn)Biginteger大數(shù)計算實例詳解

    Golang實現(xiàn)Biginteger大數(shù)計算實例詳解

    這篇文章主要為大家介紹了Golang實現(xiàn)Biginteger大數(shù)計算實例詳解,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進(jìn)步,早日升職加薪
    2022-07-07
  • GO語言(golang)基礎(chǔ)知識

    GO語言(golang)基礎(chǔ)知識

    這篇文章主要介紹了GO語言(golang)基礎(chǔ)知識,需要的朋友可以參考下
    2015-01-01
  • Go語言實現(xiàn)的簡單網(wǎng)絡(luò)端口掃描方法

    Go語言實現(xiàn)的簡單網(wǎng)絡(luò)端口掃描方法

    這篇文章主要介紹了Go語言實現(xiàn)的簡單網(wǎng)絡(luò)端口掃描方法,實例分析了Go語言網(wǎng)絡(luò)程序的實現(xiàn)技巧,具有一定參考借鑒價值,需要的朋友可以參考下
    2015-02-02

最新評論