(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202210549648.9 (22)申请日 2022.05.20 (71)申请人 新华三技术有限公司 地址 310052 浙江省杭州市滨江区长河路 466号 (72)发明人 元立本　石超　 (51)Int.Cl. G06F 9/50(2006.01) (54)发明名称 集群模式下分布式任务调度方法、 装置、 设 备及存储介质 (57)摘要 本发明提供一种集群模式下分布式任务调 度方法、 装置、 设备及存储介质， 用于解决任务调 度框架调度不灵活和调度效率不高的技术问题。 本发明通过增加线程监控器监听任务数量， 根据 任务数量等信息动态地调整线程池的配置参数； 通过增加任务监控器监控作业任务的执行状态， 提供停止作业任务的接口以实现按需停止作业 任务的能力； 通过任务监控器监控周期性调度的 作业任务的执行情况， 提供任务调度策略的动态 调整接口， 以实现根据资源负载动态调整周期性 调度的作业任务的调度策略的功能。 本发明能够 提高分布式任务调度框架的作业任务的调度灵 活性和调度效率， 避免资源的浪费， 提高资源的 利用率， 预防服 务和数据库的宕机 。 权利要求书2页 说明书7页 附图2页 CN 115033375 A 2022.09.09 CN 115033375 A 1.一种集群模式下分布式任务调度方法， 其特征在于， 该方法应用于为分布式计算集 群提供任务调度功能的任务调度节点， 该 方法包括： 通过线程监控器监 听任务调度信 息库中的任务数量， 根据任务数量动态地调整线程池 的配置参数； 提供停止作业任务接口， 通过任务监控器响应停止作业任务指令， 获取执行作业任务 的线程信息， 停止对应作业任务； 通过任务监控器监控周期性调度的作业任务的执行情况， 根据作业任务的执行情况及 资源负载情况动态调整周期性调度的作业任务的调度策略。 2.根据权利要求1所述的方法， 其特征在于， 所述根据任务数量动态地调整线程池的配 置参数的方法为： 若当前任务数量超过前一统计周期的任务数量且小于预设的最大任务数量门限值 时， 增加线程池的线程数量； 若当前任务数量小于前一统计周期任务数量的预设比例且大于预 设的最小任务数量门限值时， 减小 线程池的线程数量。 3.根据权利要求1所述的方法， 其特征在于， 所述通过任务监控器响应停止作业任务指 令， 获取执行作业任务的线程信息， 停止对应作业任务的步骤 包括： 所述任务监控器根据停止作业任务指令中携带的作业任务标识在任务调度信息库中 查询执行对应作业任务的线程信息， 向线程所在计算节点发送停止作业任务的指 令以使计 算节点停止作业任务的执 行。 4.根据权利要求1所述的方法， 其特征在于， 所述通过任务监控器监控周期性调度的作 业任务的执行情况， 根据作业任务的执行情况及资源负载情况动态调整周期性调度的作业 任务的调度策略的方法为： 通过任务监控器周期性获取所述周期性调度的作业任务的执行情况以及执行所述周 期性调度的作业任务的计算节点和业 务数据库的资源负载情况； 在所述计算节点和业务数据库的资源充足的情况下， 调整所述作业任务的调度策略， 允许所述周期性调度的作业任务并行 执行； 在所述计算节点和业务数据库的资源不足的情况下， 调整所述作业任务的调度策略， 使所述周期性调度的作业任务串行 执行。 5.根据权利要求1所述的方法， 其特 征在于， 所述周期性调度的作业任务的执行情况包括作业任务是否完成、 未完成作业任务的预 估完成时长； 在前一所述周期性调度的作业任务未完成的情况下， 所述任务监控器根据所述计算节 点和业务数据库的资源情况， 动态调整后续所述周期性调度的作业任务的调度策略； 任务调度器根据修改后的任务调度策略进行任务调度。 6.一种集群模式下分布式任务调度装置， 其特征在于， 该装置应用于为分布式计算集 群提供任务调度功能的任务调度节点， 该装置包括： 线程监控器， 用于监听任务调度信息库中的任务数量， 根据任务数量动态地调整线程 池的配置参数； 任务监控器， 用于提供停止作业任务接口， 响应停止作业任务指令， 获取执行作业任务 的线程信息， 停止对应作业任务； 还用于监控周期性调度的作业任务的执行情况， 根据作业权　利　要　求　书 1/2 页 2 CN 115033375 A 2任务的执 行情况及资源负载情况动态调整周期性调度的作业任务的调度策略。 7.根据权利要求6所述的装置， 其特 征在于， 所述任务监控器在当前任务数量超过前一统计周期的任务数量且小于预设的最大任 务数量门限值时， 增加线程池的线程数量； 在当前任务数量小于前一统计周期任务数量的 预设比例且大于预设的最小任务数量门限值时， 减小 线程池的线程数量。 8.根据权利要求6所述的装置， 其特 征在于， 所述任务 监控器包括： 任务停止模块， 用于根据停止作业任务指令 中携带的作业任务标识在任务调度信 息库 中查询执行对应作业任务的线程信息， 向线程所在计算节点 发送停止作业任务的指令以使 计算节点停止作业任务的执 行； 状态资源获取模块， 用于周期性获取所述周期性调度的作业任务的执行情况以及执行 所述周期性调度的作业任务的计算节点和业 务数据库的资源负载情况； 调度策略调整模块， 用于在所述计算节点和业务数据库的资源充足的情况下， 调整所 述作业任务的调度策略， 允许所述周期性调度的作业任务并行执行； 在所述计算节点和业 务数据库的资源不足的情况下， 调整所述作业任务的调度策略， 使所述周期性调度的作业 任务串行 执行。 9.一种电子设备， 其特征在于， 包括处理器、 通信接口、 存储介质和通信总线， 其中， 处 理器、 通信接口、 存 储介质通过通信总线完成相互间的通信； 存储介质， 用于存放计算机程序； 处理器， 用于执行存储介质上所存放的计算机程序时， 实施权利要求1 ‑5中任一项所述 的方法。 10.一种计算机可读存储介质， 其上存储有计算机程序， 其特征在于， 所述计算机程序 当被处理器执行时实施如权利要求1至 5中任一项所述的方法。权　利　要　求　书 2/2 页 3 CN 115033375 A 3