yiming1997 /
agilepool
agilePool 是一个高性能 Go 任务池。它按滑动窗口直方图统计的提交速率和消费速率，用公式自动计算目标 worker 数，在突发流量下快速扩容；空闲 worker 会被自动回收复用，任务支持无界缓冲与背压，还支持重试、超时、上下文取消和优雅关闭。适合提交海量小异步任务、又不想让 goroutine 数量失控的场景。 亮点 1. 自适应扩缩容：每 10ms 根据提交和消费速率的中位数推算所需 worker 数，积压越深扩容越激进，…
Product images
About
agilePool 是一个高性能 Go 任务池。它按滑动窗口直方图统计的提交速率和消费速率，用公式自动计算目标 worker 数，在突发流量下快速扩容；空闲 worker 会被自动回收复用，任务支持无界缓冲与背压，还支持重试、超时、上下文取消和优雅关闭。适合提交海量小异步任务、又不想让 goroutine 数量失控的场景。 亮点 1. 自适应扩缩容：每 10ms 根据提交和消费速率的中位数推算所需 worker 数，积压越深扩容越激进，负载回落后自动收缩，不需要手工调线程数。 2. 无界缓冲 + 背压：小容量交接 channel 加分段链表缓冲，BLOCK/NONBLOCK 两种提交模式，突发任务不会丢，也不会无限占内存。 3. 五种空闲 worker 容器：LinkedList、MinHeap、Treap、Slice、RingQueue 可插拔，FIFO/LRU、O(1) 出队、批量过期清理按场景选择。 4. 完整的任务语义：支持指数退避重试、SubmitCtx 取消、SubmitBefore 截止时间、panic 隔离、生命周期 Hook，以及自定义 Logger。 5. MIT 开源、无第三方依赖：仅依赖标准库，附独立 benchmark 仓库，与主流 Go goroutine 池对比。
Discovery history
- 阮一峰周刊·用户投稿
- HelloGitHub·用户投稿
Discuss this product