无缓冲channel用于同步通信,发送方阻塞直到接收方就绪;2. 带缓冲channel可暂存数据,减少阻塞,通过range遍历并检测关闭;3. 多生产者并发向同一channel发送数据,主函数统一接收处理。

在Go语言中,channel 是实现goroutine之间通信的核心机制。它不仅用于传递数据,还能保证并发安全。下面通过几个常见示例展示如何使用channel进行数据通信。
1. 基本的channel数据传递
创建一个无缓冲channel,一个goroutine发送数据,另一个接收:
func main() {
ch := make(chan string)
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
ch <- 1
ch <- 2
ch <- 3
close(ch)
for num := range ch {
fmt.Println(num)
}}
缓冲channel在未满时不阻塞发送,读取时使用range可自动检测channel是否关闭。
网趣网上购物系统支持PC电脑版+手机版+APP,数据一站式更新,支持微信支付与支付宝支付接口,是专业的网上商城系统,网趣商城系统支持淘宝数据包导入,实现与淘宝同步更新!支持上传图片水印设置、图片批量上传功能,同时支持订单二次编辑以及多级分类隐藏等实用功能,新版增加商品大图浏览与列表显示功能,使分类浏览更方便,支持最新的支付宝即时到帐接口。
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)
}
}
func main() {
ch := make(chan int)
var wg sync.WaitGroup
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)
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发送数据。









