前言

goroutine协程非常轻量级,这也是为什么go支持高并发,但是goroutine频繁创建销毁对GC的压力比较大。

grpool的作用就是复用goroutine,减少频繁创建销毁的性能消耗。

名词概念

Pool: goroutine池,用于管理若干可复用的goroutine协程资源

Worker: 池对象中参与任务执行的goroutine,一个worker可以执行若干个job,直到队列中再无等待的job

Job:添加到池对象的任务队列中等待执行的任务,是一个func()方法,一个job同时只能被一个worker获取并执行。

使用示例

使用默认的协程池,限制100个协程执行1000个任务

pool.Size() 获得当前工作的协程数量

pool.Jobs() 获得当前池中待处理的任务数量

打印结果:

是不是灰常简单~

踩坑之旅

一个简单的场景,请使用协程打印0~9。

常犯的错误

大家看下面的代码有没有问题,请预测一下打印结果。

不用着急看答案

猜一下打印结果是什么

打印结果:

分析原因

goroutineiii9

正确写法:

打印结果:

使用grpool

i

错误代码

打印结果:

正确代码

打印结果:

总结

通过这篇文章我们了解到:grpool的作用就是复用goroutine,减少频繁创建销毁的性能消耗。也了解到使用协程容易犯的错误,以及用临时变量的方式来解决问题。

说句题外话:grpool的基础概念:Pool、Worke、Job 和我之前设计的派单系统简直一模一样。