快速响应:Go WaitGroup在高并发场景下的应用
在高并发场景下,Go的WaitGroup是一种有效的工具,用于等待一组goroutine完成其任务。
WaitGroup有三个方法可以使用:
- `Add(n int)`:表示等待的goroutine数量增加n。
- `Done()`:表示等待的goroutine数量减少1。
- `Wait()`:阻塞等待,直到等待的goroutine数量为0。
下面是一个使用WaitGroup的示例代码,在高并发场景下,使用goroutine处理任务,并使用WaitGroup等待所有goroutine完成:
```go
package main
import (
"fmt"
"sync"
"time"
)
func main() {
var wg sync.WaitGroup
for i := 0; i < 10; i++ {
wg.Add(1)
go func(n int) {
defer wg.Done()
time.Sleep(time.Second) // 模拟任务处理时间
fmt.Printf("Task %d completed\n", n)
}(i)
}
wg.Wait() // 等待所有任务完成
fmt.Println("All tasks completed")
}
```
在上面的代码中,我们创建了10个goroutine来处理任务。每个goroutine在完成任务后,调用`Done()`方法来减少等待的goroutine数量。最后,调用`Wait()`方法来阻塞等待,直到所有goroutine完成任务。
通过使用WaitGroup,我们可以保证在高并发场景下,所有的goroutine都能够完成任务后再执行后续的操作。
免责声明:
① 本站未注明“稿件来源”的信息均来自网络整理。其文字、图片和音视频稿件的所属权归原作者所有。本站收集整理出于非商业性的教育和科研之目的,并不意味着本站赞同其观点或证实其内容的真实性。仅作为临时的测试数据,供内部测试之用。本站并未授权任何人以任何方式主动获取本站任何信息。
② 本站未注明“稿件来源”的临时测试数据将在测试完成后最终做删除处理。有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341