主权项 |
一种海量数据管理中动态一致性控制方法,其特征在于,该方法包括以下步骤:(1)主线程对环境做初始化工作,包括以下五个步骤:(1.1)创建三个空置队列,按照创建的先后顺序,分别命名为高优先级队列,表示为HQ;中优先级队列,表示为MQ;低优先级队列,表示为LQ;(1.2)创建三个变量NS、VS、PS,分别用来保存所有的任务队列中所有的任务的数据条目偏差总和,数值偏差总和以及新旧程度偏差总和,并将初始值均设为0;(1.3)创建三个计数器NC、VC、PC,分别用来保存当前所有的任务队列中关于数据条目偏差的任务总数,数值偏差的任务总数以及新旧程度偏差的任务总数,并将初始值均设为0;(1.4)创建并启动一个子线程T1,用于逐个处理三个任务队列中的任务;(1.5)创建并启动两个子线程T2和T3,用于定期调度三个任务队列中的任务,避免因较高优先级任务队列中的任务长时间拥堵,导致较低优先级队列中的任务没有机会处理的情况发生;(2)服务节点开始监听来自客户端发来的读写请求;(3)当服务节点接收到一个来自客户端发来的数据读写请求任务后,首先读取该请求任务的操作类型;(4)读取该请求任务的偏差类型,并读取该请求任务的偏差值,并将读取结果与当前的阈值比较后放到相应的队列尾部;(5)回退到步骤(2),继续监听来自客户端发来的请求。 |