下面代碼的 Unbounded 實現摘自grpc/internal/buffer/unbounded.go,
它沒有選擇使用帶容量的channel,而是另外使用了一個list來備份積壓的消息,這裏我猜有兩個緣由code
- 使用這種方式channel變成了一個任意長度的channel,不用考慮channel被寫滿致使的問題。
- 這裏爲何不直接使用list + mutex,由於須要channel的特性來隔離goroutine。
当前版本 | AnqiCMS-v3.1.4 |
开发者 | Sinclair Liang |
主要特色 | 安企内容管理系统(AnqiCMS),是一款使用 GoLang 开发的企业站内容管理系统,它部署简单,软件安全,界面优雅,小巧,执行速度飞快,使用 AnqiCMS 搭建的网站可以防止众多安全问题发生。 |
GitHub | https://github.com/fesiong/goblog |