在 golang 函数中处理并发 goroutine 的优雅方法：使用 sync.waitgroups：通过指定 goroutine 数量并等待每个 goroutine 完成来实现同步。使用通道：通过创建通道并使用 goroutine 发送和接收数据，实现通信和同步。使用上下文：通过传递一个带有取消功能的上下文，实现取消或超时 goroutine 的功能。
如何在 Golang 函数中优雅地处理并发 goroutine
在 Golang 中，goroutine 指的是轻量级线程，它可以方便地并发执行任务。然而，管理并发 goroutine 可能是一项艰巨的任务，如果处理不当，会导致死锁、数据竞争或内存泄漏。本文将讨论如何在 Go 函数中优雅地处理并发 goroutine，并通过一个实战案例加以阐述。
使用 sync.WaitGroup
立即学习“go语言免费学习笔记（深入）”；
使用 uber-go/dig 在 Golang 中实现依赖注入——基于反射容器，提供 Provide/Invoke、dig.In/dig.Out 参数与结果对象，支持命名依赖等
sync.WaitGroup 是一种同步机制，可用于等待一组 goroutine 完成。通过调用 Add(n) 方法指定等待的 goroutine 数量，并在每个 goroutine 完成后调用 Done() 方法。当 Wait() 方法返回时，表明所有 goroutine 都已完成。
import (
"sync"
"fmt"
)
func main() {
var wg sync.WaitGroup
wg.Add(2)
go func() {
// 模拟异步任务
fmt.Println("Goroutine 1 完成")
wg.Done()
}()
go func() {
// 模拟异步任务
fmt.Println("Goroutine 2 完成")
wg.Done()
}()
wg.Wait()
fmt.Println("所有 goroutine 完成")
}使用通道
通道是一种用于在 goroutine 之间通信和同步的机制。可以通过 make(chan T) 创建一个通道，其中 T 是通道元素的类型。goroutine 可以使用 读取通道，使用 <code>ch 发送数据到通道。
import (
"fmt"
)
func main() {
ch := make(chan string)
go func() {
// 模拟异步任务
ch <- "Goroutine 1 完成"
}()
go func() {
// 模拟异步任务
ch <- "Goroutine 2 完成"
}()
for i := 0; i < 2; i++ {
fmt.Println(<-ch)
}
}使用上下文
上下文被用于在 goroutine 之间传递取消或超时信息。可以使用 context.Background() 创建一个新的上下文并使用 context.WithCancel() 创建一个带有取消功能的派生上下文。要取消上下文，可以调用 CancelFunc() 方法。
import (
"context"
"fmt"
"time"
)
func main() {
ctx, cancel := context.WithCancel(context.Background())
go func() {
for {
select {
case <-ctx.Done():
// 上下文已取消，停止 goroutine
fmt.Println("Goroutine 已取消")
return
default:
// 继续执行 goroutine
fmt.Println("Goroutine 正在运行")
time.Sleep(time.Second)
}
}
}()
time.Sleep(5 * time.Second)
cancel()
} 
