溫馨提示×

溫馨提示×

您好,登錄后才能下訂單哦!

密碼登錄×
登錄注冊×
其他方式登錄
點擊 登錄注冊 即表示同意《億速云用戶服務(wù)條款》

Go語言如何實現(xiàn)帶緩沖的通道

發(fā)布時間:2021-04-26 15:01:36 來源:億速云 閱讀:175 作者:小新 欄目:開發(fā)技術(shù)

這篇文章主要介紹Go語言如何實現(xiàn)帶緩沖的通道,文中介紹的非常詳細(xì),具有一定的參考價值,感興趣的小伙伴們一定要看完!

什么是go

go是golang的簡稱,golang 是Google開發(fā)的一種靜態(tài)強類型、編譯型、并發(fā)型,并具有垃圾回收功能的編程語言,其語法與 C語言相近,但并不包括如枚舉、異常處理、繼承、泛型、斷言、虛函數(shù)等功能。

Go語言中有緩沖的通道(buffered channel)是一種在被接收前能存儲一個或者多個值的通道。這種類型的通道并不強制要求 goroutine 之間必須同時完成發(fā)送和接收。通道會阻塞發(fā)送和接收動作的條件也會不同。只有在通道中沒有要接收的值時,接收動作才會阻塞。只有在通道沒有可用緩沖區(qū)容納被發(fā)送的值時,發(fā)送動作才會阻塞。

這導(dǎo)致有緩沖的通道和無緩沖的通道之間的一個很大的不同:無緩沖的通道保證進行發(fā)送和接收的 goroutine 會在同一時間進行數(shù)據(jù)交換;有緩沖的通道沒有這種保證。

在無緩沖通道的基礎(chǔ)上,為通道增加一個有限大小的存儲空間形成帶緩沖通道。帶緩沖通道在發(fā)送時無需等待接收方接收即可完成發(fā)送過程,并且不會發(fā)生阻塞,只有當(dāng)存儲空間滿時才會發(fā)生阻塞。同理,如果緩沖通道中有數(shù)據(jù),接收時將不會發(fā)生阻塞,直到通道中沒有數(shù)據(jù)可讀時,通道將會再度阻塞。

無緩沖通道保證收發(fā)過程同步。無緩沖收發(fā)過程類似于快遞員給你電話讓你下樓取快遞,整個遞交快遞的過程是同步發(fā)生的,你和快遞員不見不散。但這樣做快遞員就必須等待所有人下樓完成操作后才能完成所有投遞工作。如果快遞員將快遞放入快遞柜中,并通知用戶來取,快遞員和用戶就成了異步收發(fā)過程,效率可以有明顯的提升。帶緩沖的通道就是這樣的一個“快遞柜”。

創(chuàng)建帶緩沖通道

如何創(chuàng)建帶緩沖的通道呢?參見如下代碼:

通道實例 := make(chan 通道類型, 緩沖大小)

  • 通道類型:和無緩沖通道用法一致,影響通道發(fā)送和接收的數(shù)據(jù)類型。

  • 緩沖大小:決定通道最多可以保存的元素數(shù)量。

  • 通道實例:被創(chuàng)建出的通道實例。

下面通過一個例子中來理解帶緩沖通道的用法,參見下面的代碼:

package main
import "fmt"
func main() {
    // 創(chuàng)建一個3個元素緩沖大小的整型通道
    ch := make(chan int, 3)
    // 查看當(dāng)前通道的大小
    fmt.Println(len(ch))
    // 發(fā)送3個整型元素到通道
    ch <- 1
    ch <- 2
    ch <- 3
    // 查看當(dāng)前通道的大小
    fmt.Println(len(ch))
}

代碼輸出如下:
0
3

代碼說明如下:

  • 第 8 行,創(chuàng)建一個帶有 3 個元素緩沖大小的整型類型的通道。

  • 第 11 行,查看當(dāng)前通道的大小。帶緩沖的通道在創(chuàng)建完成時,內(nèi)部的元素是空的,因此使用 len() 獲取到的返回值為 0。

  • 第 14~16 行,發(fā)送 3 個整型元素到通道。因為使用了緩沖通道。即便沒有 goroutine 接收,發(fā)送者也不會發(fā)生阻塞。

  • 第 19 行,由于填充了 3 個通道,此時的通道長度變?yōu)?3。

阻塞條件

帶緩沖通道在很多特性上和無緩沖通道是類似的。無緩沖通道可以看作是長度永遠為 0 的帶緩沖通道。因此根據(jù)這個特性,帶緩沖通道在下面列舉的情況下依然會發(fā)生阻塞:

  • 帶緩沖通道被填滿時,嘗試再次發(fā)送數(shù)據(jù)時發(fā)生阻塞。

  • 帶緩沖通道為空時,嘗試接收數(shù)據(jù)時發(fā)生阻塞。

為什么Go語言對通道要限制長度而不提供無限長度的通道?

我們知道通道(channel)是在兩個 goroutine 間通信的橋梁。使用 goroutine 的代碼必然有一方提供數(shù)據(jù),一方消費數(shù)據(jù)。當(dāng)提供數(shù)據(jù)一方的數(shù)據(jù)供給速度大于消費方的數(shù)據(jù)處理速度時,如果通道不限制長度,那么內(nèi)存將不斷膨脹直到應(yīng)用崩潰。因此,限制通道的長度有利于約束數(shù)據(jù)提供方的供給速度,供給數(shù)據(jù)量必須在消費方處理量+通道長度的范圍內(nèi),才能正常地處理數(shù)據(jù)。

以上是“Go語言如何實現(xiàn)帶緩沖的通道”這篇文章的所有內(nèi)容,感謝各位的閱讀!希望分享的內(nèi)容對大家有幫助,更多相關(guān)知識,歡迎關(guān)注億速云行業(yè)資訊頻道!

向AI問一下細(xì)節(jié)

免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點不代表本網(wǎng)站立場,如果涉及侵權(quán)請聯(lián)系站長郵箱:is@yisu.com進行舉報,并提供相關(guān)證據(jù),一經(jīng)查實,將立刻刪除涉嫌侵權(quán)內(nèi)容。

AI