Golang中的channel代碼示例----無緩沖、有緩沖、range、close
阿新 • • 發佈:2018-10-08
數量 nbu -- 協程 channel 運行 package break dead
// code_043_channel_unbuffered project main.go
package main
import (
"fmt"
"time"
)
func main() {
c := make(chan int, 0) //無緩沖的通道
//內置函數 len 返回未被讀取的緩沖元素數量, cap 返回緩沖區大小
fmt.Printf("len(c)=%d, cap(c)=%d\n", len(c), cap(c))
go func() {
defer fmt.Println("子協程結束")
for i := 0; i < 3; i++ {
fmt.Printf("子協程正在運行[%d]: len(c)=%d, cap(c)=%d\n", i, len(c), cap(c))
c <- i //備註:如果在上面的話, 不會執行最後一次Printf
}
}()
time.Sleep(2 * time.Second) //延時2s
for i := 0; i < 3; i++ {
num := <-c //從c中接收數據,並賦值給num
fmt.Println("num = ", num)
}
fmt.Println("main協程結束")
}
// code_044_channel_buffered project main.go package main import ( "fmt" "time" ) //有緩沖的通道(buffered channel)是一種在被接收前能存儲一個或者多個值的通道。 //只有在通道中沒有要接收的值時,接收動作才會阻塞。只有在通道沒有可用緩沖區容納被發送的值時,發送動作才會阻塞。 //有緩沖的通道和無緩沖的通道之間的不同: //1)無緩沖的通道保證進行發送和接收的 goroutine 會在同一時間進行數據交換; //2)有緩沖的通道沒有這種保證 func main() { c := make(chan int, 3) fmt.Printf("len(c)=%d, cap(c)=%d\n", len(c), cap(c)) go func() { defer fmt.Println("子協程結束") for i := 0; i < 3; i++ { c <- i fmt.Printf("子協程正在運行[%d]: len(c)=%d, cap(c)=%d\n", i, len(c), cap(c)) } }() time.Sleep(2 * time.Second) for i := 0; i < 3; i++ { num := <-c fmt.Println("num=", num) } fmt.Println("main協程結束") }
// code_045_channel_range_close project main.go package main import ( "fmt" ) //註意點: //?channel不像文件一樣需要經常去關閉,只有當你確實沒有任何發送數據了,或者你想顯式的結束range循環之類的,才去關閉channel; //?關閉channel後,無法向channel 再發送數據(引發 panic 錯誤後導致接收立即返回零值); //?關閉channel後,可以繼續向channel接收數據; // 對於nil channel,無論收發都會被阻塞。 /* close()的使用 func main() { c := make(chan int) go func() { for i := 0; i < 5; i++ { c <- i } //把 close(c) 註釋掉,程序會一直阻塞在 if data, ok := <-c; ok 那一行 //註釋後報錯“死鎖”:fatal error: all goroutines are asleep - deadlock! close(c) }() for { //ok為true說明channel沒有關閉,為false說明管道已經關閉 if data, ok := <-c; ok { fmt.Println(data) } else { break } } fmt.Println("Finished") } */ func main() { c := make(chan int) go func() { for i := 0; i < 5; i++ { c <- i } close(c) }() for data := range c { fmt.Println(data) } fmt.Println("Finished") }
Golang中的channel代碼示例----無緩沖、有緩沖、range、close