在Go語言中,緩沖通道是一種特殊類型的通道,它與普通通道的行為有所不同。普通通道在發(fā)送數(shù)據(jù)時,發(fā)送者會被阻塞,直到有接收者接收數(shù)據(jù)為止。而緩沖通道則允許發(fā)送者在通道未滿時繼續(xù)發(fā)送數(shù)據(jù),而不會被阻塞。這樣一來,發(fā)送者可以更快地完成發(fā)送操作,而不需要等待接收者。對于Go語言的使用者來說,緩沖通道的行為可以提供更高的并發(fā)性能和更好的響應(yīng)速度。
問題內(nèi)容
我試圖了解緩沖通道的工作原理并為其編寫代碼片段
package main import ( "fmt" ) func squares(c chan int) { for i := 0; i < 4; i++ { num := <-c fmt.println(num * num) } } func main() { fmt.println("main() started") c := make(chan int, 3) go squares(c) c <- 1 c <- 2 c <- 3 c <- 4 // blocks here fmt.println("main() stopped") }
登錄后復(fù)制
按照我預(yù)期程序的行為方式,主 goroutine 啟動并持續(xù)到 c<-4,此時它被阻塞,控制權(quán)轉(zhuǎn)到 square goroutine(因為緩沖區(qū)容量為 3)。 squares goroutine 中的循環(huán)一直持續(xù)到第四次迭代,此時通道為空。空通道上的讀取操作會被阻塞,因此控制權(quán)會返回到主 goroutine。此時,對通道(c<-4)的寫入操作被執(zhí)行,我們打印“main()已停止”,程序結(jié)束。
意思是我期望的輸出是,
main() started 1 4 9 main() stopped
登錄后復(fù)制
但是我得到了輸出,
main() started 1 4 9 16 main() stopped
登錄后復(fù)制
如何?我是否遺漏了渠道到底如何運作的一些信息?
解決方法
渠道不是這樣運作的。
Goroutines 并發(fā)運行。這意味著當一個 Goroutine 發(fā)送到緩沖通道時,另一個等待從該通道接收的 Goroutine 可以立即接收它。它不會等待通道填滿。
至于程序的結(jié)束,當你將最后一個數(shù)字發(fā)送到通道時,不能保證 goroutine 會在程序結(jié)束之前拾取它并打印輸出,因為你沒有等待 goroutine完全的。因此,幸運的是,它運行并打印輸出。還會有其他執(zhí)行不會發(fā)生這種情況,并且程序會在 goroutine 打印輸出之前終止。