Golang中的channel代碼示例----無緩沖、有緩沖、range、close

// 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")
}