Go 中实现循环任务并发执行需用 worker pool 控制并发度、channel 协调数据、WaitGroup 等待完成、results channel 收集结果，并可选加 context 实现超时取消。
在 Go 中实现循环任务的并发执行，核心是用 goroutine 启动多个工作单元，用 channel 协调输入、输出与完成信号。关键不是“让所有任务同时跑”，而是“控制并发度 + 安全传递数据 + 正确等待结束”。
用 worker pool 控制并发数量
无限制启 goroutine（比如 for 循环里直接 go f()）容易耗尽资源或压垮下游服务。应预先启动固定数量的工作协程，从 channel 读取任务并处理。
- 定义一个任务 channel（如
jobs := make(chan Job, 100)），缓冲区避免发送阻塞 - 启动 N 个 worker：每个 worker 在 for-range 中持续接收 job 并执行
- 主 goroutine 将所有任务发到 jobs channel，发完后
close(jobs)
用 waitgroup 等待所有 worker 完成
channel 关闭后，worker 会自然退出 for-range，但主 goroutine 需确认它们全部结束才能继续。用 sync.WaitGroup 最直观可靠：
- 启动前
wg.Add(N) - 每个 worker 执行完 defer wg.Done()
- 主 goroutine 调用
wg.Wait()阻塞直到全部完成
用结果 channel 收集返回值（可选）
如果任务有输出（如处理结果、错误、耗时），不要在 worker 内部打印或写共享变量——易竞态。应通过另一个 channel（如 results := make(chan Result, len(tasks))）统一收集：
立即学习“go语言免费学习笔记（深入）”；
- 每个 worker 处理完 job 后，把
Result{JobID: ..., Data: ..., Err: ...}发送到 results - 主 goroutine 在 wg.Wait() 后，用 for-range 从 results 读取所有结果（注意：要读完，否则可能死锁）
加 context 实现超时或取消（进阶）
长时间运行的任务需支持中断。将 context.Context 传入 worker，在 select 中监听 ctx.Done()：
- 主 goroutine 创建带 timeout 的 ctx：
ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second) - worker 内部用
select { case job := - 记得在退出前调用
cancel()（或 defer cancel()）
