快捷導(dǎo)航

Go語(yǔ)言帶緩沖的通道實(shí)現(xiàn)

更新時(shí)間：2021年04月26日 11:43:03 投稿：zx

這篇文章主要介紹了Go語(yǔ)言帶緩沖的通道實(shí)現(xiàn)，文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧

Go語(yǔ)言中有緩沖的通道（buffered channel）是一種在被接收前能存儲(chǔ)一個(gè)或者多個(gè)值的通道。這種類(lèi)型的通道并不強(qiáng)制要求 goroutine 之間必須同時(shí)完成發(fā)送和接收。通道會(huì)阻塞發(fā)送和接收動(dòng)作的條件也會(huì)不同。只有在通道中沒(méi)有要接收的值時(shí)，接收動(dòng)作才會(huì)阻塞。只有在通道沒(méi)有可用緩沖區(qū)容納被發(fā)送的值時(shí)，發(fā)送動(dòng)作才會(huì)阻塞。

這導(dǎo)致有緩沖的通道和無(wú)緩沖的通道之間的一個(gè)很大的不同：無(wú)緩沖的通道保證進(jìn)行發(fā)送和接收的 goroutine 會(huì)在同一時(shí)間進(jìn)行數(shù)據(jù)交換；有緩沖的通道沒(méi)有這種保證。

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

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

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

如何創(chuàng)建帶緩沖的通道呢？參見(jiàn)如下代碼：

通道實(shí)例 := make(chan 通道類(lèi)型, 緩沖大小)

通道類(lèi)型：和無(wú)緩沖通道用法一致，影響通道發(fā)送和接收的數(shù)據(jù)類(lèi)型。
緩沖大?。簺Q定通道最多可以保存的元素?cái)?shù)量。
通道實(shí)例：被創(chuàng)建出的通道實(shí)例。

下面通過(guò)一個(gè)例子中來(lái)理解帶緩沖通道的用法，參見(jiàn)下面的代碼：

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

代碼輸出如下：
0
3

代碼說(shuō)明如下：

第 8 行，創(chuàng)建一個(gè)帶有 3 個(gè)元素緩沖大小的整型類(lèi)型的通道。
第 11 行，查看當(dāng)前通道的大小。帶緩沖的通道在創(chuàng)建完成時(shí)，內(nèi)部的元素是空的，因此使用 len() 獲取到的返回值為 0。
第 14～16 行，發(fā)送 3 個(gè)整型元素到通道。因?yàn)槭褂昧司彌_通道。即便沒(méi)有 goroutine 接收，發(fā)送者也不會(huì)發(fā)生阻塞。
第 19 行，由于填充了 3 個(gè)通道，此時(shí)的通道長(zhǎng)度變?yōu)?3。

阻塞條件

帶緩沖通道在很多特性上和無(wú)緩沖通道是類(lèi)似的。無(wú)緩沖通道可以看作是長(zhǎng)度永遠(yuǎn)為 0 的帶緩沖通道。因此根據(jù)這個(gè)特性，帶緩沖通道在下面列舉的情況下依然會(huì)發(fā)生阻塞：

帶緩沖通道被填滿(mǎn)時(shí)，嘗試再次發(fā)送數(shù)據(jù)時(shí)發(fā)生阻塞。
帶緩沖通道為空時(shí)，嘗試接收數(shù)據(jù)時(shí)發(fā)生阻塞。

為什么Go語(yǔ)言對(duì)通道要限制長(zhǎng)度而不提供無(wú)限長(zhǎng)度的通道？

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

到此這篇關(guān)于Go語(yǔ)言帶緩沖的通道實(shí)現(xiàn)的文章就介紹到這了,更多相關(guān)Go語(yǔ)言帶緩沖通道內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: