分析一个简单的goroutine资源池
2023-04-18 16:26:11 时间
分析一个简单的goroutine资源池 tunny。
从资源池中获取goroutine并进行处理的逻辑如下:
tunny将goroutine处理单元封装为workWrapper
,由此可以对goroutine的数目进行限制。
workerWrapper.run()作为一个goroutine,内部负责具体事务的处理。其会将一个workRequest
(可以看作是请求处理单元)放入reqChan
,并阻塞等待使用方的调用。workRequest
主要包含两个channel,其中jobChan
用于传入调用方的输入,retChan
用于给调用方返回执行结果。
调用方会从pool的reqChan中获取一个workRequest
请求处理单元,并在workRequest.jobChan
中传参,这样workerWrapper.run()中就会继续进行work.process
处理。处理结束之后将结果通过workRequest.retChan
返回给调用方,然后继续通过reqChan <- workRequest
阻塞等待下一个调用方的处理。
其中workerWrapper.run()中的work
是一个需要用户实现的接口,接口内容如下,最重要的接口是Process(interface{}) interface{}
type Worker interface {
// Process will synchronously perform a job and return the result.
Process(interface{}) interface{}
// BlockUntilReady is called before each job is processed and must block the
// calling goroutine until the Worker is ready to process the next job.
BlockUntilReady()
// Interrupt is called when a job is cancelled. The worker is responsible
// for unblocking the Process implementation.
Interrupt()
// Terminate is called when a Worker is removed from the processing pool
// and is responsible for cleaning up any held resources.
Terminate()
}
结论
tunny中的封装和处理函数并不适合所有的场景,但可以借鉴其核心思想来构造特定场景下的goroutine资源池。
相关文章
- 适用于Linux的高级实时系统监控工具
- 太方便:Chrome 浏览器新增实时字幕功能,可自动为音视频创建字幕
- 大数据下的数据分析-Hadoop架构解析
- 炫技!Bug排查大曝光,涉及Linux内核的那种
- Asahi Linux 报告:将 Linux 移植到 M1 Mac 太难了
- Windows 10 将预装 Windows Terminal
- 64位Chrome运行至少需8GB内存:安卓网友直呼用不起
- Chrome这硬伤终于修正!内存占用将大幅下降
- 数据集成平台引入基于云的商业智能应用
- 浅析Linux进程的内存管理
- 大数据(BigData)环境下的商业智能平台技术解析
- 这次答应我,一举拿下 I/O 多路复用!
- 开源软件发展史:Hadoop的昨天与今天
- 在鸿蒙上实现本地和Internet视频资源播放
- 深度体验了一把最新的Linux系统 它果然还是很难用
- 解析集团数据仓库系统改造新招数
- Linux黑话解释:Xorg,X11,Wayland,什么是显示服务器
- Teradata召开2011大中华区数据仓库和企业分析峰会
- 把你的树莓派变成一个 HiFi 音乐系统
- 谷歌发布适用于Chrome浏览器的Spectre PoC代码漏洞