1.廣播

當一個通道關閉時, 所有此通道的讀取都會退出阻塞. 利用此特性可以實現廣播功能

package main

import (
    "fmt"
    "time"
)

func main() {
    c := make(chan bool)

    for i := 0; i < 5; i++ {
        go func(n int) {
            <-c //讀取到資料或通道關閉時會退出阻塞
            fmt.Println("收到通知:", n)
        }(i)

    }

    fmt.Println("廣播通知"
 
)
    close(c) //關閉通道, 廣播通知

    time.Sleep(time.Second * 1) //等待其它協程處理

}

2.同時讀取多個通道

有時需要監視多個通道, 這個時候可以使用select

package main

import (
    "fmt"
    "time"
)

func main() {
    c1 := make(chan int)
    c2 := make(chan int)

    go func() {
        var n int
        select {
        case n = <-c1:
        case
 
 n = <-c2:
        }
        fmt.Println("資料:", n)
    }()

    fmt.Println("寫入")
    c1 <- 1
    //c2 <- 2

    close(c1)
    close(c2)

    time.Sleep(time.Second * 1) //等待其它協程處理

}

3.超時

channel本身無法設定超時, 可以使用select和定時器實現超時功能

package main

import (
    "fmt"
    "time"
)

func main() {
    c := make
 
(chan int, 1)

    go func() {
        timeout := false
        var n int

        select {
        case n = <-c:
        case <-time.After(time.Second * 1):
            timeout = true
        }

        if timeout {
            fmt.Println("超時")
        } else {
            fmt.Println("讀取到資料:", n)
        }
    }()

    time.Sleep(time.Second * 2)
    c <- 2

    time.Sleep(time.Second * 3) //等待其它協程處理

}