php小编柚子在此为大家介绍一种在sync.WaitGroup goroutine中写入chan的方法。在并发编程中,sync.WaitGroup是一种非常有用的同步机制,它可以等待一组goroutine的执行完成。然而,有时我们需要在goroutine执行完毕后,将结果写入到一个chan中,以供其他goroutine消费。本文将详细介绍如何在sync.WaitGroup goroutine中实现这一功能,让我们一起来看看吧!
问题内容
我正在从 API 端点获取项目列表。然后,对于每个项目,我都会发出另一个 API 请求以获取有关单个项目的数据。
我无法同时对每个项目发出第二个 API 请求,因为我的 API 令牌有速率限制,如果我同时发出太多请求,我会受到限制。
但是,初始 API 响应数据可以分为多个页面,这使我能够同时处理数据页面。
经过一些研究,下面的代码完全符合我的要求:
func main() { // pretend paginated results from initial API request page1 := []int{1, 2, 3} page2 := []int{4, 5, 6} page3 := []int{7, 8, 9} pages := [][]int{page1, page2, page3} results := make(chan string) var wg sync.WaitGroup for i := range pages { wg.Add(1) go func(i int) { defer wg.Done() for j := range pages[i] { // simulate making additional API request and building the report time.Sleep(500 * time.Millisecond) result := fmt.Sprintf("Finished creating report for %d", pages[i][j]) results <- result } }(i) } go func() { wg.Wait() close(results) }() for result := range results { fmt.Println(result) } }
我想了解为什么它能发挥作用:
go func() { wg.Wait() close(results) }()
我的第一次尝试没有成功——我想我可以在 wg.Wait()
之后遍历通道,并且我会在结果写入 results
通道时读取结果。
func main() { // pretend paginated results from initial API request page1 := []int{1, 2, 3} page2 := []int{4, 5, 6} page3 := []int{7, 8, 9} pages := [][]int{page1, page2, page3} results := make(chan string) var wg sync.WaitGroup for i := range pages { wg.Add(1) go func(i int) { defer wg.Done() for j := range pages[i] { // simulate making additional API request and building the report time.Sleep(500 * time.Millisecond) result := fmt.Sprintf("Finished creating report for %d", pages[i][j]) results <- result } }(i) } // does not work wg.Wait() close(results) for result := range results { fmt.Println(result) } }
解决方法
在您的第一次尝试中:
- 主 goroutine 使 3 个 goroutine 将值放入结果通道中。
- 主协程等待所有协程完成。
- 其中一个 goroutine 将一个值放入结果通道中并填充通道(通道大小为 1 个字符串)。
- 现在所有三个 goroutine 都无法再将值放入结果通道并进入睡眠状态,直到结果通道被释放。
- 所有 goroutine 都处于睡眠状态。你陷入了僵局。
在第二次尝试中:
- 主 goroutine 包含 4 个 goroutine。
- 3 个 goroutine 将值放入结果通道中。
- 其他 goroutine(我将其称为第 4 个)等待这 3 个 goroutine 结束。
- 同时主协程等待结果通道中的值(for 循环)
- 在这种情况下,如果其中一个 goroutine 在结果通道中放入一个值,则会阻塞其余的三个 goroutine;主 Goroutine 将值从结果通道中取出,从而解除对其他 Goroutine 的阻塞。
- 因此,所有 3 个 goroutine 都放入各自的值并结束
- 然后第四个 goroutine 关闭通道
- 主 Goroutine 结束其 for 循环。
以上是在sync.WaitGroup goroutine中写入chan的详细内容。更多信息请关注PHP中文网其他相关文章!

Go语言的核心特性包括垃圾回收、静态链接和并发支持。1.Go语言的并发模型通过goroutine和channel实现高效并发编程。2.接口和多态性通过实现接口方法,使得不同类型可以统一处理。3.基本用法展示了函数定义和调用的高效性。4.高级用法中,切片提供了动态调整大小的强大功能。5.常见错误如竞态条件可以通过gotest-race检测并解决。6.性能优化通过sync.Pool重用对象,减少垃圾回收压力。

Go语言在构建高效且可扩展的系统中表现出色,其优势包括:1.高性能:编译成机器码,运行速度快;2.并发编程:通过goroutines和channels简化多任务处理;3.简洁性:语法简洁,降低学习和维护成本;4.跨平台:支持跨平台编译,方便部署。

关于SQL查询结果排序的疑惑学习SQL的过程中,常常会遇到一些令人困惑的问题。最近,笔者在阅读《MICK-SQL基础�...

golang ...

Go语言中如何对比并处理三个结构体在Go语言编程中,有时需要对比两个结构体的差异,并将这些差异应用到第�...

GoLand中自定义结构体标签不显示怎么办?在使用GoLand进行Go语言开发时,很多开发者会遇到自定义结构体标签在�...


热AI工具

Undresser.AI Undress
人工智能驱动的应用程序,用于创建逼真的裸体照片

AI Clothes Remover
用于从照片中去除衣服的在线人工智能工具。

Undress AI Tool
免费脱衣服图片

Clothoff.io
AI脱衣机

AI Hentai Generator
免费生成ai无尽的。

热门文章

热工具

VSCode Windows 64位 下载
微软推出的免费、功能强大的一款IDE编辑器

SublimeText3 Mac版
神级代码编辑软件(SublimeText3)

SecLists
SecLists是最终安全测试人员的伙伴。它是一个包含各种类型列表的集合,这些列表在安全评估过程中经常使用,都在一个地方。SecLists通过方便地提供安全测试人员可能需要的所有列表,帮助提高安全测试的效率和生产力。列表类型包括用户名、密码、URL、模糊测试有效载荷、敏感数据模式、Web shell等等。测试人员只需将此存储库拉到新的测试机上,他就可以访问到所需的每种类型的列表。

SublimeText3 英文版
推荐:为Win版本,支持代码提示!

Dreamweaver CS6
视觉化网页开发工具