(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202210757280.5 (22)申请日 2022.06.30 (71)申请人 中国工商银行股份有限公司 地址 100140 北京市西城区复兴门内大街 55号 (72)发明人 胡文涛　王卓成　李逶　陈鹏翼　 (74)专利代理 机构 华进联合专利商标代理有限 公司 44224 专利代理师 姚姝娅 (51)Int.Cl. G06F 9/48(2006.01) G06F 9/50(2006.01) (54)发明名称 任务调度方法、 装置、 计算机设备、 存储介质 和程序产品 (57)摘要 本申请涉及大数据领域， 特别涉及任务调度 方法、 装置、 计算机设备、 存储介质和程序产品。 方法包括： 获取分布式系统中的所有候选任务和 各候选任务的任务并发数量； 候选任务表示分布 式系统中当前已被执行容错机制的任务； 获取各 候选任务对应的关键服务节点的最小空闲线程 数； 根据各关键服务节点的最小空闲线程数， 对 对应候选任务的任务并发数量进行调整， 得到各 候选任务的目标任务并发数； 目标任务并发数为 各关键服务节点能够执行对应候选任务的任务 数量。 采用本方法能够降低再次执行候选任务时 仍然可能会发生阻塞的风险。 权利要求书2页 说明书16页 附图6页 CN 115016915 A 2022.09.06 CN 115016915 A 1.一种任务调度方法， 其特 征在于， 所述方法包括： 获取分布式系统中的所有候选任务和各所述候选任务的任务并发数量； 所述候选任务 表示所述分布式系统中当前已被执 行容错机制的任务； 获取各所述候选任务对应的关键服 务节点的最小空 闲线程数； 根据各所述关键服务节点的最小空闲线程数， 对对应候选任务的任务并发数量进行调 整， 得到各所述候选任务的目标任务并发数； 目标任务并发数为各所述关键服务节点能够 执行对应候选任务的任务数量。 2.根据权利要求1所述的方法， 其特征在于， 在获取各所述候选任务对应的关键服务节 点的最小空 闲线程数之前， 所述方法还 包括： 获取服务调用层次关系， 所述 服务调用层次关系包括各个任务的服 务节点调用链； 将所述服务调用 层次关系中各个任务的服务节点调用链中存在预设的节点标识的服 务节点确定为关键服务节点； 所述节点标识用于标识发生任务调度堵塞概率大于预设概率 值的服务节点。 3.根据权利要求2所述的方法， 其特征在于， 所述获取各候选任务对应的关键服务节点 的最小空 闲线程数， 包括： 根据所述服务调用 层次关系中的各个关键服务节点， 构建服务节点分类树； 所述服务 节点分类树包括对应于所有所述关键服务节点的节点区间以及每个节点区间的实时空闲 线程数； 根据所述服务节点分类树， 确定各所述候选任务对应的关键服务节点的最小空闲线程 数。 4.根据权利要求3所述的方法， 其特征在于， 所述根据服务节点分类树， 确定各所述候 选任务对应的关键服 务节点的最小空 闲线程数， 包括： 从所述服务节点分类树中查询各所述候选任务对应的关键服务节点的实时空闲线程 数； 针对任一个候选任务， 将所述候选任务对应的关键服务节点的实时空闲线程数中的最 小值， 确定为所述 候选任务对应的关键服 务节点的最小空 闲线程数。 5.根据权利要求3所述的方法， 其特征在于， 根据所述服务节点分类树， 确定各所述候 选任务对应的关键服 务节点的最小空 闲线程数， 包括： 针对任一个候选任务， 从所述服务节点分类树中查询所述候选任务对应的关键服务节 点所属的目标节点区间； 将所述目标节点 区间的实时空闲线程数中的最小值， 确定为所述候选任务对应的关键 服务节点的最小空 闲线程数。 6.根据权利要求3 ‑5任一项所述的方法， 其特征在于， 在对对应候选任务的任务并发数 量进行调整， 得到各 所述候选任务的目标任务并发数之后， 所述方法还 包括： 针对任一个候选任务， 根据所述候选任务的目标任务并发数， 对所述服务节点分类树 中所述候选任务对应的目标节点区间的实时空闲线程数进 行更新， 并对更新完成的目标节 点区间进行 标记。 7.根据权利要求1 ‑5所述的方法， 其特征在于， 根据各所述关键服务节点的最小空闲线 程数， 对对应候选任务的任务并发数量进 行调整， 得到各所述候选任务的目标任务并发数，权　利　要　求　书 1/2 页 2 CN 115016915 A 2包括： 将各所述候选任务的任务并发数量和各所述候选任务对应的关键服务节点的最小空 闲线程数进行比对， 得到各 所述候选任务的比对结果； 通过各所述候选任务的比对结果， 对对应候选任务的任务并发数量进行调整， 得到各 所述候选任务的目标任务并发数。 8.根据权利要求7所述的方法， 其特征在于， 所述通过各候选任务的比对结果， 对对应 候选任务的任务并发数量进行调整， 得到各 所述候选任务的目标任务并发数， 包括： 针对任一个候选任务， 若所述候选任务的对比结果为所述候选任务的任务并发数量大 于所述候选任务对应的关键服务节点的最小空闲线程数， 则将所述候选任务的任务并发数 量调整为与所述最小空闲线程数相同的数量； 所述最小空闲线程数为所述候选任务的目标 任务并发数。 9.一种任务调度装置， 其特 征在于， 所述装置包括： 第一获取模块， 用于获取分布式系统中的所有候选任务和各所述候选任务的任务并发 数量； 所述 候选任务表示所述分布式系统中当前已被执 行容错机制的任务； 第二获取模块， 用于获取 各所述候选任务对应的关键服 务节点的最小空 闲线程数； 调整模块， 用于根据各所述关键服务节点的最小空闲线程数， 对对应候选任务的任务 并发数量进行调整， 得到各所述候选任务的目标任务并发数； 目标任务并发数为各所述关 键服务节点能够执 行对应候选任务的任务数量。 10.一种计算机设备， 包括存储器和 处理器， 所述存储器存储有计算机程序， 其特征在 于， 所述处 理器执行所述计算机程序时实现权利要求1至8中任一项所述的方法的步骤。 11.一种计算机可读存储介质， 其上存储有计算机程序， 其特征在于， 所述计算机程序 被处理器执行时实现权利要求1至8中任一项所述的方法的步骤。 12.一种计算机程序产品， 包括计算机程序， 其特征在于， 该计算机程序被处理器执行 时实现权利要求1至8中任一项所述的方法的步骤。权　利　要　求　书 2/2 页 3 CN 115016915 A 3