Golang通道（Channel）入门：创建、通信与实战示例

为什么使用通道

在其他语言如Java中，多线程通信通常依赖于锁（synchronized）或原子类对象（如AtomicInteger）来协调资源访问。相比之下，Go语言提倡“不要通过共享内存来通信，而要通过通信来共享内存”。通道在多个goroutine之间架起了管道，不仅传递数据，还自动提供了同步交换数据的机制，确保数据读写的安全性与顺序性。

图：goroutine 与 channel 的通信示意图

如何创建通道

在Go中，通道的创建需要使用内置函数 make，并必须指定通道的数据类型。只有相同类型的值才能在该通道中传输。

第1步：定义通道类型

目的： 确定通道中流动的数据形态。
语法： chanName := make(chan DataType)
注意： 如果未指定数据类型，编译器可能无法推断，建议显式声明。

// 1. 创建接收整数int的通道
ch1 := make(chan int)

// 2. 创建接收任意对象interface{}的通道（类似泛型或Any，但需谨慎使用）
ch2 := make(chan interface{})

// 3. 创建接收User结构体指针的通道
ch3 := make(chan *User)

向通道发送数据

目的： 将数据推入通道供其他goroutine读取。
入口： 当前代码上下文。
动作： 使用箭头符号 <- 指向通道变量。
完成状态： 数据成功写入通道缓冲区或直接传递给接收者。

// 给 ch1 发送整数 0
ch1 <- 0

// 给 ch2 发送字符串（因类型为 interface{}，可发任意对象）
ch2 <- "hello, mars酱"

// 构造结构体并发送其指针
userInfo := User{ID: 1, Name: "mars酱"}
ch3 <- &userInfo

重要提醒： 上述单独发送的代码片段在实际运行时会报错或阻塞，因为Go语言的通道操作遵循严格同步规则：**发送和接收必须成对出现**，否则发送方会一直等待直到有接收方到来。

从通道接收数据

目的： 从通道中获取数据并继续执行后续逻辑。
入口： 消费端goroutine。
动作： 使用 <- chanName 形式。

场景A：阻塞式接收

参数： data := <- ch
行为： 这是最常见的用法。程序会暂停在此行，直到通道中有数据到达或通道被关闭。
结果： 接收到的值赋值给变量 data。

data := <- ch1

场景B：非阻塞检测

参数： data, ok := <- ch
行为： 尝试接收数据。
结果： data 接收到的值（若未收到则为该类型的零值），ok 为布尔值，表示是否成功接收到数据。若通道已关闭且无数据，ok 将为 false。

data, ok := <- ch1

场景C：忽略接收

动作： <- ch
目的： 仅为了推进进度或清空缓冲区，不关心具体数据内容。

<- ch1 // 丢弃通道中的数据

实战示例：并发倒数计时器

下面通过一个具体的例子，展示如何利用通道在goroutine间实现一个每秒递减的倒数器。这模拟了火箭发射前的倒计时场景。

第1步：初始化测试环境

func Test_chanTest(t *testing.T) {
	// 1. 创建一个整型通道
	ch1 := make(chan int)

	// 2. 启动一个独立的 goroutine 进行倒数
	go func() {
		for i := 5; i >= 0; i-- {
			// 3. 将当前数值发送到通道
			ch1 <- i
			// 间隔1秒后发送下一个
			time.Sleep(time.Second)
		}
		close(ch1) // 倒数结束后关闭通道，通知接收方结束循环
	}()

	// 4. 在主协程中使用 range 遍历通道
	for data := range ch1 {
		fmt.Println(data)
		if data == 0 {
			break
		}
	}
}

图：倒数计时器运行输出结果

运行解析：

• 发送端： 后台goroutine从5倒数到0，每次将数字送入通道并休眠1秒。
• 接收端： 主goroutine使用 for data := range ch1 持续从通道读取。每当发送端放入一个数，接收端立即打印并进入下一轮循环。
• 终止条件： 当 data == 0 时，满足跳出循环的条件，程序结束。

以上就是Golang通道（Channel）入门教程的详细内容，更多关于Golang并发编程的资料请关注本站其它相关文章！