Golang —协程池(panjf2000/ants/v2)
Golang —协程池(panjf2000/ants/v2)
- 1 ants
- 1.1 基本信息
- 1.2 ants 是如何运行的(流程图)
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 是如何运行的(流程图)
- 这里每一个worker其实就是一个单独的协程。Submit()就是将一个任务交给worker(协程)来异步处理,等任务执行完后,worker会将自己交还给协程池。
- 倘若回归协程池失败,或者用户提交了一个空的任务包,则该 goWorker 会被销毁,销毁方式是将自身放回协程池的对象池 workerCache. 并且会调用协调器 cond 唤醒一个阻塞等待的协程。
- 通过使用 ants,可以实例化一个 goroutine 池,复用 goroutine ,节省资源,提升性能,它会自动管理worker(协程)的创建、回收、释放等工作。