本文實(shí)例分析了Go語(yǔ)言中關(guān)閉帶緩沖區(qū)的頻道。分享給大家供大家參考。具體分析如下：
Go語(yǔ)言提供了兩種頻道，帶緩沖區(qū)和不帶緩沖區(qū)的。不帶緩沖區(qū)的頻道，發(fā)送和接收是同步的，必須接收端接收了消息，發(fā)送端才能從發(fā)送調(diào)用中解脫。帶緩沖區(qū)的頻道，在緩沖區(qū)滿之前，發(fā)送和接收是異步的，發(fā)送端的發(fā)送操作只保證把消息放入緩沖區(qū)。
Go的頻道是可以關(guān)閉的，關(guān)閉頻道的目的是讓接收端知道不會(huì)再有消息從這個(gè)頻道進(jìn)入，我們可能會(huì)用某個(gè)頻道的關(guān)閉來(lái)表示某種狀態(tài)的終結(jié)。
當(dāng)我們關(guān)閉一個(gè)帶緩沖區(qū)的頻道時(shí)，如果緩沖區(qū)中還有消息，接收端是會(huì)繼續(xù)接收完剩余消息呢？還是直接就丟棄剩余消息呢？下面是我做的一個(gè)試驗(yàn)代碼：
復(fù)制代碼代碼如下:
package main
import "fmt"
func main() {
input := make(chan int, 10)
wait := make(chan int)
for i := 0; i < 10; i ++ {
input <- i
}
close(input)
go func() {
for {
if i, ok := <- input; ok {
fmt.Println(i)
} else {
break
}
}
wait <- 1
}()
<-wait
}
import "fmt"
func main() {
input := make(chan int, 10)
wait := make(chan int)
for i := 0; i < 10; i ++ {
input <- i
}
close(input)
go func() {
for {
if i, ok := <- input; ok {
fmt.Println(i)
} else {
break
}
}
wait <- 1
}()
<-wait
}
希望本文所述對(duì)大家的Go語(yǔ)言程序設(shè)計(jì)有所幫助。
