(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202210665880.9 (22)申请日 2022.06.13 (71)申请人 际络科技 （上海） 有限公司 地址 202150 上海市崇明区长兴镇江南大 道1333弄11号楼001室4座 (72)发明人 王雄　陈同杰　 (74)专利代理 机构 北京路浩知识产权代理有限 公司 11002 专利代理师 张文玄 (51)Int.Cl. G06F 9/48(2006.01) G06F 9/50(2006.01) (54)发明名称 任务流并发调度方法、 系统、 电子 设备、 存储 介质 (57)摘要 本发明提供一种任务流并发调度方法、 系 统、 电子设备、 存储介质， 所述方法包括： 设置控 制所述任务流并发数的调度配置； 执行所述调度 配置， 获取对应的所述任务流， 根据所述任务流 的剩余的任务数和所述调度配置， 计算得到所述 任务流的并发数， 修改到所述任务流的属性中。 在大规模任务流场景下， 能够 有效的保护系统资 源不被用户击穿的同时， 能够根据任务流实际运 行状态， 动态的分配并发资源， 避免任务流出现 踩踏， 相互抢占系统资源， 减少任务流的排队时 长。 权利要求书1页 说明书5页 附图2页 CN 115237554 A 2022.10.25 CN 115237554 A 1.一种任务 流并发调度方法， 其特 征在于， 所述方法包括： 设置控制所述任务 流并发数的调度配置； 执行所述调度配置， 获取对应的所述任务流， 根据所述任务流的剩余的任务数和所述 调度配置， 计算得到所述任务 流的并发数， 修改到所述任务 流的属性中。 2.根据权利要求1所述的任务流并发调度方法， 其特征在于， 所述调度配置包括调度周 期， 对应的， 所述执 行所述调度配置， 包括： 按照所述调度周期， 周期性 地执行所述调度配置 。 3.根据权利要求1所述的任务流并发调度方法， 其特征在于， 所述方法包括多种所述调 度配置， 所述调度配置包括并发总数， 对应的， 所述计算得到所述任务 流的并发数， 包括： 对于所有映射同种所述调度配置的多个任务流， 限定所述多个任务流的并发数之和不 超过所述并发总数。 4.根据权利要求1所述的任务流并发调度方法， 其特征在于， 所述调度配置包括单个任 务流的最大并发数， 对应的， 所述计算得到所述任务 流的并发数， 包括： 限定所述任务 流的并发数不超过 所述最大并发数， 计算得到所述任务 流的并发数。 5.根据权利要求1所述的任务流并发调度方法， 其特征在于， 所述调度配置包括匹配规 则， 所述匹配规则用来 为符合所述匹配规则的任务 流匹配对应的所述调度配置 。 6.根据权利要求1所述的任务流并发调度方法， 其特征在于， 所述根据 所述任务流的剩 余的任务数和所述调度配置， 计算得到所述任务 流的并发数， 包括： 优先级高的所述任务流相较于优先级低的所述任务流， 优先分配并发数； 和/或， 提交 早的所述任务 流相较于提交晚的所述任务 流， 优先分配并发数。 7.一种任务 流并发调度系统， 其特 征在于， 所述系统包括： 设置模块， 所述设置模块设置控制所述任务 流并发数的调度配置； 调度模块， 所述调度模块执行所述调度配置， 获取对应的所述任务流， 根据所述任务流 的剩余的任务数和所述调度配置， 计算得到所述任务流的并发数， 修改到所述任务流的属 性中。 8.一种电子设备， 包括存储器、 处理器及存储在所述存储器上并可在所述处理器上运 行的计算机程序， 其特征在于， 所述处理器执行所述程序时实现如权利要求 1‑6中任一项 所 述任务流并发调度方法的步骤。 9.一种非暂态计算机可读存储介质， 其上存储有计算机程序， 其特征在于， 所述计算机 程序被处 理器执行时实现如权利要求1 ‑6中任一项所述任务 流并发调度方法的步骤。 10.一种计算机程序产品， 包括计算机程序， 其特征在于， 所述计算机程序被处理器执 行时实现如权利要求1 ‑6中任一项所述任务 流并发调度方法的步骤。权　利　要　求　书 1/1 页 2 CN 115237554 A 2任务流并发调度方 法、 系统、 电子 设备、 存储介质 技术领域 [0001]本发明涉及并发控制技术领域， 尤其涉及一种任务流并发调度方法、 系统、 电子设 备、 存储介质。 背景技术 [0002]系统通常存在资源容量上限， 如果用户不限制的提交任务流， 会导致任务流相互 踩踏， 抢占系统资源。 现有技术只提供了针对任务流总数的并发限制， 没有控制每个任务流 的并发控制能力。 发明内容 [0003]针对现有技术存在的问题， 本发明提供一种任务流并发调度方法、 系统、 电子设 备、 存储介质， 部分实施例能够通过全局的并发控制方法， 根据系统的资源使用量和任务流 的执行状态动态地调节任务 流的并发数， 从而 避免大批量任务 流执行时的相互踩踏。 [0004]本发明提供的一种任务 流并发调度方法， 所述方法包括： [0005]设置控制所述任务 流并发数的调度配置； [0006]执行所述调度配置， 获取对应的所述任务流， 根据所述任务流的剩余的任务数和 所述调度配置， 计算得到所述任务 流的并发数， 修改到所述任务 流的属性中。 [0007]根据本发明提供的一种任务流并发调度方法， 所述调度配置包括调度周期， 对应 的， 所述执 行所述调度配置， 包括： [0008]按照所述调度周期， 周期性 地执行所述调度配置 。 [0009]根据本发明提供的一种任务流并发调度方法， 所述方法包括多种所述调度配置， 所述调度配置包括并发总数， 对应的， 所述计算得到所述任务 流的并发数， 包括： [0010]对于所有映射同种所述调度配置的多个任务流， 限定所述多个任务流的并发数之 和不超过 所述并发总数。 [0011]根据本发明提供的一种任务流并发调度方法， 所述调度配置包括单个任务流的最 大并发数， 对应的， 所述计算得到所述任务 流的并发数， 包括： [0012]限定所述任务流的并发数不超过所述最大并发数， 计算得到所述任务流的并发 数。 [0013]根据本发明提供的一种任务流并发调度方法， 所述调度配置包括匹配规则， 所述 匹配规则用来 为符合所述匹配规则的任务 流匹配对应的所述调度配置 。 [0014]根据本发明提供的一种任务流并发调度方法， 所述根据所述任务流的剩余的任务 数和所述调度配置， 计算得到所述任务 流的并发数， 包括： [0015]优先级高的所述任务流相较于优先级低的所述任务流， 优先分配并发数； 和/或， 提交早的所述任务 流相较于提交晚的所述任务 流， 优先分配并发数。 [0016]本发明还提供的一种任务 流并发调度系统， 所述系统包括： [0017]设置模块， 所述设置模块设置控制所述任务 流并发数的调度配置；说　明　书 1/5 页 3 CN 115237554 A 3