golang使用通道时需要注意的一些问题

ch := make(chan int) // 可存放int类型数据，缓冲为0
ch := make(chan any) // 可存放任意类型数据，缓冲为0
ch := make(chan int, 5) // 存放int类型数据，缓冲为5
// 默认的通道是既可以写入又可以读取的，但我们也可以限制通道的方向
ch := make(<-chan int) // 只能从此通道读取数据，且不能关闭此通道
ch := make(chan<- int) // 只能写入数据到此通道
length := len(ch) // 通道里有多少个数据
capacity := cap(ch) // 通道的缓冲区大小

func display(msg ...any) {
    fmt.Print(time.Now().Format(time.DateTime), " ")
    fmt.Println(msg...)
}

func main() {
    ch := make(chan int)
    // 协程1
    go func() {
        for i := 0; i < 3; i++ {
            display("准备发送：", i)
            ch <- i
            display("已发送完毕：", i)
        }
    }()
    for data := range ch {
        display("获得数据：", data)
    }
}

func main() {
    ch := make(chan int)
    // 协程1
    go func() {
        for i := 0; i < 3; i++ {
            display("准备发送：", i)
            ch <- i
            display("已发送完毕：", i)
        }
    }()
    // 协程2
    go func() {
        for data := range ch {
            display("获得数据：", data)
        }
    }()
    // 死循环
    for {
    }
}

func main() {
    ch := make(chan int)
    // 协程1
    go func() {
        for i := 0; i < 3; i++ {
            display("准备发送：", i)
            ch <- i
            display("已发送完毕：", i)
        }
        close(ch) // 新添加代码
    }()
    for data := range ch {
        display("获得数据：", data)
    }
}

func main() {
    ch := make(chan int, 2)
    ch <- 123
    ch <- 456
    close(ch)
    // 使用for-range读取已关闭通道，通道空了之后会自动跳出循环
    for data := range ch {
        display(data)
    }
    // 方式2：使用ok变量判断通道是否已空
    /*for {
        data, ok := <-ch
        if !ok {
            break
        }
        display(data)
    }*/
    // 方式3：通过通道长度来判断通道是否已空
    /*num := len(ch)
    for i := 0; i < num; i++ {
        data := <-ch
        display(data)
    }*/
}

// 函数参数是单向通道
func sendMessage(in chan<- int) {
    for i := 0; i < 3; i++ {
        in <- i
    }
    close(in)
}
func main() {
    ch := make(chan int) // 双向通道
    go sendMessage(ch)
    for data := range ch {
        display(data)
    }
}

func sendMessage(in chan<- int, sleep time.Duration) {
    time.Sleep(sleep)
    in <- 1
}
func main() {
    display("开始")
    display("协程数量：", runtime.NumGoroutine())
    ch1 := make(chan int) // 错误
    // 正确：ch1 := make(chan int, 1)
    // 协程1
    go sendMessage(ch1, 5 * time.Second)
    select {
    case v := <-ch1:
        display("从通道1获取到了数据：", v)
    case <-time.After(1 * time.Second):
        display("超时了，退出select")
    }
    for {
        display("协程数量：", runtime.NumGoroutine())
        time.Sleep(1 * time.Second)
    }
}