sync.WaitGroup.Go 管理并发任务生命周期的实现方式

如果项目使用 Go 1.25 或更高版本，管理一组并发任务时可以直接调用 sync.WaitGroup.Go：它负责把任务计数加一、启动 goroutine，并在函数正常返回时把计数减一，主协程再调用 Wait 等待整组任务结束。这样可以把原本分散的 Add(1)、go 和 Done() 收口到一个调用点，但任务错误仍要通过返回值、channel 或受保护的结果集合显式传递。

WaitGroup.Go 解决的是“任务有没有被计数、结束时有没有回收”的生命周期问题，不是错误聚合器，也不是 panic 恢复器。生产代码要先确认 Go 版本，再为任务函数设计清晰的错误出口。

• 版本要求：WaitGroup.Go 从 Go 1.25 加入，旧版本需要继续使用 Add/Done。
• 计数边界：空 WaitGroup 上要先调用 Go 再调用 Wait；非空时可以由任务继续派生任务。
• 异常边界：官方文档要求传入的函数不能 panic，失败应转成结果或错误。

先确认 WaitGroup.Go 的版本与职责

Go 官方同步包把 WaitGroup 定义为用于等待一组 goroutine 或任务完成的计数信号量。WaitGroup.Go 是 Go 1.25 新增的方法，签名为 func (wg *WaitGroup) Go(f func())，它只接收无返回值的函数，因此不会替你收集任务错误。

升级前先看项目的 go.mod 和构建环境。如果某个构建节点仍低于 Go 1.25，直接写 wg.Go 会在编译阶段失败；此时应保留兼容封装，等工具链统一后再切换。

用 Go 方法收口启动、等待和错误回收

下面的写法把每个任务的错误写入带缓冲的 channel。缓冲容量覆盖任务数量，避免主协程在调用 Wait 前因为接收不及时而让任务卡在发送处。

package main

import (
	"fmt"
	"sync"
)

type taskResult struct {
	name string
	err  error
}

func main() {
	var wg sync.WaitGroup
	tasks := []string{"订单校验", "库存读取", "审计写入"}
	results := make(chan taskResult, len(tasks)) // 缓冲覆盖全部任务，避免发送阻塞

	for _, name := range tasks {
		taskName := name // 固定本轮任务名称，避免闭包读取变化中的循环变量
		wg.Go(func() {
			// 任务函数不把失败变成 panic，而是把错误作为结果传出。
			if taskName == "库存读取" {
				results 

这段代码的关键不是把 Go 当成更短的语法，而是把生命周期绑定在一个函数边界内。任务内部可以提前 return，计数仍会被正确回收；错误则从结果通道进入主协程，便于决定是否中止后续流程或记录失败。

生产边界：panic、Wait 顺序和批次复用

官方文档明确要求传给 WaitGroup.Go 的函数不能 panic。对可能失败的工作，应在函数内部把可预期失败转换为 error；如果必须隔离不可预期的 panic，需要在任务函数内部自行 recover，并把恢复结果转成错误，否则进程可能直接因 goroutine panic 退出。

空的 WaitGroup 还有一个容易忽略的顺序约束：应先完成所有初始 wg.Go 调用，再调用 wg.Wait。当计数器已经非零时，任务可以继续调用同一个 WaitGroup 的 Go 派生子任务；但一轮任务全部结束后，下一轮独立任务必须等上一次 Wait 返回。

不要复制已经开始使用的 WaitGroup，也不要把同一个实例交给多个互不相关的生命周期。更稳妥的做法是让一个函数拥有一个 WaitGroup，并在函数返回前完成等待和结果整理。

旧版本的兼容写法与速查

如果构建链还没有 Go 1.25，下面的写法可以保持同样的“先计数、再启动、结束回收”约束。它更容易被遗漏 Done，所以建议把 defer wg.Done() 放在 goroutine 的第一行。

func runLegacy(tasks []func()) {
	var wg sync.WaitGroup
	for _, task := range tasks {
		job := task
		wg.Add(1) // 旧版本必须在启动 goroutine 前增加计数
		go func() {
			defer wg.Done() // 无论任务从哪里返回，都回收本次计数
			job()
		}()
	}
	wg.Wait() // 所有 Add 的任务都结束后再继续
}

常见问题

WaitGroup.Go 能不能直接返回任务错误？

不能。它的函数参数是 func()，应通过 channel、结果对象或带锁的集合把错误送回协调方。

调用 Go 后还需要手动 Done 吗？

不需要。WaitGroup.Go 会在函数正常返回时完成任务计数回收；再手动调用 Done 会让计数减少两次。

Go 1.24 项目能直接使用它吗？

不能直接使用。应继续采用 Add、启动 goroutine、defer Done 的组合，或先升级构建工具链和模块声明。