(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202210663977.6 (22)申请日 2022.06.14 (71)申请人 恒生电子股份有限公司 地址 310053 浙江省杭州市滨江区江南大 道3588号恒生大厦1 1楼 (72)发明人 李平　秦元　楼浩盛　王凯　罗成　 (74)专利代理 机构 北京超凡宏宇专利代理事务 所(特殊普通 合伙) 11463 专利代理师 张萌 (51)Int.Cl. G06F 9/48(2006.01) G06F 9/50(2006.01) G06F 9/54(2006.01) (54)发明名称 任务处理方法、 工作节点设备、 主节点设备 及存储介质 (57)摘要 本申请提供一种任务处理方法、 工作节 点设 备、 主节点设备及存储介质， 涉及计算机技术领 域。 该任务处理方法包括： 首先， 从所述工作节点 对应的执行线程池中确定空闲线程的空闲线程 数； 并根据所述空闲线程数， 确定待执行的任务 数量。 接着， 向主节点发送任务请求消息， 并接收 所述主节 点返回的任务请求结果， 根据所述目标 任务中各任务的信息， 采用所述任务数量个的所 述空闲线程 分别执行所述各任务。 实现了基于 拉 模式的任务处理方法， 即工作节 点可以实时根据 自己的空闲线程数 （即处理任务的能力） 向主节 点请求相应的任务数量个任务来执行， 从而避免 任务在工作节点中排 队而导致优先级高的任务 得不到及时执 行。 权利要求书2页 说明书15页 附图6页 CN 114756356 A 2022.07.15 CN 114756356 A 1.一种任务处理方法， 其特征在于， 所述方法应用于任务调度系统中的任一工作节点， 所述方法包括： 从所述工作节点对应的执 行线程池中确定空 闲线程的空 闲线程数； 根据所述空 闲线程数， 确定待执 行的任务数量； 向主节点发送任务请求消息， 所述任务请求消息包括所述任务数量； 所述任务请求消 息用于使得 所述主节点从预设的任务优先级列表中选择 所述任务数量个的目标任务； 接收所述主节点返回的任务请求结果， 所述任务请求结果包括： 所述目标任务的信息； 根据所述目标任务中各任务的信 息， 采用所述任务数量个的所述空闲线程分别执行所 述各任务； 所述根据 所述目标任务中各任务的信 息， 采用所述任务数量个的所述空闲线程分别执 行所述各任务， 包括： 根据所述任务请求结果， 对所述目标任务中的各任务进行封装； 提交封装后的所述各任务到所述执行线程池中的所述空闲线程， 以采用所述任务数量 个的所述空 闲线程分别执 行所述各任务。 2.如权利要求1所述的方法， 其特征在于， 所述从所述工作节点对应的执行线程池中确 定空闲线程的空 闲线程数， 包括： 采用预先开启的轮询线程， 扫描所述执行线程池， 得到所述执行线程池中的活跃线程 数量； 根据所述执 行线程池中的总线程数量和所述活跃线程数量， 计算所述空 闲线程数。 3.如权利要求2所述的方法， 其特 征在于， 所述方法还 包括： 若所述活跃线程数量等于所述总线程数量， 则确定所述执行线程池中不存在空闲线 程， 并休眠第一预设时长 。 4.如权利要求1所述的方法， 其特 征在于， 所述方法还 包括： 若在发送所述任务请求消息之后的第 二预设时长 内， 未接收到所述主节点返回的任务 请求结果， 则重新发送所述任务请求消息 。 5.如权利要求1所述的方法， 其特 征在于， 所述方法还 包括： 在所述各任务提交至所述执行线程池中的所述空闲线程之后， 向所述主节点发送任务 执行应答， 所述任务执 行应答用于使得 所述主节点更新所述任务优先级列表。 6.如权利要求2所述的方法， 其特 征在于， 所述方法还 包括: 在所述各任务提交至所述执行线程池中的所述空闲线程之后， 控制所述轮询线程休眠 第三预设时长后， 重新确定所述空 闲线程数。 7.一种任务处理方法， 其特征在于， 所述方法应用于任务调度系统中的任一主节点， 所 述方法包括： 接收工作节点发送的任务请求消息， 所述任务请求消息包括： 待执行的任务数量， 所述 任务数量为所述工作节点从所述工作节点对应的执行线程池中确定空闲线程的空闲线程 数， 并根据所述空 闲线程数 所确定的任务数量； 从预设的任务优先级列表中选择 所述任务数量个的目标任务； 向所述工作节点返回任务请求结果， 所述任务请求结果包括： 所述目标任务的信 息， 所 述任务请求结果用于使得所述工作 节点根据所述目标任务中各任务的信息， 采用所述任务权　利　要　求　书 1/2 页 2 CN 114756356 A 2数量个的所述空闲线程分别执行所述各任务； 其中， 所述任务请求结果用于使得所述工作 节点对所述目标任务中的各任务进行封装， 并提交封装后的所述各任务到执行线程池的空 闲线程中以分别执 行所述各任务。 8.如权利要求7 所述的方法， 其特 征在于， 所述任务请求消息中还 包括： 任务分组标识； 所述从预设的任务优先级列表中选择 所述任务数量个的目标任务， 包括： 从所述任务优先级列表中所述任务分组标识对应的任务中， 选择所述任务数量个的所 述目标任务。 9.如权利要求7 所述的方法， 其特 征在于， 所述方法还 包括： 接收所述工作节点发送的任务执 行应答； 根据所述任务执 行应答， 更新所述任务优先级列表。 10.一种工作节点设备， 其特征在于， 包括： 处理器、 存储介质和总线， 所述存储介质存 储有所述处理器可执行 的程序指令， 当工作节点设备运行时， 所述处理器与所述存储介质 之间通过总线通信， 所述处理器执行所述程序指令， 以执行时执行如权利要求1至6任一所 述的任务处 理方法的步骤。 11.一种主节点设备， 其特征在于， 包括： 处理器、 存储介质和总线， 所述存储介质存储 有所述处理器可执行 的程序指令， 当主节点设备运行时， 所述处理器与所述存储介质之间 通过总线通信， 所述处理器执行所述程序指令， 以执行时执行如权利要求7至9任一所述的 任务处理方法的步骤。 12.一种计算机可读存储介质， 其特征在于， 所述存储介质上存储有计算机程序， 所述 计算机程序被处理器运行时执行如权利要求1至6任一所述的任务处理方法的步骤或执行 如权利要求7至9任一所述的任务处 理方法的步骤。权　利　要　求　书 2/2 页 3 CN 114756356 A 3