Golang —协程池（panjf2000/ants/v2）

1 ants

1.1 基本信息

代码地址：github.com/panjf2000/ants/v2
介绍：ants是一个高性能的 goroutine 池，实现了对大规模 goroutine 的调度管理、goroutine 复用，允许使用者在开发并发程序的时候限制 goroutine 数量，复用资源，达到更高效执行任务的效果。

功能：

• 自动调度海量的 goroutines，复用 goroutines。
• 定期清理过期的 goroutines，进一步节省资源。
• 提供了大量有用的接口：任务提交、获取运行中的 goroutine 数量、动态调整 Pool 大小、释放 Pool、重启 Pool。
• 优雅处理 panic，防止程序崩溃。
• 资源复用，极大节省内存使用量；在大规模批量并发任务场景下比原生 goroutine 并发具有更高的性能。
• 非阻塞机制。

1.2 ants 是如何运行的（流程图）

1. 这里每一个worker其实就是一个单独的协程。Submit()就是将一个任务交给worker（协程）来异步处理，等任务执行完后，worker会将自己交还给协程池。
2. 倘若回归协程池失败，或者用户提交了一个空的任务包，则该 goWorker 会被销毁，销毁方式是将自身放回协程池的对象池 workerCache. 并且会调用协调器 cond 唤醒一个阻塞等待的协程。
3. 通过使用 ants，可以实例化一个 goroutine 池，复用 goroutine ，节省资源，提升性能，它会自动管理worker（协程）的创建、回收、释放等工作。