Golang循环任务并发实现方法

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))）统一收集：

• 每个 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 := <-jobs: ... case <-ctx.Done(): return }
• 记得在退出前调用 cancel()（或 defer cancel()）