go语言使用range来接收通道里面的数据
更新时间：2025年04月14日 09:38:56 作者：Achilles.Wang
本文主要介绍了go语言使用range来接收通道里面的数据,for ... range 循环会一直从通道中接收值,直到通道关闭并且所有值都被接收完毕,下面就来介绍一下,感兴趣的可以了解一下
在 Go 语言中，可以使用 for ... range 循环来遍历通道（channel）。for ... range 循环会一直从通道中接收值，直到通道关闭并且所有值都被接收完毕。
使用 for ... range 遍历通道
示例代码
下面是一个使用 for ... range 遍历通道的示例：
package main
import (
"fmt"
"time"
)
func main() {
// 创建一个有缓冲的通道
ch := make(chan int, 5)
// 启动一个 goroutine 向通道发送值
go func() {
for i := 0; i < 5; i++ {
ch <- i
time.Sleep(100 * time.Millisecond) // 模拟耗时操作
}
close(ch) // 关闭通道
}()
// 使用 for ... range 遍历通道
for value := range ch {
fmt.Println("Received:", value)
}
}
解释
创建通道：
ch := make(chan int, 5)
make(chan int, 5)创建一个容量为 5 的有缓冲通道。
启动 goroutine 发送值：
go func() {
for i := 0; i < 5; i++ {
ch <- i
time.Sleep(100 * time.Millisecond) // 模拟耗时操作
}
close(ch) // 关闭通道
}()
- 启动一个 goroutine，向通道发送 0 到 4 的整数。
time.Sleep(100 * time.Millisecond)模拟耗时操作，使发送操作之间有时间间隔。close(ch)关闭通道，表示不再发送新的值。
使用 for ... range 遍历通道：
for value := range ch {
fmt.Println("Received:", value)
}
for value := range ch循环会一直从通道中接收值，直到通道关闭并且所有值都被接收完毕。- 每次接收到一个值，都会打印出来。
注意事项
关闭通道：
- 必须在发送完所有值后关闭通道，否则
for ... range循环会一直阻塞，等待新的值。 - 关闭通道后，不能再向通道发送值，否则会引发 panic。
- 必须在发送完所有值后关闭通道，否则
多接收者：
- 如果有多个 goroutine 同时从同一个通道接收值，可能会出现竞争条件。建议使用互斥锁或其他同步机制来确保线程安全。
空通道：
- 对于无缓冲通道，如果没有接收者，发送操作会阻塞，直到有接收者准备接收值。
示例：多接收者
下面是一个多接收者从同一个通道接收值的示例：
package main
import (
"fmt"
"sync"
"time"
)
func main() {
// 创建一个有缓冲的通道
ch := make(chan int, 5)
// 启动一个 goroutine 向通道发送值
go func() {
for i := 0; i < 5; i++ {
ch <- i
time.Sleep(100 * time.Millisecond) // 模拟耗时操作
}
close(ch) // 关闭通道
}()
// 使用 sync.WaitGroup 等待所有接收者完成
var wg sync.WaitGroup
// 启动多个接收者 goroutine
for i := 0; i < 3; i++ {
wg.Add(1)
go func(id int) {
defer wg.Done()
for value := range ch {
fmt.Printf("Receiver %d received: %d\n", id, value)
}
}(i)
}
// 等待所有接收者完成
wg.Wait()
}
解释
启动多个接收者 goroutine：
for i := 0; i < 3; i++ {
wg.Add(1)
go func(id int) {
defer wg.Done()
for value := range ch {
fmt.Printf("Receiver %d received: %d\n", id, value)
}
}(i)
}
- 启动三个接收者 goroutine，每个 goroutine 都使用
for ... range循环从通道中接收值。 wg.Add(1)增加 WaitGroup 的计数。defer wg.Done()在 goroutine 结束时减少 WaitGroup 的计数。
等待所有接收者完成：
wg.Wait()
- 使用
wg.Wait()等待所有接收者 goroutine 完成。
通过使用 for ... range 循环，可以方便地遍历通道中的值，直到通道关闭并且所有值都被接收完毕。这对于处理并发任务和数据流非常有用。
到此这篇关于go语言使用range来接收通道里面的数据的文章就介绍到这了,更多相关go语言range接收数据内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！
相关文章
代理模式是一种结构型设计模式， 其中代理控制着对于原对象的访问， 并允许在将请求提交给原对象的前后进行一些处理，从而增强原对象的逻辑处理，这篇文章主要来学习一下代理模式的构成和用法,需要的朋友可以参考下2023-05-05
本文主要介绍了Golang中gorm无法将字段更新为空值，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧2023-05-05
golang 输出重定向:fmt Log,子进程Log,第三方库logrus的详解
这篇文章主要介绍了golang 输出重定向:fmt Log,子进程Log,第三方库logrus的详解，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧2020-12-12
这篇文章介绍了在Debian系统上实现多版本Go共存的详细方法,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧2026-04-04
Go 在泛型方面一直被诟病，因为它在这方面相对比较落后。但是，在 Go 1.18 版本中，泛型已经被正式引入，成为了 Go 语言中一个重要的特性。本文将会详细介绍 Go 泛型的相关概念，语法和用法，希望能够帮助大家更好地理解和应用这一特性2023-05-05
这篇文章主要为大家介绍了Golang实现EasyCache缓存库实例探究,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪2024-01-01
Go语言中切片（slice）和数组（array）是两种不同的数据结构,它们在用法和行为上有一些重要区别,所以本文就通过一些代码示例给大家详细的介绍一下Go语言中切片(slice)和数组(array)的区别,需要的朋友可以参考下2023-09-09
Go语言编译运行缓慢问题可能是由于Windows 11更新引入的PCManagerServiceStore进程导致的,该进程会强制检查Go代码编译过程,消耗大量系统资源,下面就来介绍一下该问题的解决2025-08-08
Golang中的container/heap包提供堆操作,适用于实现了heap.Interface的类型,本文主要介绍了golang中的container/heap包使用,感兴趣的可以了解一下2025-02-02
Go 语言作为一门新语言，在早期经常遭到唾弃的就是在垃圾回收(下称：GC)机制中 STW(Stop-The-World)的时间过长。下面文章就对此话题展开，感兴趣的小伙伴可以参考下面文章的内容2021-09-09
最新评论