共计 1575 个字符，预计需要花费 4 分钟才能阅读完成。
goroutine 是非常轻量的，不会暂用太多资源，基本上有多少任务，我们可以开多少 goroutine 去处理。但有时候，我们还是想控制一下。
比如，我们有 A、B 两类工作，不想把太多资源花费在 B 类务上，而是花在 A 类任务上。对于 A，我们可以来 1 个开一个 goroutine 去处理，对于 B，我们可以使用一个协程池，协程池里有 5 个线程去处理 B 类任务，这样 B 消耗的资源就不会太多。
控制使用资源并不是协程池目的，使用协程池是为了更好并发、程序鲁棒性、容错性等。废话少说，快速入门协程池才是这篇文章的目的。
协程池指的是预先分配固定数量的 goroutine 处理相同的任务，和线程池是类似的，不同点是协程池中处理任务的是协程，线程池中处理任务的是线程。
最简单的协程池模型
上面这个图展示了最简单的协程池的样子。先把协程池作为一个整体看，它使用 2 个通道，左边的 jobCh 是任务通道，任务会从这个通道中流进来，右边的 retCh 是结果通道，协程池处理任务后得到的结果会写入这个通道。至于协程池中，有多少协程处理任务，这是外部不关心的。
看一下协程池内部，图中画了 5 个 goroutine，实际 goroutine 的数量是依具体情况而定的。协程池内每个协程都从 jobCh 读任务、处理任务，然后将结果写入到 retCh。
示例
模型看懂了，看个小例子吧。
workerPool() 会创建 1 个简单的协程池，协程的数量可以通入参数 n 执行，并且还指定了 jobCh 和 retCh 两个参数。
worker() 是协程池中的协程，入参分布是它的 ID、job 通道和结果通道。使用 for-range 从 jobCh 读取任务，直到 jobCh 关闭，然后一个最简单的任务：生成 1 个字符串，证明自己处理了某个任务，并把字符串作为结果写入 retCh。
main() 启动 genJob 获取存放任务的通道 jobCh，然后创建 retCh，它的缓存空间是 200，并使用 workerPool 启动一个有 5 个协程的协程池。1s 之后，关闭 retCh，然后开始从 retCh 中读取协程池处理结果，并打印。
genJob 启动一个协程，并生产 n 个任务，写入到 jobCh。
示例运行结果如下，一共产生了 10 个任务，显示大部分工作都被 worker 2 这个协程抢走了，如果我们设置的任务成千上万，协程池长时间处理任务，每个协程处理的工作数量就会均衡很多。
➜ go run simple_goroutine_pool.go
worker 2 processed job: 4
worker 2 processed job: 5
worker 2 processed job: 6
worker 2 processed job: 7
worker 2 processed job: 8
worker 2 processed job: 9
worker 0 processed job: 1
worker 3 processed job: 2
worker 4 processed job: 3
worker 1 processed job: 0
回顾
最简单的协程池模型就这么简单，再回头看下协程池及周边由哪些组成：
协程池内的一定数量的协程。
任务队列，即 jobCh，存在协程池不能立即处理任务的情况，所以需要队列把任务先暂存。
结果队列，即 retCh，同上，协程池处理任务的结果，也存在不能被下游立刻提取的情况，要暂时保存。
协程池最简要（核心）的逻辑是所有协程从任务读取任务，处理后把结果存放到结果队列。
Go 并发系列文章
Golang 并发模型：轻松入门流水线模型
Golang 并发模型：轻松入门流水线 FAN 模式
Golang 并发模型：并发协程的优雅退出
Golang 并发模型：轻松入门 select
Golang 并发模型：select 进阶
Golang 并发模型：轻松入门协程池
如果这篇文章对你有帮助，请点个赞 / 喜欢，鼓励我持续分享，感谢。
如果喜欢本文，随意转载，但请保留此原文链接。
博客文章列表，点此可查看