Golang中的channel程式碼示例----無緩衝、有緩衝、range、close
摘要：
// code_043_channel_unbuffered project main.go
package main
import (
"fmt"
"time"
)
func main() {
c := make(chan int,...
// 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")
}