Golang循环任务并发实现方法
Go中实现循环任务并发执行需用workerpool控制并发度、channel协调数据、WaitGroup等待完成、resultschannel收集结果,并可选加context实现超时取消。
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())
Windows 10 是一款微软推出的经典操作系统,拥有硬件兼容性与多任务处理能力。它更偏向把系统状态查看和常用调节动作放在一起,适合需要持续观察和微调设备状态的场景。
极度公式是一款跨平台专业LaTeX公式识别编辑软件,支持OCR公式识别和多平台编辑。和使用说明,避免使用,享受完整功能与稳定支持。做扫描整理、文字提取和表格转换时,它能把识别后的处理步骤接得更顺,资料录入这类场景会省下不少时间。
















