在 Go 中，ch := make(chan int) 创建了一个通道（channel），用于在不同的 goroutine 之间安全地传递整数类型的值。通道是 Go 并发编程中的一个核心概念，它提供了一种在 goroutine 之间进行通信和同步的机制。

通道的基本用法

1. 创建通道

ch := make(chan int)

这行代码创建了一个无缓冲的通道，用于传递整数类型的值。无缓冲的通道意味着发送值到通道的 goroutine 会阻塞，直到有另一个 goroutine 从通道中接收值。

2. 发送值到通道

ch <- 42

这行代码将整数 42 发送到通道 ch 中。如果通道是无缓冲的，发送操作会阻塞，直到有另一个 goroutine 从通道中接收值。

3. 从通道接收值

value := <-ch

这行代码从通道 ch 中接收一个值，并将其赋给变量 value。如果通道是无缓冲的，接收操作会阻塞，直到有另一个 goroutine 向通道中发送值。

示例代码

以下是一个完整的示例，展示如何使用通道在两个 goroutine 之间传递值：

package main

import (
    "fmt"
    "time"
)

func sender(ch chan int) {
    for i := 1; i <= 5; i++ {
        ch <- i // 发送值到通道
        fmt.Printf("Sent %d\n", i)
    }
    close(ch) // 关闭通道
}

func receiver(ch chan int) {
    for value := range ch { // 从通道接收值
        fmt.Printf("Received %d\n", value)
        time.Sleep(1 * time.Second)
    }
}

func main() {
    ch := make(chan int) // 创建通道

    go sender(ch)        // 启动发送者 goroutine
    go receiver(ch)      // 启动接收者 goroutine

    time.Sleep(6 * time.Second) // 等待所有值被发送和接收
    fmt.Println("Main goroutine is exiting...")
}

输出示例

运行上述代码后，你可能会看到类似以下的输出：

Sent 1
Received 1
Sent 2
Received 2
Sent 3
Received 3
Sent 4
Received 4
Sent 5
Received 5
Main goroutine is exiting...

通道的类型

1. 无缓冲通道（Unbuffered Channel）

   • 无缓冲通道是最简单的通道类型，发送和接收操作是同步的。发送值到无缓冲通道的 goroutine 会阻塞，直到有另一个 goroutine 从通道中接收值。

   • 示例：

     ch := make(chan int)
     

2. 带缓冲通道（Buffered Channel）

   • 带缓冲通道有一个固定大小的缓冲区，可以在缓冲区未满时非阻塞地发送值。如果缓冲区已满，发送操作会阻塞，直到有另一个 goroutine 从通道中接收值。

   • 示例：

     ch := make(chan int, 3) // 创建一个大小为 3 的带缓冲通道
     

通道的关闭

• 关闭通道：使用 close(ch) 关闭通道。关闭通道后，不能再向通道发送值，但可以从通道中接收值，直到缓冲区为空。
• 接收已关闭通道的值：从已关闭的通道中接收值时，会返回通道中的值，直到缓冲区为空。之后，接收操作会返回零值，但不会阻塞。

通道的用途

1. 数据传递：在 goroutine 之间传递数据。
2. 同步：通过通道的阻塞特性，实现 goroutine 之间的同步。
3. 信号传递：用于在 goroutine 之间传递信号，例如通知 goroutine 退出。

示例：使用通道传递信号

package main

import (
    "fmt"
    "time"
)

func worker(stop chan bool) {
    for {
        select {
        case <-stop: // 检查是否有停止信号
            fmt.Println("Worker received stop signal, exiting...")
            return
        default:
            fmt.Println("Worker is running...")
            time.Sleep(1 * time.Second)
        }
    }
}

func main() {
    stop := make(chan bool) // 创建一个通道用于传递停止信号

    go worker(stop) // 启动一个 worker goroutine

    time.Sleep(5 * time.Second) // 让 worker 运行一段时间
    stop <- true                // 发送停止信号
    fmt.Println("Main goroutine is exiting...")
}

输出示例

运行上述代码后，你可能会看到类似以下的输出：

Worker is running...
Worker is running...
Worker is running...
Worker is running...
Worker is running...
Worker received stop signal, exiting...
Main goroutine is exiting...

总结

• 通道（Channel）：用于在 goroutine 之间安全地传递值。
• 无缓冲通道：发送和接收操作是同步的。
• 带缓冲通道：发送操作可以在缓冲区未满时非阻塞地进行。
• 关闭通道：使用 close(ch) 关闭通道，接收已关闭通道的值时会返回零值。
• 用途：数据传递、同步、信号传递。

希望这些信息对你有帮助！如果有任何问题，请随时提问。