集思谱需要我帮你解读这件专利吗？
公开（公告）号CN122985428A | 申请号CN202611467970.1 | 专利类型发明专利 |
状态在审 | 国家或地区CN | 申请人北京华恒盛世科技有限公司 |
分类号G06F9/50(2006.01), H04L67/55(2022.01) | 申请日2026-09-21 | 公开日2026-10-27 |
发布日期2026-10-27 | 文档 ID84635777974400010 | 源数据页码97 |
专利语言zh | ||
本申请提供一种基于GO语言的作业状态监听转换及Kafka推送方法和系统，涉及分布式计算技术领域。该方法通过监测作业状态日志文件确定初始作业状态数据流；在内存池中通过原子指令交换缓冲区地址指针锁定待处理缓冲区并输入无锁通道，且依据高算力消耗作业算力变化剧烈程度动态确定优先换出水位线；由GO协程提取并格式转换生成含节点标识及算力消耗等级的作业状态报文送入带缓冲并发通道；待发送数量达阈值时结合Broker实时IO吞吐能力确定目标分区；由GO协程池投递并将日志末端读取偏移量固化为断点恢复记录。本发明使突发算力波动下作业状态低延迟无锁传递并可断点恢复，提升高并发推送的实时性与可靠性。
附图 1