CN113495779B 一种任务调度方法和装置、任务执行系统 （北京沃东天骏信息技术有限公司）

级相对权重比、任务在其子流程中最近N次历史先级相对权重比根据配置的各业务线权重计算2将不同业务线的同一子流程的任务分配到同一任务执行器，根据所述任务的优先级相对权重比、所述任务在其子流程中最近N次历史执行记录的按照所述动态优先级调度每一所述任务执行2.根据权利要求1所述的方法，其特征在于，根据所述任务在其子流程的平均执行时根据所述任务在其子流程的平均执行时长与所述任务在其子流程中最近N次历史执行根据所述任务的单位数据量的平均时长与所述任务本次执行的数据6.根据权利要求1所述的方法，其特征在于，所述预设通过如下方式计算所述任务在其任务执行器计算所述任务在其子流程中最近N次历史执行记录的最大执行时长与所述任务在其任务执行器中的预测执行时长的第一差值，将所述第一差值与所述任务在其子流程中最近N以所述预设的第一调和因子作为所述任务的优先级相对权重比的加权系数，以1与所对于每一所述任务执行器，按照其中任务的所述动态优先级生成任定所述任务队列中每一任务对应的分组，所述分组与所述任务执行器中的计算机一一对3任务分配模块，用于将不同业务线的同一子流程的任务分动态优先级计算模块，用于根据所述任务的优先级的优先级相对权重比根据配置的各所述业务线权重计算得所述任务调度中心处理器，用于将不同业务线的同一子流程的任务流程中最近N次历史执行记录的最大执行时长、所述任务在其任务执行器中的预测执行时4流程中最近N次历史执行记录的最大执行时长、所述任务在其任务执行器中的预测执行时所述任务在其子流程中最近N次历史执行记录的平均数据量，计算所述任务在其任务执行述任务在其子流程的平均执行时长与所述任务在其子流程中最近N次历史执行记录的平均5最近N次历史执行记录的平均数据量、所述当次历史执行记录开始时间距离当前的间隔天任务在其任务执行器中的动态优先级：计算所述任务在其子流程中最近N次历史执行记录值与所述任务在其子流程中最近N次历史执行记录的最大执行时长的比值，作为所述任务权系数，以1与所述预设的第一调和因子的第二差值作为所述任务的预计空闲时间占比的加权系数，计算所述任务的优先级相对权重比与所述任务的预计空闲时间占比的加权和，务队列中的每一任务对应的分组时，统计各分组当前已有任务的所述预测执行时长的总述任务的优先级相对权重比、所述任务在其子流程中最近N次历史执行记录的最大执行时行时长与所述任务在其子流程中最近N次历史执行记录的平均数据量的商，得到所述任务6程中最近N次历史执行记录的最大执行时长与所述任务在其任务执行器中的预测执行时长的第一差值，将所述第一差值与所述任务在其子流程中最近N次历史执行记录的最大执行务的优先级相对权重比的加权系数，以1与所述预设的第一调和因子的第二差值作为所述流程中最近N次历史执行记录的最大执行时长、所述任务在其任务执行器中的预测执行时7[0031]上述的非惯用的可选方式所具有的进一步效果将在下文中结合具体实施方式加[0041]图9是适于用来实现本发明实施例的终端设备或服务器的计算机系统的结构示意[0044]如图1所示，本发明一个实施例的任务调度方法主要包括如下的步骤S101至步骤8其子流程的平均执行时长与任务在其子流程中最近N次历史执行记录的平均数据量的商，[0051]可以通过如下方式计算任务在其子流程的平均执行时长：根据任务在其子流程[0053]预设的第二调和因子的取值范围在(0,1)[0054]任务的优先级相对权重比等于第一业务线权重与配置的各业务线权重的总和的子流程中最近N次历史执行记录的最大执行时长与任务在其任务执行器中的预测执行时长的第一差值，将该第一差值与任务在其子流程中最近N次历史执行记录的最大执行时长的比的加权系数，以1与预设的第一调和因子的第二差值作为任务的预计空闲时间占比的加9务从整体上统计任务执行耗时30分钟，从而实现根据硬件资源的忙碌和空闲状况调度任作Job_dataCenter，以及若干多个任务执行器，记作：multi_Job_Performeri|i＝1,该任务分配到空闲任务执行器(未执行任何子流程的任务务开始时间(work_start_tm)、任务结束时间(work_end_tm)、每次执行时任务的数据量data_size等，任务执行记录表还包括任务在其子流程中各次历史执行记录的执行时长算出的上述四项计算出任务k在其任务执行器i中的动态优先级dyn_priority[0076]avg_timeik表示行时都保持不变，那么任务k在其子流程中的当前执行时长只与任务k本次执行的数据量[0077]定义w_hisi为任务在其子流程的最近N次历史执行记录中第i次历史执行记录的为最近N次历史执行记录中第i次历史执行记录的数据量大小，为最近N次历史执行记录的平均数据量，dis_daysi是最近N次历史执行记录中第i次历史执行记录开始[0080]假设任务在其子流程一共有u次历史执行记录，且历史执行记录是按照时间顺序[0082]其中，w_hisr为任务在其子流程的所有历史执行记录中的第r次历史执行记录的影响权重；data_sizer为该第r的偏移是指本次任务数据量大小与本任务最近10次的数据量大小平均值的差距)，权重应[0086]即根据任务k的最近10次执行历史执行记录的影响权重以及执行时长，计算得到[0087]下面举例介绍任务k在cal_sec表示任务在其子流程中各次历史执行[0088]按照任务在其子流程的最近N次历史执行记录中第i次历史执行记录的影响权重[0090]根据图4(a)所示，data_size1＝12，最近四次历史执行记录的平均数据量[0103]对于任务k，通过上述方法可以得到任务k在其子流程i的平均执行时长avg_[0104]下面计算任务k在其任务执行器i的预测执行时长forecast_timeik，forecast_timeik与该任务k在其子流程的平均执行时长和本次执行的数据均执行时长avg_timeik与该平均数据量的商为任务k的单位数据量的[0111]任务1对应的上述平均数据量任务2对应的上述平均数据量那么通过上述forecast_timeik的计算公式可以计算出forecast_time11[0112]根据任务k的优先级相对权重比任务k在其子流程i中最近N次历史执行记录的最大执行时长max(timer＝u-N-1,u)、任务k在其任务执行器i中的预测执行时长[0118]任务调度中心通过一个核心任务对各个执行状态的任务按照任务对应的子流程为任务分配任务执行器，每个任务执行器中有多台计算机并发执个任务都被分配到当前执行任务总体耗时最短的一个机器(计算机)[0119]由于基础数据的数量不同，即使同样的计算逻辑也会导致任务的执行时长不一[0122]任务分配模块701，用于将不同业务线的同一子流程的任务分配到同一任务执行务在其子流程中最近N次历史执行记录的平均数据量的商，得到任务的单位数据量的平均[0129]任务调度装置700还可以包括优先级相对权重比计算模块，用于根据第一业务线[0131]动态优先级计算模块702具体用于通过如下方式计算任务在其任务执行器中的动态优先级：计算任务在其子流程中最近N次历史执行记录的最大执行时长与任务在其任务执行器中的预测执行时长的第一差值，将该第一差值与任务在其子流程中最近N次历史执为任务的优先级相对权重比的加权系数，以1与预设的第一调和因子的第二差值作为任务任务队列中的每一任务对应的分组时，统计各分组当前已有任务的预测执行时长的总和，[0137]本发明一个实施例的任务执行系统的任务执行原理，以及任务调度中心处理器、[0138]图8示出了可以应用本发明实施例的任务调度方法或任务调度装置的示例性系统[0145]下面参考图9，其示出了适于用来实现本申请实施例的终端设备或服务器的计算存储器(ROM)902中的程序或者从存储部分908加载到随机访问存储器(RAM)903中的程序而的计算机程序根据需要被安装入存储部分9申请中，计算机可读的信号介质可以包括在基带中或者作为载波一部