1. Go并发编程中的WaitGroup核心概念
WaitGroup的定义与零值特性
在Go的并发编程中，WaitGroup是一个用来等待一组Goroutine完成的同步原语。它的零值可以直接使用，无需显式初始化，这使得在简单场景下的集成非常方便。通过对待执行的goroutine数量进行计数，WaitGroup提供了一个明确的结束信号。
使用场景通常是：你需要并发地执行若干任务，随后再继续执行下一步逻辑。此时你可以创建一个var wg sync.WaitGroup，随后为每个Goroutine增加计数。零散任务的同步变得简单而可控。
计数器、Add与Done的使用规则
核心API包括wg.Add(n int)、wg.Done()和wg.Wait()。Add用于增加计数，Done用于将计数减一，Wait将阻塞直到计数归零。需要注意：Add在Wait调用后会不可继续增加计数，且计数不能变为负数，否则会触发运行时崩溃。
当一个Goroutine完成工作时，应调用wg.Done()来减少计数；这通常通过defer语句来确保即使发生错误也会执行。这种模式使得并发任务的结束信号变得可靠可控。
WaitGroup的零值与初始化误区
一个常见的误区是直接使用var wg sync.WaitGroup而忘记在开始创建Goroutine之前正确调用wg.Add来调整计数。这会导致等待永远进行不到结束的情况。正确的顺序是先Add再启动Goroutine，避免竞态导致的未定义行为。
此外，在使用并发任务池时，避免在Wait完成之后再继续Add，否则可能引发死锁或计数错误。通过严格的代码风格，可以将风险降到最低。
2. 基于WaitGroup的Goroutine同步设计要点
等待完成信号的优雅组合
在设计高并发场景时，WaitGroup与Goroutine并发的组合提供了简单而强大的同步能力。通过统一的等待点，主协程知道所有工作已经结束，避免了半途退出或未完成任务的情况。
为了实现节流与稳定性，通常会将wg.Add放在创建Goroutine之前；在每个Goroutine内，用defer wg.Done()确保退出信号被发送。这能有效避免“Goroutine泄漏”的风险。
避免死锁与资源泄漏的常见场景
常见错误是漏掉wg.Done()、在Wait之后继续Add、或者在goroutine中错误地阻塞其他资源。通过一致的代码风格，可以把这些风险降到最低。
此外，如果你的Goroutine需要等待外部资源，你应当使用超时策略与上下文结合来避免长时间阻塞，确保WaitGroup的计数在合理的时间内归零。结合上下文取消，可以提升整体鲁棒性。
3. 实战演示：借助WaitGroup实现Goroutine的同步
代码结构与工作流
本节通过一个简单的并发任务集来展示<强>WaitGroup的典型用法：初始化计数、启动若干Goroutine、在工作结束时调用Done，最后阻塞等待所有任务完成，然后继续后续流程。这样可以确保在并发阶段的结束信号统一，避免过早进入后续阶段。
注意：在生产环境中，你可能还会组合使用信道(channel)以传递错误信息，或者构建一个限流的Goroutine池来进一步稳定高并发行为。
完整示例代码
package main
import (
"fmt"
"sync"
"time"
)
func worker(id int, wg *sync.WaitGroup) {
defer wg.Done()
fmt.Printf("Worker %d: starting\n", id)
time.Sleep(100 * time.Millisecond)
fmt.Printf("Worker %d: done\n", id)
}
func main() {
var wg sync.WaitGroup
workers := 4
// 增加要等待的Goroutine数量
wg.Add(workers)
for i := 0; i < workers; i++ {
go worker(i, &wg)
}
// 等待所有Goroutine完成
wg.Wait()
fmt.Println("All workers completed.")
}
