(19)国家知识产权局 (12)发明 专利 (10)授权公告 号 (45)授权公告日 (21)申请 号 202211069686.0 (22)申请日 2022.09.02 (65)同一申请的已公布的文献号 申请公布号 CN 115145711 A (43)申请公布日 2022.10.04 (73)专利权人 北京睿企信息科技有限公司 地址 100013 北京市东城区和平里 北街6号 6号楼一层101室 专利权人 日照睿安信息科技有限公司 (72)发明人 赵洲洋　于伟　靳雯　石江枫　 王全修　 (74)专利代理 机构 北京锺维联合知识产权代理 有限公司 1 1579 专利代理师 安娜(51)Int.Cl. G06F 9/48(2006.01) G06F 9/50(2006.01) G06F 9/54(2006.01) 审查员 李铎 (54)发明名称 一种获取有向无环图任务结果的数据处理 系统 (57)摘要 本发明提供了一种获取有向无环图任务结 果的数据处理系统， 通过 获取初始任务节点对应 的初始潜在等待时间， 并将初始时间由小至大进 行排序， 为任务队列处理器分配初始任务节点， 通过更快的执行得到初始任务的结果， 从而使原 始任务节点能够更快由第二任务状态转换为第 一任务状态； 还通过指令处理器对任务处理器进 行监听并且将得到的中间任务节点结果发送至 任务节点调度器， 进而获取到目标任务列表， 任 务节点调度器为非工作状态的任务 队列处理器 分配目标任务节点， 节省了时间资源， 提高了任 务队列处 理器的工作效率。 权利要求书2页 说明书6页 附图1页 CN 115145711 B 2022.12.23 CN 115145711 B 1.一种获取有向无环图任务结果的数据处理系统， 其特征在于， 所述系统包括： 数据 库、 处理器、 任务节点调度器、 一个或者多个任务队列处理器、 存储有计算机程序的存储器， 其中， 所述数据库包括： 目标有向无环图对应的原始任务节点列表A={A1，……， Aj，……， Am}， Aj= （Aʹj， YAʹjg） ， A'j为第j个原始任务节点ID， YA ʹjg为Aʹj对应的第g个历史执行时间， j 的取值为1到m， m为目标有向无环图对应的原始任务节点的数量， g的取值为1到zj， zj为A ʹj 对应的历史执 行时间的数量， 当所述计算机程序被处 理器执行时， 实现如下步骤： S100、 基于A， 获取目标有向无环图对应的初始任务节点列表B0={B0 1，……， B0 x，…… B0 p}， B0 x=(Bʹ0 x， YBʹ0 xe)， Bʹ0 x为第x个初始任务节点ID， YB ʹ0 xe为Bʹ0 x对应的第e个历史执行时 间， x的取值为1到p， p为目标有向无环图对应的初始任务节点的数量， e的取值为1到hx， hx 为Bʹ0 x对应的历史执行时间的数量， 其中， 任一初始任务节 点为当Aj对应的任务状态为第一 任务状态时的原 始任务节点， 所述第一任务状态为当前任务节点可被执 行状态； S200、 基于B0， 获取B0对应的第一等待时长列表T0={T0 1，……， T0 x，……， T0 p}， T0 x为B0 x对 应的第一 等待时长， T0 x符合如下 条件： ； 其中， q0为B0对应的时间点处于第二任务状态的原始任务节点的数量， q0 x为B0 x对应的 全部子节点的数量， 所述第二任务状态为当前任务节点 不可被执 行状态； S300、 对T0进行排序， 获取第二等待时长列表T ʹ0={Tʹ0 1，……， Tʹ0 x，……， Tʹ0 p}， Tʹ0 x为第 x个第二等待时长， 其中， T ʹ0 x＜Tʹ0 x+1； S400、 通过任务节点调度器将前k个T ʹ0 x对应的初始任务节点分配至任务队列处理器 中， 获取任务队列 处理对应的任务执行结果， 并将所述任务执行结果对应的原始任务节点 状态变更为第三任务状态， 所述第三任务状态为当前任务节点已经被执 行完成状态； S500、 ， 获取目标任务节点集B={B1，……， Br，……， Bs}， Br为第r个时间点对应的目标任 务节点列表， r的取值范围为1到s， s为目标有向无环图对应的目标任务节点列表的数量； S600、 当r=s且A中所有原始任务节点任务状态全部处于第三任务状态时， 获取目标有 向无环图对应的目标任务结果。 2.根据权利要求1所述的系统， 其特 征在于， k=n， n 为任务队列处 理器的数量。 3.根据权利要求2所述的系统， 其特征在于， 所述系统还包括任务指令处理器， 在S500 中， 还包括如下步骤获取Br： S5011、 通过指令处理器监听任务队列处理器， 当Br‑1对应的时间点指令处理器监听到 有一个或多个任务队列处理器处于非工作状态时， 获取中间任务节点结果Sy r‑1并将Sy r‑1对 应的原始任务节点状态更新为第三任务状态， y的取值为1到h， h为中间任务节点结果的数 量， 其中， 中间任务节点结果 为任务队列处 理器执行Br‑1中目标任务节点得到的结果； S5012、 获取Sy r‑1对应的目标任务队列处理器列表Gr‑1= （G1 r‑1， ...， Gy r‑1， ...,Gq r‑1） ， Gy r‑1 为第y个目标任务队列处理器， y的取值为1到q， q为目标任务队列处理器的数量， 其中， 目标 任务队列处 理器为在 Br‑1对应的时间点处于非工作状态的任务队列处 理器；权　利　要　求　书 1/2 页 2 CN 115145711 B 2S5013、 通过指令处 理器将Sy r‑1发送至任务节点调度器； S5014、 任务节点调度器通过接收到的Sy  r‑1， 获取Br= （Br1， ...， Brd， ...， Brtr） ， Brd为Br对 应的第d个目标任务节 点， d的取值为 1到tr， tr 为目标任务节 点的数量， 其中， 所述目标任务 节点为Br对应的时间点处于第一任务状态的原 始任务节点； S5015、 基于Br， 通过任务节点调度器将Brd分配至Gy r‑1对应的目标任务队列处 理器。 4.根据权利要求1所述的系统， 其特征在于， Aj= （ASj， ZTj） ， ASj为Aj对应的上层任务节点 数量， ZTj为Aj对应的当前工作状态。 5.根据权利要求3所述的系统， 其特征在于， 所述任务指令处理器为基于钩子函数的指 令处理器。 6.根据权利要求1所述的系统， 其特征在于， 所述任务队列处理器为多线程的任务处理 器。权　利　要　求　书 2/2 页 3 CN 115145711 B 3