该框架核心是可控并发、安全排队与稳定回收；任务需实现task接口以返回结果和错误，自行捕获panic；i/o任务须接收context.context；队列用带缓冲channel并采用非阻塞select提交。
Go语言实现基于协程池的并发任务执行框架，核心在于可控并发 + 安全排队 + 稳定回收。它不是简单地“复用goroutine”，而是通过结构化设计，让系统在高负载下不OOM、不丢任务、不 panic、不雪崩。
任务定义要带结果与错误处理
任务不能只是 func()，必须能反馈执行状态。推荐接口形式：
- type Task interface { Execute() (result interface{}, err error) }
- 每个任务自行处理内部 panic，避免 worker 崩溃退出（否则池容量永久缩水）
- 若任务含 I/O（如 HTTP 请求、DB 查询），需接收 context.Context 并传到底层 client，不能依赖 worker 统一超时
任务队列要用带缓冲 channel + 非阻塞提交
channel 是天然的任务队列，但用法很关键：
- 初始化 tasks := make(chan Task, queueSize)，缓冲大小建议设为预期峰值积压量（如 1000）
- Submit 方法必须用 select { case p.tasks
- 绝不能直接 tasks
Worker 启动与退出需严格同步
worker 数量固定，但生命周期管理极易出错：
- 启动：for i := 0; i
- worker 内部用 for { select { case task, ok :=
- 关闭前：先用 sync.Once 阻止新任务写入 → close(p.tasks) → 用 sync.WaitGroup 等所有 worker 退出 → 再关闭 result/error channel
- 漏掉 WaitGroup 或提前 close channel，会导致 Submit 返回成功但任务静默丢失
拒绝策略必须主动响应，不能忽略错误
池满不是异常，是明确的背压信号：
- Submit 返回 ants.ErrPoolOverload（或自定义错误）时，应降级处理：同步执行、写入本地磁盘队列、返回 HTTP 429
- 不要 log.Fatal 或 panic，这会让整个服务不可用
- 若开启非阻塞模式（WithNonblocking(true)），Submit 永远不排队；需要排队，就得关掉该选项，并配好 queueSize
golang免费学习笔记（深入）：立即使用
在学习笔记中，你将探索golang的核心概念和高级技巧！
