go语言使用range来接收通道里面的数据

更新时间：2025年04月14日 09:38:56 作者：Achilles.Wang

本文主要介绍了go语言使用range来接收通道里面的数据,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接收数据内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！

您可能感兴趣的文章:

详解如何解决golang定时器引发的id重复问题
这篇文章主要为大家详细介绍了如何解决golang定时器引发的id重复问题,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一下
2024-04-04
一文了解Go语言的并发特性
本文主要介绍了一文了解Go语言的并发特性,通过轻量级线程、通道及选择语句,使得并发编程变得既简单又高效,下面就来具体了解一下如何使用,感兴趣的可以了解一下
2024-02-02
GoLang BoltDB数据库详解
这篇文章主要介绍了GoLang BoltDB数据库，boltdb是使用Go语言编写的开源的键值对数据库，boltdb存储数据时 key和value都要求是字节数据，此处需要使用到序列化和反序列化
2023-02-02
Go单元测试对GORM进行Mock测试
这篇文章主要为大家介绍了Go单元测试对GORM进行Mock测试用例详解，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步，早日升职加薪
2022-06-06
深入理解Go语言的容器包
Go语言的container标准包包含了堆（heap）、链表（list）和环（ring）三种数据结构,本文就来详细的介绍一下这三种的使用,感兴趣的可以了解一下
2024-10-10
golang切片内存应用技巧详解
这篇文章主要介绍了golang切片内存应用技巧详解，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
2019-12-12
Golang语言如何高效拼接字符串详解
最近在做性能优化,有个函数里面的耗时特别长,看里面的操作大多是一些字符串拼接的操作,而字符串拼接在 golang 里面其实有很多种实现,下面这篇文章主要给大家介绍了关于Golang语言如何高效拼接字符串的相关资料,需要的朋友可以参考下
2021-11-11
GO中对map排序的实现
本文主要介绍了GO中对map排序的实现，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
2023-03-03
Golang Gin框架获取请求参数的几种常见方式
在我们平常添加路由处理函数之后,就可以在路由处理函数中编写业务处理代码了,但在此之前我们往往需要获取请求参数,本文就详细的讲解下gin获取请求参数常见的几种方式,需要的朋友可以参考下
2024-02-02
详解Go并发编程时如何避免发生竞态条件和数据竞争
大家都知道，Go是一种支持并发编程的编程语言，但并发编程也是比较复杂和容易出错的。比如本篇分享的问题：竞态条件和数据竞争的问题
2023-04-04