任务调度的方法、装置和系统.pdf

(19)中华人民共和国国家知识产权局(12)发明专利申请(10)申请公布号CN113760480A(43)申请公布日2021.12.07(21)申请号202010547321.9(22)申请日2020.06.16(71)申请人北京沃东天骏信息技术有限公司地址100176北京市北京经济技术开发区科创十一街18号院2号楼4层A402室申请人北京京东世纪贸易有限公司(72)发明人王鹏飞王晓烽(74)专利代理机构中原信达知识产权代理有限责任公司11219代理人张一军张效荣(51)Int.Cl.G06F9/48(2006.01)权利要求书2页说明书11页附图3页(54)发明名称任务调度的方法、装置和系统(57)摘要本发明公开了任务调度的方法、装置和系统，涉及计算机技术领域。该方法的一具体实施方式包括：在任务系统的多个任务节点执行如下任务获取逻辑：周期性地判断所述任务节点的缓存中是否存在任务标识；若是，则利用所述任务节点处理所述任务标识对应的任务；否则，采用轮询方式从共享存储端存储的多个任务标识中获取一个任务标识，以处理与所述一个任务标识对应的任务。该实施方式通过采用去中心化思想在任务系统的多个任务节点执行任务获取逻辑，能够实现轻量级、高可用的任务调度系统。CN113760480ACN113760480A权利要求书1/2页1.一种任务调度的方法，其特征在于，包括：在任务系统的多个任务节点执行如下任务获取逻辑：周期性地判断所述任务节点的缓存中是否存在任务标识；若是，则利用所述任务节点处理所述任务标识对应的任务；否则，采用轮询方式从共享存储端存储的多个任务标识中获取一个任务标识，以处理与所述一个任务标识对应的任务。2.如权利要求1所述的方法，其特征在于，利用所述任务节点处理所述任务标识对应的任务之前，还包括：确认所述任务标识有效；若所述任务标识失效，则采用轮询方式从共享存储端存储的多个任务标识中获取一个任务标识，以处理与所述一个任务标识对应的任务。3.如权利要求2所述的方法，其特征在于，确认所述任务标识有效之后，还包括：向共享存储端发送续期请求，以对所述任务节点的缓存中的所述任务标识进行续期操作。4.如权利要求1或2所述的方法，其特征在于，采用轮询方式从共享存储端存储的多个任务标识中获取一个任务标识，包括：对所述多个任务标识中的任一任务标识执行获取操作，判断是否获取成功；若是，则以成功获取的任务标识作为所述一个任务标识；否则，对所述多个任务标识中所述任一任务标识的下一个任务标识执行获取操作，判断是否获取成功；若是，则以成功获取的任务标识作为所述一个任务标识；否则，对所述多个任务标识中所述下一个任务标识的下一个任务标识执行获取操作；如此循环，直至获取成功或对所述多个任务标识中的所有任务标识都执行获取操作；判断是否获取成功；若是，则以成功获取的任务节点作为所述一个任务标识；否则，将所述任务节点标记为候选节点。5.如权利要求4所述的方法，其特征在于，所有任务标识采用键值对保存；其中，所述键值对的键包括任务标识，所述键值对的值包括任务标识对应的节点标识；所述获取操作包括：向共享存储端发送获取请求，以使共享存储端将任务标识对应的键值对的值修改为所述任务节点的节点标识；接收所述共享存储端返回的获取结果；其中，若所述获取结果为表明修改成功的第一消息，则表明获取成功；若所述获取结果为表明修改失败的第二消息，则表明获取失败。6.如权利要求5所述的方法，其特征在于，所述共享存储端通过执行Lua脚本将任务标识对应的节点标识字段的字段值修改为所述任务节点的节点标识。7.一种任务调度装置，其特征在于，部署在任务系统的多个任务节点，包括：轮询获取模块和任务接入模块；其中，所述轮询获取模块周期性地判断所述任务节点的缓存中是否存在任务标识；若是，则所述任务接入模块利用所述任务节点处理所述任务标识对应的任务；否则，所述轮询获取模块采用轮询方式从共享存储端存储的多个任务标识中获取一个任务标识，所述任务接入模块处理与所述一个任务标识对应的任务。8.一种任务调度系统，其特征在于，包括：共享存储端，以及部署在任务系统的多个任务节点的任务调度装置；其中，2CN113760480A权利要求书2/2页所述共享存储端保存所有任务的任务标识；所述任务调度装置周期性地判断所述任务节点的缓存中是否存在任务标识；若是，则利用所述任务节点处理所述任务标识对应的任务；否则，采用轮询方式从共享存储端存储的多个任务标识中获取一个任务标识，以处理与所述一个任务标识对应的任务。9.一种任务调度的电子设备，其特征在于，包括：一个或多个处理器；存储装置，用于存储一个或多个程序，当所述一个或多个程序被所述一个或多个处理器执行，使得所述一个或多个处理器实现如权利要求1-6中任一所述的方法。10.一种计算机可读介质，其上