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