修订历史

• 2023.02.21 创建笔记

ants 提供固定/无限容量的协程池，通过复用协程来执行任务，达到节省系统资源的目的。

协程池由三部分构成：Pool、Queue、Worker * n：

• 每个 Worker 都启动一个执行循环语句的协程。Worker 在循环语句中等待接收任务和执行任务。当任务执行完毕后将自身的引用插入 Queue，并记录任务执行完毕的时间。
• Queue 记录空闲的 Worker。Queue 可分为两类：无限容量的 stack 和固定容量的 loop queue
• Pool 从 Queue 获得空闲的 Worker，向其提交用户的任务。如果没有空闲的 Worker，则：
  • 若启动的协程数未超过池子容量，则创建新的 Worker
  • 若启动的协程数超过池子容量，则：
    • 若开启非阻塞，则返回错误
    • 若关闭非阻塞，则阻塞等待空闲的 Worker

实现细节

回收空闲的 Worker

Pool 会启动一个回收 Worker 的协程，定时检查 Queue 中 Worker 的时间戳。

当 Worker 最近执行的时间与当前的时间间隔超过设定值，则回收该 Worker

缓存当前时间戳

Worker 的时间戳并不需要非常精确。可以通过缓存时间戳，来避免频繁调用系统函数：

Pool 会启动一个协程，每隔一段时间更新 Pool 的时间戳。当 Worker 任务执行完任务后，会以 Pool 的时间戳作为任务执行完成的时间。

对象池

协程池使用 sync.Pool 对象池来创建和回收 Worker。通过复用 Worker 对象，减轻 GC 负担。