Go語言帶緩沖的通道的使用
Go語言中有緩沖的通道(buffered channel)是一種在被接收前能存儲一個或者多個值的通道。這種類型的通道并不強(qiáng)制要求 goroutine 之間必須同時完成發(fā)送和接收。通道會阻塞發(fā)送和接收動作的條件也會不同。只有在通道中沒有要接收的值時,接收動作才會阻塞。只有在通道沒有可用緩沖區(qū)容納被發(fā)送的值時,發(fā)送動作才會阻塞。
這導(dǎo)致有緩沖的通道和無緩沖的通道之間的一個很大的不同:無緩沖的通道保證進(jìn)行發(fā)送和接收的 goroutine 會在同一時間進(jìn)行數(shù)據(jù)交換;有緩沖的通道沒有這種保證。
在無緩沖通道的基礎(chǔ)上,為通道增加一個有限大小的存儲空間形成帶緩沖通道。帶緩沖通道在發(fā)送時無需等待接收方接收即可完成發(fā)送過程,并且不會發(fā)生阻塞,只有當(dāng)存儲空間滿時才會發(fā)生阻塞。同理,如果緩沖通道中有數(shù)據(jù),接收時將不會發(fā)生阻塞,直到通道中沒有數(shù)據(jù)可讀時,通道將會再度阻塞。
無緩沖通道保證收發(fā)過程同步。無緩沖收發(fā)過程類似于快遞員給你電話讓你下樓取快遞,整個遞交快遞的過程是同步發(fā)生的,你和快遞員不見不散。但這樣做快遞員就必須等待所有人下樓完成操作后才能完成所有投遞工作。如果快遞員將快遞放入快遞柜中,并通知用戶來取,快遞員和用戶就成了異步收發(fā)過程,效率可以有明顯的提升。帶緩沖的通道就是這樣的一個“快遞柜”。
創(chuàng)建帶緩沖通道
如何創(chuàng)建帶緩沖的通道呢?參見如下代碼:
通道實(shí)例 := make(chan 通道類型, 緩沖大小)
- 通道類型:和無緩沖通道用法一致,影響通道發(fā)送和接收的數(shù)據(jù)類型。
- 緩沖大?。簺Q定通道最多可以保存的元素?cái)?shù)量。
- 通道實(shí)例:被創(chuàng)建出的通道實(shí)例。
下面通過一個例子中來理解帶緩沖通道的用法,參見下面的代碼:
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 個整型元素到通道。因?yàn)槭褂昧司彌_通道。即便沒有 goroutine 接收,發(fā)送者也不會發(fā)生阻塞。
- 第 19 行,由于填充了 3 個通道,此時的通道長度變?yōu)?3。
阻塞條件
帶緩沖通道在很多特性上和無緩沖通道是類似的。無緩沖通道可以看作是長度永遠(yuǎn)為 0 的帶緩沖通道。因此根據(jù)這個特性,帶緩沖通道在下面列舉的情況下依然會發(fā)生阻塞:
- 帶緩沖通道被填滿時,嘗試再次發(fā)送數(shù)據(jù)時發(fā)生阻塞。
- 帶緩沖通道為空時,嘗試接收數(shù)據(jù)時發(fā)生阻塞。
為什么Go語言對通道要限制長度而不提供無限長度的通道?
我們知道通道(channel)是在兩個 goroutine 間通信的橋梁。使用 goroutine 的代碼必然有一方提供數(shù)據(jù),一方消費(fèi)數(shù)據(jù)。當(dāng)提供數(shù)據(jù)一方的數(shù)據(jù)供給速度大于消費(fèi)方的數(shù)據(jù)處理速度時,如果通道不限制長度,那么內(nèi)存將不斷膨脹直到應(yīng)用崩潰。因此,限制通道的長度有利于約束數(shù)據(jù)提供方的供給速度,供給數(shù)據(jù)量必須在消費(fèi)方處理量+通道長度的范圍內(nèi),才能正常地處理數(shù)據(jù)。
到此這篇關(guān)于Go語言帶緩沖的通道的使用的文章就介紹到這了,更多相關(guān)Go語言帶緩沖通道內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!
- golang關(guān)閉chan通道的方法示例
- Go語言無緩沖的通道的使用
- 一文教你Golang如何正確關(guān)閉通道
- 詳解Golang中的通道機(jī)制與應(yīng)用
- Go語言?Channel通道詳解
- golang使用通道時需要注意的一些問題
- Go語言通道之無緩沖通道與緩沖通道詳解
- 一文帶你掌握Golang基礎(chǔ)之通道
- 超實(shí)用的Golang通道指南之輕松實(shí)現(xiàn)并發(fā)編程
- Go語言單向通道的實(shí)現(xiàn)
- 淺談golang通道類型
- Golang通道的無阻塞讀寫的方法示例
- Golang通道阻塞情況與通道無阻塞實(shí)現(xiàn)小結(jié)
相關(guān)文章
Golang限流器time/rate設(shè)計(jì)與實(shí)現(xiàn)詳解
在?Golang?庫中官方給我們提供了限流器的實(shí)現(xiàn)golang.org/x/time/rate,它是基于令牌桶算法(Token?Bucket)設(shè)計(jì)實(shí)現(xiàn)的,下面我們就來看看他的具體使用吧2024-03-03
Go語言中使用 buffered channel 實(shí)現(xiàn)線程安全的 pool
這篇文章主要介紹了Go語言中使用 buffered channel 實(shí)現(xiàn)線程安全的 pool,因?yàn)镚o語言自帶的sync.Pool并不是很好用,所以自己實(shí)現(xiàn)了一線程安全的 pool,需要的朋友可以參考下2014-10-10
關(guān)于Golang標(biāo)準(zhǔn)庫flag的全面講解
這篇文章主要介紹了關(guān)于Golang標(biāo)準(zhǔn)庫flag的全面講解,這個庫的代碼量只有1000行左右,卻提供了非常完善的命令行參數(shù)解析功能,更多相關(guān)內(nèi)容需要的朋友可以參考一下2022-09-09
以alpine作為基礎(chǔ)鏡像構(gòu)建Golang可執(zhí)行程序操作
這篇文章主要介紹了以alpine作為基礎(chǔ)鏡像構(gòu)建Golang可執(zhí)行程序操作,具有很好的參考價(jià)值,希望對大家有所幫助。一起跟隨小編過來看看吧2020-12-12
golang利用redis和gin實(shí)現(xiàn)保存登錄狀態(tài)校驗(yàn)登錄功能
這篇文章主要介紹了golang利用redis和gin實(shí)現(xiàn)保存登錄狀態(tài)校驗(yàn)登錄功能,本文給大家介紹的非常詳細(xì),對大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值,需要的朋友參考下吧2024-01-01
golang求連續(xù)子數(shù)組的最大和實(shí)例
這篇文章主要介紹了golang求連續(xù)子數(shù)組的最大和實(shí)例,具有很好的參考價(jià)值,希望對大家有所幫助。一起跟隨小編過來看看吧2020-12-12
Golang的os標(biāo)準(zhǔn)庫中常用函數(shù)的整理介紹
這篇文章主要介紹了Go語言的os標(biāo)準(zhǔn)庫中常用函數(shù),主要用來實(shí)現(xiàn)與操作系統(tǒng)的交互功能,需要的朋友可以參考下2015-10-10

