1 Star 0 Fork 0

k8sio/cnkit

加入 Gitee
与超过 1200万 开发者一起发现、参与优秀开源项目,私有仓库也完全免费 :)
免费加入
文件
该仓库未声明开源许可证文件(LICENSE),使用请关注具体项目描述及其代码上游依赖。
克隆/下载
贡献代码
同步代码
取消
提示: 由于 Git 不支持空文件夾,创建文件夹后会生成空的 .keep 文件
Loading...
README

PayloadHub

PayloadHub 是一个高性能的处理数据生产/消费的工具包,特别适合于多个消费者并发处理相同生产数据的情况

Watcher callback 函数一般来说应该尽快返回避免阻塞,消费速率需要业务代码自行保证

如果业务逻辑较复杂或耗时较长,建议使用 chan 把数据发到其他地方专门处理

如果 Watcher callback 耗时较长或发生了阻塞,可能会影响后续数据不能及时处理而被新 Push payload 覆盖掉

数据结构采用循环链表来存放 payload,当本轮链表节点耗尽后新 Push 的数据会循环覆盖之前较老的 payload

马建仓 AI 助手
尝试更多
代码解读
代码找茬
代码优化
1
https://gitee.com/k8sio/cnkit.git
git@gitee.com:k8sio/cnkit.git
k8sio
cnkit
cnkit
master

搜索帮助