无缓冲channel用于同步通信，发送方阻塞直到接收方就绪；2. 带缓冲channel可暂存数据，减少阻塞，通过range遍历并检测关闭；3. 多生产者并发向同一channel发送数据，主函数统一接收处理。
在Go语言中，channel 是实现goroutine之间通信的核心机制。它不仅用于传递数据，还能保证并发安全。下面通过几个常见示例展示如何使用channel进行数据通信。
1. 基本的channel数据传递
创建一个无缓冲channel，一个goroutine发送数据，另一个接收：
func main() { ch := make(chan string) <pre class='brush:php;toolbar:false;'>go func() { ch <- "Hello from goroutine" }() msg := <-ch fmt.Println(msg)
}
这里main函数等待从channel接收数据，发送完成后程序退出。注意：无缓冲channel会阻塞发送方直到有接收方就绪。
立即学习“go语言免费学习笔记（深入）”；
2. 使用带缓冲的channel避免阻塞
当发送频率较高时，可以使用带缓冲的channel临时存储数据：
func main() { ch := make(chan int, 3) // 缓冲大小为3 <pre class='brush:php;toolbar:false;'>ch <- 1 ch <- 2 ch <- 3 close(ch) for num := range ch { fmt.Println(num) }
}
缓冲channel在未满时不阻塞发送，读取时使用range可自动检测channel是否关闭。
3. 多生产者-单消费者模型
多个goroutine向同一个channel发送数据，主函数统一处理：
func producer(id int, ch chan<- int, wg *sync.WaitGroup) { defer wg.Done() for i := 0; i < 3; i++ { ch <- id*10 + i time.Sleep(100 * time.Millisecond) } } <p>func main() { ch := make(chan int) var wg sync.WaitGroup</p><pre class='brush:php;toolbar:false;'>for i := 0; i < 3; i++ { wg.Add(1) go producer(i, ch, &wg) } go func() { wg.Wait() close(ch) }() for num := range ch { fmt.Println("Received:", num) }
}
使用WaitGroup确保所有生产者完成后再关闭channel，防止panic。
4. 使用select监听多个channel
当需要处理多个数据源时，select能实现非阻塞多路复用：
func main() { ch1 := make(chan string) ch2 := make(chan string) <pre class='brush:php;toolbar:false;'>go func() { ch1 <- "data from ch1" }() go func() { ch2 <- "data from ch2" }() for i := 0; i < 2; i++ { select { case msg1 := <-ch1: fmt.Println(msg1) case msg2 := <-ch2: fmt.Println(msg2) } }
}
select随机选择就绪的case执行，适合处理并发事件响应。
基本上就这些。channel的设计理念是“不要通过共享内存来通信，而应该通过通信来共享内存”。合理使用channel能写出简洁、安全的并发代码。注意及时关闭不再使用的channel，并避免对已关闭的channel发送数据。