(19)国家知识产权局 (12)发明 专利 (10)授权公告 号 (45)授权公告日 (21)申请 号 202210547767.0 (22)申请日 2022.05.20 (65)同一申请的已公布的文献号 申请公布号 CN 114741179 A (43)申请公布日 2022.07.12 (73)专利权人 北京宇信科技 集团股份有限公司 地址 100044 北京市海淀区高梁桥 斜街42 号院1号楼5层1- 519 (72)发明人 王虓　刘明　 (74)专利代理 机构 北京卓岚智财知识产权代理 事务所 (特殊普通合伙) 11624 专利代理师 沈煜华 (51)Int.Cl. G06F 9/48(2006.01)G06F 9/50(2006.01) 审查员 狄晓斐 (54)发明名称 异步通讯的任务执行方法、 装置、 电子设备 和存储介质 (57)摘要 本发明提供异步通讯的任务执行方法、 装 置、 电子设备和存储介质， 该方法包括： 在本地时 间轮向全局时间轮同步任务时， 获取全局时间轮 的当前时间轮参数和本地时间轮的当前时间轮 参数； 根据全局时间轮的当前时间轮参数和本地 时间轮的当前时间轮参数， 判断全局时间轮中是 否存在未执行的历史任务； 当全局时间轮中不存 在未执行的历史任务时， 根据本地时间轮的当前 时间轮参数执行任务。 本发明实施例提供的异步 通讯的任务执行方法， 通过设置本地时间轮和全 局时间轮， 通过本地时间轮推动全局时间轮执行 任务， 在面对海量的交易任务时， 能够实现实时 处理， 提高了任务的执 行效率。 权利要求书3页 说明书14页 附图5页 CN 114741179 B 2022.08.30 CN 114741179 B 1.一种异步 通讯的任务执 行方法， 其特 征在于， 所述方法包括： 在本地时间轮向全局时间轮同步任务 时， 获取所述全局时间轮的当前时间轮参数和所 述本地时间轮的当前时间轮参数； 其中， 所述本地时间轮设置于本地应用中， 所述全局时间 轮设置于远程字典服 务中； 根据所述全局时间轮的当前时间轮参数和所述本地 时间轮的当前时间轮参数， 判断所 述全局时间轮中是否存在未 执行的历史任务； 当所述全局时间轮中不存在未执行的历史任务 时， 根据所述本地 时间轮的当前时间轮 参数执行所述任务。 2.根据权利要求1所述的方法， 其特征在于， 所述本地 时间轮的当前时间轮参数包括本 地时间轮的当前时间片数和当前轮数， 所述全局时间轮的当前时间轮参数包括全局时间轮 的当前时间片数和当前轮数； 所述根据 所述全局时间轮的当前时间轮参数和所述本地 时间轮的当前时间轮参数， 判 断所述全局时间轮中是否存在未 执行的历史任务， 包括： 将所述本地 时间轮的当前时间片数和当前轮数、 所述全局时间轮的当前时间片数和当 前轮数进行比较； 根据比较结果判断所述全局时间轮中是否存在未 执行的历史任务。 3.根据权利要求1所述的方法， 其特征在于， 所述根据所述全局时间轮的当前时间轮参 数和所述本地时间轮的当前时间轮参数， 判断所述全局时间轮中是否存在未执行的历史任 务， 包括： 当所述本地 时间轮的当前时间轮参数滞后于所述全局时间轮的当前时间轮参数时， 确 定所述全局时间轮中存在未 执行的历史任务； 当所述本地 时间轮的当前时间轮参数不滞后于所述全局时间轮的当前时间轮参数时， 确定所述全局时间轮中不存在未 执行的历史任务。 4.根据权利要求1所述的方法， 其特 征在于， 所述方法还 包括： 根据所述全局时间轮的当前时间轮参数计算下一次待执 行任务的时间轮参数； 根据所述下一次待执行任务的时间轮参数执行所述下一次待执行任务； 其中， 所述根 据所述下一次待执 行任务的时间轮参数 执行所述下一次待执 行任务包括： 所述全局时间轮中存储有任务列表， 基于确定的所述下一次待执行任务的时间轮参 数， 获取所述全局时间轮中存储的任务列表中的与所述下一次待 执行任务的时间轮参数对 应的任务； 执行与所述下一次待执 行任务的时间轮参数对应的任务。 5.根据权利要求4所述的方法， 其特征在于， 在获取所述全局时间轮中存储的任务列表 中的与所述下一次待执 行任务的时间轮参数对应的任务之后， 所述方法还 包括： 判断所述下一次待执 行任务是否需要重复执 行； 当需要重复执行时， 计算该需要重复执行的任务每次执行时的时间轮参数， 并存储在 所述全局时间轮中。 6.根据权利要求4所述的方法， 其特征在于， 所述根据所述全局时间轮的当前时间轮参 数计算下一次待执 行任务的时间轮参数， 包括： 确定下一次待执 行任务的预设时间和所述全局时间轮中每 个时间片占用的时间；权　利　要　求　书 1/3 页 2 CN 114741179 B 2根据所述全局时间轮中包括的当前时间片数、 预设时间和所述全局时间轮中每个时间 片占用的时间， 得到衍 生变量； 获取所述全局时间轮的最大片数值； 根据所述衍生变量和所述全局时间轮的最大片数值， 计算下一 次执行待执行任务的时 间片数和轮数。 7.根据权利要求1所述的方法， 其特征在于， 当所述全局时间轮中不存在未执行的历史 任务时， 所述方法还 包括： 针对所述全局时间轮， 创建N个时间片， 每个时间片的片数标记为从1到N， 其中， N为大 于1的整数； 按照从1到N的顺序遍历各个时间片， 并获取 所述各个时间片的时间片数和轮数； 针对任一时间片， 根据该时间片的时间片数和轮数更新所述本地时间轮的时间轮参 数。 8.根据权利要求1所述的方法， 其特征在于， 在所述根据 所述本地 时间轮的当前时间轮 参数执行所述任务之后， 所述方法还 包括： 所述本地时间轮向所述全局时间轮同步任务， 获取所述全局时间轮的当前时间轮参 数； 当所述本地 时间轮的当前时间轮参数超前于所述全局时间轮的当前时间轮参数时， 将 所述全局时间轮的当前时间轮参数 更新为所述本地时间轮的当前时间轮参数。 9.根据权利要求4所述的方法， 其特征在于， 在所述任务列表中通过Lua脚本方式获取 所述任务； 所述全局时间轮通过L ist数据结构存 储有任务列表。 10.一种异步 通讯的任务执 行装置， 其特 征在于， 所述装置包括： 获取模块， 用于在本地时间轮向全局时间轮同步任务时， 获取所述全局时间轮的当前 时间轮参数和所述本地时间轮的当前时间轮参数； 其中， 所述本地时间轮设置于本地应用 中， 所述全局时间轮设置 于远程字典服 务中； 判断模块， 用于根据 所述全局时间轮的当前时间轮参数和所述本地 时间轮的当前时间 轮参数， 判断所述全局时间轮中是否存在未 执行的历史任务； 执行模块， 用于当所述全局时间轮中不存在未执行的历史任务时， 根据所述本地时间 轮的当前时间轮参数 执行所述任务。 11.根据权利要求10所述的装置， 其特 征在于， 所述判断模块， 用于： 将所述本地 时间轮的当前时间片数和当前轮数、 所述全局时间轮的当前时间片数和当 前轮数进 行比较； 根据比较结果判断所述全局时间轮中是否存在未执行的历史任务； 其中， 所述本地时间轮的当前时间轮参数包括本地时间轮的当前时间片数和当前轮数， 所述全局 时间轮的当前时间轮参数包括全局时间轮的当前时间片数和当前轮数。 12.根据权利要求10所述的装置， 其特 征在于， 所述判断模块， 用于： 当所述本地 时间轮的当前时间轮参数滞后于所述全局时间轮的当前时间轮参数时， 确 定所述全局时间轮中存在未 执行的历史任务； 当所述本地 时间轮的当前时间轮参数不滞后于所述全局时间轮的当前时间轮参数时， 确定所述全局时间轮中不存在未 执行的历史任务。 13.根据权利要求10所述的装置， 其特征在于， 所述装置还包括： 计算模块， 用于根据 所权　利　要　求　书 2/3 页 3 CN 114741179 B 3