(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202210987579.X (22)申请日 2022.08.17 (71)申请人 中国银联股份有限公司 地址 201203 上海市浦东 新区含笑路36号 (72)发明人 齐强　王增慧　 (74)专利代理 机构 北京市中伦律师事务所 11410 专利代理师 吴迪 (51)Int.Cl. G06F 9/50(2006.01) G06F 9/54(2006.01) (54)发明名称 一种任务调度方法、 装置、 电子设备及存储 介质 (57)摘要 本公开提供了一种任务调度方法、 装置、 电 子设备及存储介质， 其中， 该方法包括： 获取监测 器针对各层级任务 队列确定的当前任务调度比 例； 当前任务调度比例是在最小化集群阻塞状态 的情况下， 针对 各层级任务队列预测的实时调度 比例； 从各层级任务队列中确定与当前任务调度 比例对应的多个待调度任务； 将多个待调度任务 插入到缓存队列中。 本公开中的当前任务调度比 例是基于最小化集群阻塞状态确定的， 这样所实 现的调度 将更大可能的利用集群资源， 使得各任 务都能够被有效调度， 除此之外， 这里的当前任 务调度比例是 实时产生的， 这将尽可能的缓解业 务系统在进行大数据任务调度过程中所产生的 各种问题， 进一 步提升调度效率。 权利要求书2页 说明书14页 附图3页 CN 115421905 A 2022.12.02 CN 115421905 A 1.一种任务调度方法， 其特 征在于， 包括： 获取监测器针对各层级任务队列确定的当前任务调度比例； 所述当前任务调度比例是 在最小化 集群阻塞状态的情况 下， 针对所述各层级任务队列预测的实时调度比例； 从所述各层级任务队列中确定与所述当前任务调度比例对应的多个待调度任务； 将所述多个待调度任务插入到缓存队列中， 以使得目标集群按照所述缓存队列的缓存 机制将所述多个待调度任务进行 出队并进行集群运 算。 2.根据权利要求1所述的方法， 其特 征在于， 所述方法还 包括： 在所述缓存队列中的待调度任务为空 的情况下， 响应于所述监测器针对各层级任务队 列确定的下一个任务调度比例。 3.根据权利要求1所述的方法， 其特征在于， 所述获取监测器针对各层级任务队列确定 的当前任务调度比例， 包括： 周期性地获取监测器 针对各层级任务队列确定的当前任务调度比例。 4.一种任务调度方法， 其特 征在于， 包括： 针对各层级任务队列确定当前任务调度比例； 所述当前任务调度比例是在最小化集群 阻塞状态的情况 下， 针对所述各层级任务队列预测的实时调度比例； 响应于调度器的任务调度请求， 将所述当前任务调度比例 发送至所述调度器， 以使得 所述调度器根据所述当前任务调度比例将所述各层级任务队列中的任务调度至缓存队列。 5.根据权利要求4所述的方法， 其特征在于， 所述针对各层级任务队列确定当前任务调 度比例， 包括： 获取各层级任务队列对应的当前任务 提交数和历史任务 提交数； 基于所述当前任务提交数和所述历史任务提交数， 预测得到各层级任务队列对应的未 来任务提交数； 基于所述未来任务提交数、 所述各层级任务队列当前所需的等待时间、 以及调度比例 参数， 构建包 含有调度比例参数的未来 集群阻塞状态函数； 确定在最小化未来集群阻塞状态函数的情况下， 所述调度比例参数对应的目标参数 值， 并将所述目标参数值作为所述当前任务调度比例。 6.根据权利要求5所述的方法， 其特征在于， 在所述未来任务提交数指示的是y年m月d 天第i个小时的预测结果， 且y为正整数， m为小于12的正整数， d为小于365的正整数， i为小 于24的正整数的情况下， 所述基于所述当前任务提交数和所述历史任务提交数， 预测得到 各层级任务队列对应的未来任务 提交数， 包括： 基于所述各层级任务队列在y年m月d天中i ‑3到i‑1个小时内产生的历史任务提交数， 确定第一历史任务平均提交数； 以及基于所述各层级任务队列在y年m月d ‑3到d‑1天第i个 小时内产生的历史任务提交数， 确定第二历史任务平均提交数； 以及基于所述各层级任务 队列在y年m ‑3月到m‑1月d天第i个小 时内产生的历史任务提交数， 确定第三历史任务平均 提交数； 以及基于所述各层级任务队列在y ‑3年到y‑1年m月d天第i个小 时内产生的历史任 务提交数， 确定第四历史任务平均提交数； 基于所述第一历史任务平均提交数、 所述第二历史任务平均提交数、 所述第三历史任 务平均提交数据以及所述第四历史任务平均提交数， 确定所述各层级任务队列在未来产生 的任务提交增量数；权　利　要　求　书 1/2 页 2 CN 115421905 A 2基于所述当前任务 提交数和所述任务 提交增量数， 确定所述未来任务 提交数。 7.根据权利要求6所述的方法， 其特征在于， 所述基于所述第一历史任务平均提交数、 所述第二历史任务平均提交数、 所述第三历史任务平均提交数据以及所述第四历史任务平 均提交数， 确定所述各层级任务队列在未来产生的任务 提交增量数， 包括： 分别为所述第一历史任务平均提交数、 所述第二历史任务平均提交数、 所述第三历史 任务平均提交数据以及所述第四历史任务平均提交数 赋予任务权 重值； 基于所述第一历史任务平均提交数、 所述第二历史任务平均提交数、 所述第三历史任 务平均提交数据、 所述第四历史任务平均提交数、 以及针对各个历史任务平均提交数赋予 的任务权 重值之间的加权求和， 确定所述任务 提交增量数。 8.根据权利要求5至7任一所述的方法， 其特征在于， 所述确定在最小化未来集群阻塞 状态函数的情况 下， 所述调度比例参数对应的目标参数值， 包括： 在每遍历一个预设调度比例参数对应的参数值的情况下， 确定所述未来集群阻塞状态 函数对应的函数值； 选取使得函数值 最小的参数值， 作为所述目标参数值。 9.根据权利要求 4所述的方法， 其特 征在于， 所述方法还 包括： 接收所述缓存队列记录的各层级任务队列对应的各任务出队时间， 以根据所述任务出 队时间更新所述各层级任务队列的状态信息 。 10.一种任务调度装置， 其特 征在于， 包括： 获取模块， 用于获取监测器针对各层级任务队列确定的当前任务调度比例； 所述当前 任务调度比例是在最小化集群阻塞状态的情况下， 针对所述各层级任务队列预测的实时调 度比例； 确定模块， 用于从所述各层级任务队列中确定与 所述当前任务调度比例对应的多个待 调度任务； 调度模块， 用于将所述多个待调度任务插入到缓存队列中， 以使得目标集群按照所述 缓存队列的缓存机制将所述多个待调度任务进行 出队并进行集群运 算。 11.一种任务调度装置， 其特 征在于， 包括： 确定模块， 用于针对各层级任务队列确定当前任务调度比例； 所述当前任务调度比例 是在最小化 集群阻塞状态的情况 下， 针对所述各层级任务队列预测的实时调度比例； 调度模块， 用于响应于调度器的任务调度请求， 将所述当前任务调度比例 发送至所述 调度器， 以使得所述调 度器根据所述当前任务调度比例将所述各层级任务队列中的任务调 度至缓存队列。 12.一种电子设备， 其特征在于， 包括： 处理器、 存储器和总线， 所述存储器存储有所述 处理器可执行 的机器可读指令， 当电子设备运行时， 所述处理器与所述存储器之间通过总 线通信， 所述机器可读指 令被所述处理器执行时执行如权利要求 1至9任一所述的任务调度 方法。 13.一种计算机可读存储介质， 其特征在于， 该计算机可读存储介质上存储有计算机程 序， 该计算机程序被处 理器运行时执 行如权利要求1至9任一所述的任务调度方法。权　利　要　求　书 2/2 页 3 CN 115421905 A 3