1 .一种数据同步方法,包括:
启动解析主线程,当所述解析主线程识别到待同步事务的提交事件后,创建一个线程
变更队列;
将所述待同步事务的事务ID和所述线程变更队列提交至二次解析线程池,创建一个二
次解析线程;
启动所述二次解析线程,获取所述待同步事务的初次解析数据;
对所述初次解析数据进行二次解析得到二次解析数据,将所述二次解析数据提交到所
述线程变更队列。
2 .根据权利要求1所述的数据同步方法,其中,在创建一个线程变更队列的步骤之后,
还包括:
将所述线程变更队列的名称添加至线程变更顺序队列,利用所述线程变更顺序队列记
录所述线程变更队列的提交顺序。
3 .根据权利要求2所述的数据同步方法,其中,在将所述二次解析数据提交到所述线程
变更队列的步骤之后,还包括:
启动消费线程,从所述线程变更顺序队列获取所述线程变更队列;
将所述线程变更队列的二次解析数据写入到结果队列。
4 .根据权利要求3所述的数据同步方法,其中,在将所述二次解析数据提交到所述线程
变更队列的过程中,所述方法还包括:
向所述线程变更队列写入一条提交标记,以指示所述待同步事务已完成二次解析操
作;
结束所述二次解析线程,并将其回收至所述二次解析线程池中。
5 .根据权利要求4所述的数据同步方法,其中,将所述线程变更队列的二次解析数据写
入到结果队列的过程中,所述方法还包括:
检查所述消费线程是否从所述线程变更队列中读取到所述提交标记;
若是,从所述线程变更顺序队列移除所述线程变更队列。
6 .根据权利要求3所述的数据同步方法,其中,所述线程变更队列为有限容量的阻塞队
列,在将所述二次解析数据提交到所述线程变更队列的过程中,所述方法还包括:
检查所述线程变更队列中的二次解析数据是否达到配置容量值;
若是,暂停所述二次解析线程。
7 .根据权利要求6所述的数据同步方法,其中,在暂停所述二次解析线程的步骤之后,
还包括:
检查所述消费线程是否消费到所述线程变更队列的二次解析数据;
若是,重新启动所述二次解析线程。
8.根据权利要求1所述的数据同步方法,其中,
所述待同步事务的初次解析数据提交至重排缓冲器中。
9 .一种机器可读存储介质,其上存储有机器可执行程序,所述机器可执行程序被处理
器执行时实现根据权利要求1‑8任一项所述的数据同步方法。
10.一种计算机设备,包括存储器、处理器及存储在所述存储器上并在所述处理器上运
行的机器可执行程序,并且所述处理器执行所述机器可执行程序时实现根据权利要求1‑8
权 利 要 求 书
1/2 页
2
相关文档
评论