(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202210788412.0 (22)申请日 2022.07.04 (71)申请人 北京志凌海纳科技有限公司 地址 100086 北京市海淀区知春路甲48号1 号楼8B (72)发明人 王俊锋　徐文豪　王弘毅　张凯　 (74)专利代理 机构 北京绘聚高科知识产权代理 事务所(普通 合伙) 11832 专利代理师 罗硕 (51)Int.Cl. G06F 11/20(2006.01) G06F 9/48(2006.01) G06F 9/50(2006.01) (54)发明名称 一种分布式任务的动态分配方法和系统 (57)摘要 本发明公开一种分布式任务的动态分配方 法和系统， 其中， 分布式任务的动态分配方法包 括： 任务调度器根据任务列表中的任务和所有工 作节点的资源信息， 将任务分配至工作节点的任 务执行器； 任务执行器实时监测任务的执行状 态， 当任务的执行状态异常时向任务调度器汇报 异常节点的任务异常信息； 任务调度器 当收到任 务异常信息时， 获取每个工作节 点的资源信息和 未执行任务信息； 任务调度器确定召回的未执行 任务， 并根据资源信息和未执行任务信息制定任 务分配方案； 任务调度器根据任务分配方案， 将 召回的未执行任务和任务列表中的新增任务分 配至工作节 点。 本发明的技术方案能解决现有技 术中任务分配不合理， 容易出现堵塞或工作节点 的资源利用率低的问题。 权利要求书3页 说明书11页 附图7页 CN 115048247 A 2022.09.13 CN 115048247 A 1.一种分布式任务的动态分配方法， 其特 征在于， 包括： 任务调度器根据任务列表中的任务和所有工作节点的资源信 息， 将所述任务分配至工 作节点的任务执 行器； 所述任务执行器实时监测所述任务的执行状态， 当所述任务的执行状态异常时向所述 任务调度器汇报异常节点的任务异常信息； 所述任务调度器当 收到所述任务异常信 息时， 获取每个工作节点的资源信 息和未执行 任务信息； 所述任务调度器确定召回的未执行任务， 并根据 所述资源信 息和未执行任务信 息制定 任务分配方案； 所述任务调度器根据 所述任务分配方案， 将召回的所述未执行任务和所述任务列表中 的新增任务分配至所述工作节点。 2.根据权利要求1所述的动态分配方法， 其特征在于， 所述异常节点的任务异常信 息包 括超时节点的任务超时信息； 所述任务调 度器确定召回的未执行任务并根据所述资源信息 和未执行任务信息制定任务分配方案的步骤， 包括： 所述任务调度器当收到所述任务超时信息时， 召回所述超时节点的未 执行任务； 所述任务调度器根据除所述超时节点外每个工作节点的资源信 息和未执行任务信 息， 制定所述超时节点的未 执行任务和所述任务列表中新增任务的任务分配方案； 所述任务调度器按照所述任务分配方案， 将所述未执行任务和所述新增任务统一分配 至除所述超时节点外的工作节点。 3.根据权利要求2所述的动态分配方法， 其特征在于， 所述任务调度器根据除所述超时 节点外每个工作 节点的资源信息和未执行任务信息， 制定所述超时节点的未执行任务和所 述任务列表中新增任务的任务分配方案的步骤， 包括： 所述任务调度器使用所述资源信 息和未执行任务信 息， 计算除所述超时节点外每个工 作节点的现有任务完成时间； 所述任务调度器使用所述资源信息和每项所述未执行任务和所述新增任务的消耗资 源量， 分别计算除所述超时节点外每 个工作节点分别对每项任务的任务执 行时间； 所述任务调度器按照所述现有任务完成时间以及所述任务执行时间， 分别分配所述未 执行任务和新增任务， 以均衡 每个工作节点的任务完成时间。 4.根据权利要求1所述的动态分配方法， 其特征在于， 所述异常节点的任务异常信 息包 括任务完成节点的任务完成信息； 所述任务调 度器确定召回的未执行任务并根据所述资源 信息和未 执行任务信息制定任务分配方案的步骤， 包括： 所述任务调度器根据除所述任务完成节点外其他所有工作节点的资源信息和未执行 任务信息， 制定所有未 执行任务和所述任务列表的新增任务的任务分配方案； 所述任务调度器判断所述任务分配方案分配的未 执行任务是否仍在原工作节点中； 若所述未执行任务仍在原工作节点中， 则所述任务调度器召回除仍在原工作节点的其 他所有未 执行任务； 所述任务调度器按照所述任务分配方案， 分配所述除仍在原工作节点的其他所有未执 行任务和所述 新增任务至所述工作节点。 5.根据权利要求4所述的动态分配方法， 其特征在于， 所述任务调度器根据除所述任务权　利　要　求　书 1/3 页 2 CN 115048247 A 2完成节点外其他所有工作 节点的资源信息和未执行任务信息， 制定所有 未执行任务和所述 任务列表的新增任务的任务分配方案的步骤， 包括： 所述任务调度器使用所述资源信 息和未执行任务信 息， 计算每个工作节点的任务执行 速度； 所述任务调度器按照所述每个工作节点的任务执行速度， 将所述未执行任务和新增任 务分别分配至每 个工作节点， 以均衡 每个工作节点的任务完成时间。 6.根据权利要求1所述的动态分配方法， 其特征在于， 所述任务调度器根据任务列表中 的任务和所有工作节点的资源信息， 将所述任务分配至工作节点的任务执行器的步骤， 包 括： 所述任务调度器按照所述任务的消耗资源量和所有工作节点的资源信 息， 分别计算每 个工作节点对每项任务的任务执 行时间； 所述任务调度器， 按照所述任务执行时间， 分别分配所述任务至所述工作节点的任务 执行器。 7.根据权利要求1所述的动态分配方法， 其特征在于， 所述任务调度器根据所述任务分 配方案， 将召回的所述未执行任务和所述任务列 表中的新增任务分配至所述工作 节点的步 骤， 包括： 所述任务调度器将所述未执行任务和所述新增任务分配至所述工作节点的任务执行 器； 所述任务执行器执行所述未执行任务和新增任务， 并实时监测任务的执行状态， 若监 测到任务的执 行状态存在异常时， 重复所述汇报异常节点的任务异常信息的步骤。 8.一种分布式任务的动态分配系统， 其特 征在于， 包括： 设置于调度器节点的任务列表和任务调度器， 以及 分别设置于多个工作节点中每个工 作节点的任务执 行器； 其中， 所述任务调度器， 用于根据任务列表中的任务和所有工作节点的资源信息， 将所述任 务分配至 工作节点的任务执 行器； 所述任务执行器， 用于实时监测所述任务的执行状态， 当所述任务的执行状态异常时 向所述任务调度器汇报异常节点的任务异常信息； 所述任务调度器， 还用于当收到所述任务异常信息时， 获取每个工作节点的资源信息 和未执行任务信息； 所述任务调度器， 还用于确定召回的未执行任务， 并根据所述资源信息和未执行任务 信息制定任务分配方案； 所述任务调度器， 还用于根据所述任务分配方案， 将召回的所述未执行任务和所述任 务列表中的新增任务分配至所述工作节点。 9.根据权利要求8所述的动态分配系统， 其特 征在于， 还 包括： 所述任务调度器， 具体还用于当收到所述任务超时信息时， 召回所述超时节点的未执 行任务； 所述任务调度器， 具体还用于根据除所述超时节点外每个工作节点的资源信 息和未执 行任务信息， 制定所述超时节点的未执行任务和所述任务列表中新增任务的任务分配方 案；权　利　要　求　书 2/3 页 3 CN 115048247 A 3