异构分布式实时系统的事务调度方法

摘要

本发明涉及异构分布式并行处理领域的事务优先级确定方法，包括下列步骤：确定全局事务的优先级；将全局事务分解得到的子事务按其涉及的数据的物理位置进行分配；动态确定局部事务各部分的优先级；局部事务并行处理；返回执行结果等。本发明提供一种基于异构分布式系统的动态确定事务优先级的流程，保证了系统处理全局事务的实时性、可靠性。

主权项

1.一种异构分布式实时系统的事务调度方法，其特征在于，包括以下步骤：步骤1，全局事务管理系统的全局事务调度器给各全局事务分配优先级；步骤2，全局事务调度器判断某个全局事务是否能分解；如果该事务能够分解，则全局事务调度器对该全局事务按语义以及涉及的数据的物理位置进行分析并分解为若干子事务，将分解得到的子事务分配到合适的节点上成为局部事务，各局部事务的初始优先级为原全局事务的优先级；否则，将该全局事务分配到合适的节点上作为一个局部事务；步骤3，各节点上的局部实时事务管理系统分别对本节点的局部事务构建有向无环图模型，该有向无环图模型包括若干具有前驱、后续依赖关系的事务层；步骤4，对每一个分配有子事务的节点，分别执行以下步骤：步骤4-1、确定该节点内的多核处理器的各内核最早可以开始执行新的事务的时间；步骤4-2，确定该节点的每个事务的所有前驱事务执行完毕时间；步骤4-3，确定该节点的各个事务之间的通讯损耗时间；如果父事务与子事务在同一个核上执行，则两者之间的数据传递时间可以视为0；如果分配到不同核上执行，则各个事务之间的通讯损耗时间为：（1）其中表示将数据在核传递到核需要的时间，表示的是事务的规模大小，通过单位时间内的读写次数来衡量，表示的是事务的规模大小与事务在不同节点之间传递的时间的线性因子，表示的是初始化参数；步骤4-4，确实各事务在各内核的最早开始时间；表示事务在核上的最早可以开始时间，可以通过以下公式计算得到：（2）（3）其中表示事务的所有前驱事务，，表明核已经空闲可以最早开始执行下一个事务的时间，通过估计在该核内等待调度的事务规模进行衡量，事务规模同样通过单位时间内事务读写次数来判断；表示数据传递时间损耗，通过公式(1)获得，如果是在同一个核内传递则设为0；事务在核开始时间加上事务本身执行时间得到事务在核上最早执行完毕时间；步骤4-5，当事务从上一层执行到本层时，重新计算本层内各事务的优先级，优先级可以根据如下公式计算得出：（4）其中表示事务的优先级，假设节点为核处理器，从中选取保证事务最早开始执行的核为调度目的地，表示入口事务的优先级大小，即为全局事务的优先级；步骤4-6，根据步骤4-5计算的优先级，对优先级队列重新排序；步骤4-7，内核根据优先级队列执行事务，局部事务调度器监视执行状态并反馈给全局事务调度器；如果执行成功，则记录执行结果以及执行结束时间；如果执行失败，则返回错误代码并进行必要的回滚操作；步骤4-8，判断同层各事务是否在各核内均执行完毕；如果没有则进行等待；步骤4-9，同层执行完毕，则转入下层，返回步骤4-5，直到执行到出口事务，即该局部事务执行完毕；步骤4-10，将局部事务执行结果返回给全局事务管理系统，供其进行结果汇总以及返回给应用服务器。