(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202210679829.3 (22)申请日 2022.06.15 (71)申请人 南京苏宁加电子商务有限公司 地址 210000 江苏省南京市玄武区苏宁大 道1-9号 (72)发明人 丁佐兵　陈晓松　李杨　李金国　 (74)专利代理 机构 北京市万慧达律师事务所 11111 专利代理师 黄玉东 (51)Int.Cl. G06F 9/48(2006.01) G06F 9/50(2006.01) (54)发明名称 分布式任务调度方法、 装置、 设备和存储介 质 (57)摘要 本申请涉及一种分布式任务调度方法、 装 置、 设备和存储介质。 主要 技术方案包括： 轮询获 取对应线程的有序元素集中的首个元素； 获取当 前时间， 若首个元素的最早任务执行时间大于当 前时间， 将首个元素重新加入到有序元素集中重 新排序待下次调度获取， 并继续执行从有序元素 集中获取首个元素的步骤； 若首个元素的最早任 务执行时间小于等于当前时间， 则从任务池获取 对应于首个元素的任务ID的具体任务信息； 若获 取到具体任务信息， 则将首个元素添加到对应准 备执行任务队列中； 并将添加于准备执行任务队 列的首个元素从有序元素集中删除， 继续执行从 有序元素集中获取首个元素的步骤。 本申请能够 达到无需遍历所有待处理任务， 大大提高了检测 效率的效果。 权利要求书2页 说明书11页 附图4页 CN 115080208 A 2022.09.20 CN 115080208 A 1.一种分布式任务调度方法， 其特 征在于， 该 方法包括： 轮询获取对应线程的有序元素集中的首个元素； 其中， 所述首个元素为有序元素集中 时间排序最前的元 素， 所述首个元 素包括最早任务执 行时间和任务 ID； 获取当前时间， 若所述首个元素的最早任务执行时间大于所述当前时间， 将所述首个 元素重新加入到有序元素集中重新排序待 下次调度获取， 并继续执行从有序元素集中获取 首个元素的步骤； 若所述首个元素的最早任务执行时间小于等于当前时间， 则从任务池获取对应于所述 首个元素的任务 ID的具体任务信息； 若获取到所述具体任务信息， 则将所述首个元素添加到对应准备执行任务队列中； 并 将添加于准备执行任务队列的首个元素从有序元素集中删除， 继续执行从有序元素集中获 取首个元素的步骤。 2.根据权利要求1所述的方法， 其特征在于， 所述若获取到所述具体任务信息， 则将所 述首个元素添加到对应准备执行任务队列中； 并将添加于准备执行任务队列的首个元素从 有序元素集中删除， 继续执 行从有序元 素集中获取 首个元素的步骤， 包括： 查看对应于所述首个元素的具体任务信 息中的任务执行时间， 若所述任务执行时间大 于所述当前时间， 则将所述首个元素重新加入到有序元素集中重新排序待下次调度获取， 且继续执 行从有序元 素集中获取 首个元素的步骤； 如果任务执行时间小于等于当前时间， 则将所述首个元素添加到对应准备执行任务队 列中， 并将添加于准备执行任务队列的首个元素从有序元素集中删除， 且继续执行从有序 元素集中获取 首个元素的步骤。 3.根据权利要求1 ‑2任意一项所述的方法， 其特征在于， 所述若获取到所述具体任务信 息， 则将所述首个元 素添加到对应准备 执行任务队列中， 还 包括： 若未获取到具体任务信息， 则将所述首个元素从有序元素集中删除， 且继续执行从有 序元素集中获取 首个元素的步骤。 4.根据权利要求1所述的方法， 其特征在于， 所述轮询获取对应线程的有序元素集中的 首个元素的步骤之前， 包括： 从任务队列中获取多个待处 理任务， 将多个所述待处 理任务信息添加到任务池中； 对多个所述待处理任务分别进行包装处理得到对应的元素， 将所述各元素添加到有序 元素集中进行排序整合处 理， 以待多线程调度器调度。 5.根据权利要求1所述的方法， 其特 征在于， 所述方法还 包括： 从准备执行任务队列中获取待处 理任务； 其中， 所述待处 理任务和所述元 素相对应； 若在预设时间内获取到所述待处理任务， 则从所述任务池获取对应于所述待处理任务 的任务ID的具体任务信息； 若在预设时间内未获取到待处理任务， 则 重新执行从所述准备执行任务队列中获取待 处理任务的步骤。 6.根据权利要求5所述的方法， 其特征在于， 若在预设时间内获取到待处理任务， 则从 任务池获取对应于所述待处 理任务的任务 ID的具体任务信息， 包括： 若从任务池获取到对应于所述待处理任务的任务ID的具体任务信 息， 则将所述待处理 任务发送至业 务处理系统以指示所述 业务处理系统对所述待处 理任务进行处 理；权　利　要　求　书 1/2 页 2 CN 115080208 A 2若未从任务池获取到对应于所述待处理任务的任务ID的具体任务信 息， 则将所述待处 理任务从准备执行任务队列中删除， 并重新执行从所述准备执行任务队列中获取待处理任 务的步骤。 7.根据权利要求6所述的方法， 其特征在于， 所述若从任务池获取到对应于所述待处理 任务的任务ID的具体任务信息， 则将所述待处理任务 发送至业务处理系统以指示所述业务 处理系统对所述待处 理任务进行处 理的步骤之后， 包括： 获取业务处理系统的处理结果， 若为处理成功， 则将所述待处理任务从准备执行任务 队列中删除， 将对应的具体任务信息从所述任务池中删除； 若为处理失败， 则重新计算所述待处理任务的任务执行时间， 并将所述待处理任务进 行重新包装处理得到新元素， 再将所述新元素重新加入到有序元素集中进 行重新排序以待 下次获取。 8.一种分布式任务调度装置， 其特 征在于， 该装置包括： 获取模块， 用于轮询获取对应线程的有序 元素集中的首个元素； 其中， 所述首个元素为 有序元素集中时间排序最前的元 素， 所述首个元 素包括最早任务执 行时间和任务 ID； 获取比较模块， 用于获取当前时间， 若所述首个元素的最早任务执行时间大于所述当 前时间， 将所述首个元素重新加入到有序元素集中重新排序待下次调度获取， 并继续执行 从有序元 素集中获取 首个元素的步骤； 比较获取模块， 用于若所述首个元素的最早任务执行时间小于等于当前时间， 则从任 务池获取对应于所述首个元 素的任务 ID的具体任务信息； 获取处理模块， 用于若获取到所述具体任务信息， 则将所述首个元素添加到对应准备 执行任务队列中； 并将添加于准备执行任务队列的首个元素从有序元素集中删除， 继续执 行从有序元 素集中获取 首个元素的步骤。 9.一种计算机设备， 包括： 至少一个处 理器； 以及 与所述至少一个处 理器通信连接的存 储器； 其中， 所述存储器存储有可被所述至少一个处理器执行的计算机指令， 所述计算机指令被所 述至少一个处理器执行， 以使所述至少一个处理器能够执行权利要求1 ‑7中任一项所述的 方法。 10.一种计算机可读存储介质， 其上存储有计算机指令， 其特征在于， 所述计算机指令 用于使计算机执 行权利要求1至7中任一项所述的方法。权　利　要　求　书 2/2 页 3 CN 115080208 A 3