基本設(shè)計(jì)思路：
成都創(chuàng)新互聯(lián)是一家專業(yè)提供即墨企業(yè)網(wǎng)站建設(shè),專注與網(wǎng)站設(shè)計(jì)制作、成都網(wǎng)站制作、H5場(chǎng)景定制、小程序制作等業(yè)務(wù)。10年已為即墨眾多企業(yè)、政府機(jī)構(gòu)等服務(wù)。創(chuàng)新互聯(lián)專業(yè)網(wǎng)站設(shè)計(jì)公司優(yōu)惠進(jìn)行中。
類型轉(zhuǎn)換、類型斷言、動(dòng)態(tài)派發(fā)。iface，eface。
反射對(duì)象具有的方法：
編譯優(yōu)化：
內(nèi)部實(shí)現(xiàn)：
實(shí)現(xiàn) Context 接口有以下幾個(gè)類型（空實(shí)現(xiàn)就忽略了）：
互斥鎖的控制邏輯：
設(shè)計(jì)思路：
（以上為寫被讀阻塞，下面是讀被寫阻塞）
總結(jié)，讀寫鎖的設(shè)計(jì)還是非常巧妙的：
設(shè)計(jì)思路：
WaitGroup 有三個(gè)暴露的函數(shù):
部件：
設(shè)計(jì)思路：
結(jié)構(gòu)：
Once 只暴露了一個(gè)方法：
實(shí)現(xiàn)：
三個(gè)關(guān)鍵點(diǎn)：
細(xì)節(jié)：
讓多協(xié)程任務(wù)的開始執(zhí)行時(shí)間可控（按順序或歸一）。（Context 是控制結(jié)束時(shí)間）
設(shè)計(jì)思路： 通過(guò)一個(gè)鎖和內(nèi)置的 notifyList 隊(duì)列實(shí)現(xiàn)，Wait() 會(huì)生成票據(jù)，并將等待協(xié)程信息加入鏈表中，等待控制協(xié)程中發(fā)送信號(hào)通知一個(gè)（Signal()）或所有（Boardcast()）等待者（內(nèi)部實(shí)現(xiàn)是通過(guò)票據(jù)通知的）來(lái)控制協(xié)程解除阻塞。
暴露四個(gè)函數(shù)：
實(shí)現(xiàn)細(xì)節(jié)：
部件：
包： golang.org/x/sync/errgroup
作用：開啟 func() error 函數(shù)簽名的協(xié)程，在同 Group 下協(xié)程并發(fā)執(zhí)行過(guò)程并收集首次 err 錯(cuò)誤。通過(guò) Context 的傳入，還可以控制在首次 err 出現(xiàn)時(shí)就終止組內(nèi)各協(xié)程。
設(shè)計(jì)思路：
結(jié)構(gòu)：
暴露的方法：
實(shí)現(xiàn)細(xì)節(jié)：
注意問(wèn)題：
包： "golang.org/x/sync/semaphore"
作用：排隊(duì)借資源（如錢，有借有還）的一種場(chǎng)景。此包相當(dāng)于對(duì)底層信號(hào)量的一種暴露。
設(shè)計(jì)思路：有一定數(shù)量的資源 Weight，每一個(gè) waiter 攜帶一個(gè) channel 和要借的數(shù)量 n。通過(guò)隊(duì)列排隊(duì)執(zhí)行借貸。
結(jié)構(gòu)：
暴露方法：
細(xì)節(jié)：
部件：
細(xì)節(jié)：
包： "golang.org/x/sync/singleflight"
作用：防擊穿。瞬時(shí)的相同請(qǐng)求只調(diào)用一次，response 被所有相同請(qǐng)求共享。
設(shè)計(jì)思路：按請(qǐng)求的 key 分組（一個(gè) *call 是一個(gè)組，用 map 映射存儲(chǔ)組），每個(gè)組只進(jìn)行一次訪問(wèn)，組內(nèi)每個(gè)協(xié)程會(huì)獲得對(duì)應(yīng)結(jié)果的一個(gè)拷貝。
結(jié)構(gòu)：
邏輯：
細(xì)節(jié)：
部件：
如有錯(cuò)誤，請(qǐng)批評(píng)指正。
在 Golang 游戲leaf系列(一) 概述與示例 (下文簡(jiǎn)稱系列一)中，提到過(guò)Go模塊用于創(chuàng)建能夠被 Leaf 管理的 goroutine。Go模塊是對(duì)golang中g(shù)o提供一些額外功能。Go提供回調(diào)功能，LinearContext提供順序調(diào)用功能。善用 goroutine 能夠充分利用多核資源，Leaf 提供的 Go 機(jī)制解決了原生 goroutine 存在的一些問(wèn)題：
我們來(lái)看一個(gè)例子（可以在 LeafServer 的模塊的 OnInit 方法中測(cè)試）：
這里的 Go 方法接收 2 個(gè)函數(shù)作為參數(shù)，第一個(gè)函數(shù)會(huì)被放置在一個(gè)新創(chuàng)建的 goroutine 中執(zhí)行，在其執(zhí)行完成之后，第二個(gè)函數(shù)會(huì)在當(dāng)前 goroutine 中被執(zhí)行。由此，我們可以看到變量 res 同一時(shí)刻總是只被一個(gè) goroutine 訪問(wèn)，這就避免了同步機(jī)制的使用。Go 的設(shè)計(jì)使得 CPU 得到充分利用，避免操作阻塞當(dāng)前 goroutine，同時(shí)又無(wú)需為共享資源同步而憂心。
這里主動(dòng)調(diào)用了 d.Cb(-d.ChanCb) ，把這個(gè)回調(diào)取出來(lái)了。實(shí)際上，在skeleton.Run里會(huì)自己取這個(gè)通道
看一下源碼：
New方法，會(huì)生成指定緩沖長(zhǎng)度的ChanCb。然后調(diào)用Go方法就是先執(zhí)行第一個(gè)func,然后把第二個(gè)放到Cb里。現(xiàn)在手動(dòng)造一個(gè)例子：
這里解釋一下，d.Go根據(jù)源碼來(lái)看，實(shí)際也是調(diào)用了一個(gè)協(xié)程。然后上面兩次d.Go并不能保證先后順序。目前的輸出結(jié)果是1+2那個(gè)先執(zhí)行了，把3寫入d.ChanCb，然后把3讀出來(lái)，繼續(xù)讀時(shí)，d.ChanCb里沒有東西，阻塞了。然后1+1那個(gè)協(xié)程啟動(dòng)了，最后又讀到了2。
現(xiàn)在把time.Sleep(time.Second)的注釋解開，會(huì)是啥結(jié)果呢
這里執(zhí)行到time.Sleep睡著了，上面兩個(gè)d.Go仍然是不確定順序的，但是會(huì)各自的function先執(zhí)行掉，然后陸續(xù)把cb寫入d.ChanCb?？催@次輸出，1+2先寫進(jìn)去的。所以最后執(zhí)行d.Cb時(shí)，就把3先讀出來(lái)了。然后d.ChanCb的長(zhǎng)度為1，說(shuō)明還有一個(gè)，就是輸出2了。
另外，就是close時(shí)會(huì)判斷g.pendingGo
這個(gè)例子的意思很明顯，NewLinearContext這種方式，即使先調(diào)用的慢了半秒，它還是會(huì)先執(zhí)行完。
這里先是用了一個(gè)list，加入的時(shí)候用mutexLinearGo鎖了，都加到最后。然后新開協(xié)程去處理，讀的時(shí)候從最前面開始讀，也要用mutexLinearGo鎖。執(zhí)行的時(shí)候，也要上鎖mutexExecution，確保f()執(zhí)行完并且寫入g.ChanCb回調(diào)，這個(gè)mutexExecution鎖才會(huì)解除?，F(xiàn)在可以改造一個(gè)帶回調(diào)的例子：
結(jié)果說(shuō)明，確實(shí)是2先被寫入了d.ChanCb。
無(wú)緩沖的通道（unbuffered channel）是指在接收前沒有能力保存任何值的通道。
這種類型的通道要求發(fā)送goroutine和接收goroutine同時(shí)準(zhǔn)備好，才能完成發(fā)送和接收操作。否則，通道會(huì)導(dǎo)致先執(zhí)行發(fā)送或接收操作的 goroutine 阻塞等待。
這種對(duì)通道進(jìn)行發(fā)送和接收的交互行為本身就是同步的。其中任意一個(gè)操作都無(wú)法離開另一個(gè)操作單獨(dú)存在。
阻塞：由于某種原因數(shù)據(jù)沒有到達(dá)，當(dāng)前協(xié)程（線程）持續(xù)處于等待狀態(tài)，直到條件滿足，才接觸阻塞。
同步：在兩個(gè)或多個(gè)協(xié)程（線程）間，保持?jǐn)?shù)據(jù)內(nèi)容一致性的機(jī)制。
下圖展示兩個(gè) goroutine 如何利用無(wú)緩沖的通道來(lái)共享一個(gè)值：
在第 1 步，兩個(gè) goroutine 都到達(dá)通道，但哪個(gè)都沒有開始執(zhí)行發(fā)送或者接收。
在第 2 步，左側(cè)的 goroutine 將它的手伸進(jìn)了通道，這模擬了向通道發(fā)送數(shù)據(jù)的行為。這時(shí)，這個(gè) goroutine 會(huì)在通道中被鎖住，直到交換完成。
在第 3 步，右側(cè)的 goroutine 將它的手放入通道，這模擬了從通道里接收數(shù)據(jù)。這個(gè) goroutine 一樣也會(huì)在通道中被鎖住，直到交換完成。
在第 4 步和第 5 步，進(jìn)行交換，并最終，在第 6 步，兩個(gè) goroutine 都將它們的手從通道里拿出來(lái)，這模擬了被鎖住的 goroutine 得到釋放。兩個(gè) goroutine 現(xiàn)在都可以去做別的事情了。
如果沒有指定緩沖區(qū)容量，那么該通道就是同步的，因此會(huì)阻塞到發(fā)送者準(zhǔn)備好發(fā)送和接收者準(zhǔn)備好接收。
無(wú)緩沖channel： —— 同步通信
Hello，大家好，又見面了！上一遍我們將 channel 相關(guān)基礎(chǔ)以及使用場(chǎng)景。這一篇，還需要再次進(jìn)階理解channel 阻塞問(wèn)題。以下創(chuàng)建一個(gè)chan類型為int，cap 為3。
channel 內(nèi)部其實(shí)是一個(gè)環(huán)形buf數(shù)據(jù)結(jié)構(gòu) ，是一種滑動(dòng)窗口機(jī)制，當(dāng)make完后，就分配在 Heap 上。
上面，向 chan 發(fā)送一條“hello”數(shù)據(jù)：
如果 G1 發(fā)送數(shù)據(jù)超過(guò)指定cap時(shí)，會(huì)出現(xiàn)什么情況？
看下面實(shí)例：
以上會(huì)出現(xiàn)什么，chan 緩沖區(qū)允許大小為1，如果再往chan仍數(shù)據(jù)，滿了就會(huì)被阻塞，那么是如何實(shí)現(xiàn)阻塞的呢？當(dāng) chan 滿時(shí)，會(huì)進(jìn)入 gopark，此時(shí) G1 進(jìn)入一個(gè) waiting 狀態(tài)，然后會(huì)創(chuàng)建一個(gè) sudog 對(duì)象，其實(shí)就sendq隊(duì)列，把 200放進(jìn)去。等 buf 不滿的時(shí)候，再喚醒放入buf里面。
通過(guò)如下源碼，你會(huì)更加清晰：
上面，從 chan 獲取數(shù)據(jù)：
Go 語(yǔ)言核心思想：“Do not communicate by sharing memory; instead, share memory by communicating.” 你可以看看這本書名叫：Effective Go
如果接收者，接收一個(gè)空對(duì)象，也會(huì)發(fā)生什么情況？
代碼示例 ：
也會(huì)報(bào)錯(cuò)如下：
上面，從 chan 取出數(shù)據(jù)，可是沒有數(shù)據(jù)了。此時(shí)，它會(huì)把 接收者 G2 阻塞掉，也是和G1發(fā)送者一樣，也會(huì)執(zhí)行 gopark 將狀態(tài)改為 waiting，不一樣的點(diǎn)就是。
正常情況下，接收者G2作為取出數(shù)據(jù)是去 buf 讀取數(shù)據(jù)的，但現(xiàn)在，buf 為空了，此時(shí)，接收者G2會(huì)將sudog導(dǎo)出來(lái)，因?yàn)楝F(xiàn)在G2已經(jīng)被阻塞了嘛，會(huì)把G2給G，然后將 t := -ch 中變量 t 是在棧上的地址，放進(jìn)去 elem ，也就是說(shuō)，只存它的地址指針在sudog里面。
最后， ch - 200 當(dāng)G1往 chan 添加200這個(gè)數(shù)據(jù)，正常情況是將數(shù)據(jù)添加到buf里面，然后喚醒 G2 是吧，而現(xiàn)在是將 G1 的添加200數(shù)據(jù)直接干到剛才G2阻塞的t這里變量里面。
你會(huì)認(rèn)為，這樣真的可以嗎？想一想，G2 本來(lái)就是已經(jīng)阻塞了，然后我們直接這么干肯定沒有什么毛病，而且效率提高了，不需要再次放入buf再取出，這個(gè)過(guò)程也是需要時(shí)間。不然，不得往chan添加數(shù)據(jù)需要加鎖、拷貝、解鎖一序列操作，那肯定就慢了，我想Go語(yǔ)言是為了高效及內(nèi)存使用率的考慮這樣設(shè)計(jì)的。（注意，一般都是在runtime里面完成，不然會(huì)出現(xiàn)象安全問(wèn)題。）
總結(jié) ：
chan 類型的特點(diǎn)：chan 如果為空，receiver 接收數(shù)據(jù)的時(shí)候就會(huì)阻塞等待，直到 chan 被關(guān)閉或者有新的數(shù)據(jù)到來(lái)。有這種個(gè)機(jī)制，就可以實(shí)現(xiàn) wait/notify 的設(shè)計(jì)模式。
相關(guān)面試題：
重慶分公司
重慶分公司
