暂无图片
暂无图片
暂无图片
暂无图片
暂无图片
CN118069744A-数据同步方法、存储介质及设备_人大金仓.PDF
62
15页
1次
2024-06-27
免费下载
(19)国家知识产权局
(12)发明专利申请
(10)申请公布号
(43)申请公布日
(21)申请号 202410205481 .3
(22)申请日 2024 .02 .23
(71)申请人 北京人大金仓信息技术股份有限公
地址 100102 北京市朝阳区容达路7号院5
号楼13101内二层201
(72)发明人 雷东 王凯龙 
(74)专利代理机构 北京智汇东方知识产权代理
事务所(普通合伙) 11391
专利代理师 刘长江
(51)Int.Cl.
G06F
16/27
(2019 .01)
(54)发明名称
数据同步方法存储介质及设备
(57)摘要
本发明提供了一种数据同步方法存储介质
及设备其中数据处理方法包括启动解析主线
程,当所述解析主线程识别到待同步事务的提交
事件后创建一个线程变更队列;将所述待同步
事务的事务ID和所述线程变更队列提交至二次
解析线程池创建一个二次解析线程启动所述
二次解析线程获取所述待同步事务的初次解析
数据对所述初次解析数据进行二次解析得到二
次解析数据将所述二次解析数据提交到所述线
程变更队列本发明的优点是可以在二次解析阶
段使用多线程并行处理提高待同步事务的整体
解析速度
权利要求书2页 说明书7页 附图5页
CN 118069744 A
2024.05.24
CN 118069744 A
1 .一种数据同步方法包括
启动解析主线程当所述解析主线程识别到待同步事务的提交事件后创建一个线程
变更队列
将所述待同步事务的事务ID和所述线程变更队列提交至二次解析线程池创建一个二
次解析线程
启动所述二次解析线程获取所述待同步事务的初次解析数据
对所述初次解析数据进行二次解析得到二次解析数据将所述二次解析数据提交到所
述线程变更队列
2 .根据权利要求1所述的数据同步方法其中在创建一个线程变更队列的步骤之后
还包括
将所述线程变更队列的名称添加至线程变更顺序队列利用所述线程变更顺序队列记
录所述线程变更队列的提交顺序
3 .根据权利要求2所述的数据同步方法其中在将所述二次解析数据提交到所述线程
变更队列的步骤之后还包括
启动消费线程从所述线程变更顺序队列获取所述线程变更队列
将所述线程变更队列的二次解析数据写入到结果队列
4 .根据权利要求3所述的数据同步方法其中在将所述二次解析数据提交到所述线程
变更队列的过程中所述方法还包括
向所述线程变更队列写入一条提交标记以指示所述待同步事务已完成二次解析操
作;
结束所述二次解析线程并将其回收至所述二次解析线程池中
5 .根据权利要求4所述的数据同步方法其中将所述线程变更队列的二次解析数据写
入到结果队列的过程中所述方法还包括
检查所述消费线程是否从所述线程变更队列中读取到所述提交标记
若是从所述线程变更顺序队列移除所述线程变更队列
6 .根据权利要求3所述的数据同步方法其中所述线程变更队列为有限容量的阻塞队
在将所述二次解析数据提交到所述线程变更队列的过程中所述方法还包括
检查所述线程变更队列中的二次解析数据是否达到配置容量值
若是暂停所述二次解析线程
7 .根据权利要求6所述的数据同步方法其中在暂停所述二次解析线程的步骤之后
还包括
检查所述消费线程是否消费到所述线程变更队列的二次解析数据
若是重新启动所述二次解析线程
8.根据权利要求1所述的数据同步方法其中
所述待同步事务的初次解析数据提交至重排缓冲器中
9 .一种机器可读存储介质其上存储有机器可执行程序所述机器可执行程序被处理
器执行时实现根据权利要求18任一项所述的数据同步方法
10.一种计算机设备包括存储器处理器及存储在所述存储器上并在所述处理器上运
行的机器可执行程序并且所述处理器执行所述机器可执行程序时实现根据权利要求18
权 利 要 求 书
1/2
2
CN 118069744 A
2
任一项所述的数据同步方法
权 利 要 求 书
2/2
3
CN 118069744 A
3
of 15
免费下载
【版权声明】本文为墨天轮用户原创内容,转载时必须标注文档的来源(墨天轮),文档链接,文档作者等基本信息,否则作者和墨天轮有权追究责任。如果您发现墨天轮中有涉嫌抄袭或者侵权的内容,欢迎发送邮件至:contact@modb.pro进行举报,并提供相关证据,一经查实,墨天轮将立刻删除相关内容。