(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202211016488.8 (22)申请日 2022.08.24 (71)申请人 重庆富民银行股份有限公司 地址 401121 重庆市渝北区财富 东路2号涉 外商务区一期B1栋 (72)发明人 李攀锋　 (74)专利代理 机构 重庆强大凯创专利代理事务 所(普通合伙) 50217 专利代理师 刘嘉 (51)Int.Cl. G06F 9/50(2006.01) (54)发明名称 一种基于JAVA线程的任务并行执行方法及 系统 (57)摘要 本发明涉及计算机软件开发技术领域， 具体 涉及一种基于JAVA线程的任务并行执行方法及 系统， 所述系统包括： 任务处理模块： 用于获取主 任务并将主任务分解为若干子任务， 并分析若干 子任务彼此间的依赖关系； 链路处理模块： 用于 根据依赖关系分析若干子任务在并行执行器中 的多条执行链路； 配置模块： 用于配置并行执行 器， 以及在并行执行器中配置各个子任务的任务 执行体； 任务处理模块： 用于根据多条执行链路 分析若干子任务的并行执行逻辑， 并使并行执行 器根据并行执行逻辑并行执行对应的子任务， 直 至所有子任务完成， 最后输出最终执行结果。 本 发明解决了目前基于JAVA环境开发并行执行任 务程序时， 缺少有效手段提高开发效率和开发过 程中复杂不统一的问题。 权利要求书2页 说明书7页 附图2页 CN 115292049 A 2022.11.04 CN 115292049 A 1.一种基于JA VA线程的任务并行 执行系统， 其特 征在于， 包括： 任务处理模块： 用于获取主任务并将主任务分解为若干子任务， 或直接获取划分好的 若干子任务， 并分析若干 子任务彼此间的依赖关系； 链路处理模块： 用于根据依赖关系分析若干 子任务在并行 执行器中的多条 执行链路； 配置模块： 用于配置并行执行器， 以及在并行执行器 中配置各个子任务的任务执行体， 所述任务执 行体的配置包括任务执 行代码模板的任务基 类选择和初始修改参数； 任务执行模块： 用于根据多条执行链路分析若干子任务的并行执行逻辑， 并使并行执 行器的任务执行体根据并行执行逻辑并行执行对应的子任务， 得到子任务的执行结果， 并 将一个或多个子任务的执行结果根据所属执行链路组装且传入到对应执行链路下游的子 任务中作为输入参数， 依 次执行各执行链路中的子任务直至所有子任务完成， 最后输出最 终执行结果。 2.根据权利要求1所述的一种基于JAVA线程的任务并行执行系统， 其特征在于： 还包 括： 异常处理模块： 用于在子任务遇到异常后， 判断并行执行器中设置的异常处理机制是 默认异常机制还是异常忽略机制， 若 是默认异常机制， 立即停止整个任务的执行； 若 是异常 忽略机制， 继续执行子任务， 并定义当前存在异常的子任务的执行结果为空值并传给执行 链路的下个子任务中， 且记录异常和对应的子任务。 3.根据权利要求2所述的一种基于JAVA线程的任务并行执行系统， 其特征在于： 所述链 路处理模块中， 还用于 分析执行链路中是否存在循环执行链路， 若不存在， 则启动默认异常 机制。 4.根据权利要求3所述的一种基于JAVA线程的任务并行执行系统， 其特征在于： 所述配 置模块具体包括以下子模块： 线程池资源管理子模块： 用于为并行 执行器设置独立的系统线程池； 运行模式管理子模块： 用于为并行执行器设置运行模式， 所述运行模式包括内存运行 模式和数据库运行模式； 选择内存模式时， 任务执行开始到结束任务数据都放在内存中； 选 择数据库模式时， 任务执 行开始到结束任务数据都放在数据库中。 5.根据权利要求4所述的一种基于JAVA线程的任务并行执行系统， 其特征在于： 还包 括： 断点重连模块： 用于在任务中途暂停时， 判断并行执行器设置运行模式是否在数据库 模式下， 若是， 则从数据会中调取当前子任务参数以及上一子任务的执行结果并进行任务 重试； 还用于获取当前子任务的重试参数并根据重试参数判断执行过的子任务是否需要重 新执行， 若不需要重新执 行， 则直接执 行后续未 执行的子任务， 直到最终任务执 行完成。 6.一种基于JA VA线程的任务并行 执行方法， 其特 征在于， 包括以下步骤： 任务处理步骤： 获取主任务并将主任务分解为若干子任务， 或直接获取划分好的若干 子任务， 并分析若干 子任务彼此间的依赖关系； 链路处理步骤： 根据依赖关系分析若干 子任务在并行 执行器中的多条 执行链路； 配置步骤： 配置并行执行器， 以及在并行执行器 中配置各个子任务的任务执行体， 所述 任务执行体的配置包括任务执 行代码模板的任务基 类选择和初始修改参数； 任务执行步骤： 根据多条执行链路分析若干子任务的并行执行逻辑， 并使并行执行器权　利　要　求　书 1/2 页 2 CN 115292049 A 2的任务执行体根据并行执行逻辑并行执行对应的子任务， 得到子任务的执行结果， 并将一 个或多个子任务的执行结果根据所属执行链路组装且传入到对应执行链路下游的子任务 中作为输入参数， 依 次执行各执行链路中的子任务直至所有子任务完成， 最后输出最终执 行结果。 7.根据权利要求6所述的一种基于JAVA线程的任务并行执行方法， 其特征在于： 还包 括： 异常处理步骤： 在子任务遇到异常后， 判断并行执行器中设置的异常处理机制是默认 异常机制还是异常忽略机制， 若 是默认异常机制， 立即停止整个任务的执行； 若 是异常忽略 机制， 继续执行子任务， 并定义当前存在异常的子任务的执行结果为空值并传给执行链路 的下个子任务中， 且记录异常和对应的子任务。 8.根据权利要求7所述的一种基于JAVA线程的任务并行执行方法， 其特征在于： 所述链 路处理步骤中， 还用于 分析执行链路中是否存在循环执行链路， 若不存在， 则启动默认异常 机制。 9.根据权利要求8所述的一种基于JAVA线程的任务并行执行方法， 其特征在于： 所述配 置步骤具体包括以下子步骤： 线程池资源管理子步骤： 为并行 执行器设置独立的系统线程池； 运行模式管理子步骤： 为并行执行器设置运行模式， 所述运行模式包括内存运行模式 和数据库运行模式； 选择内存模式时， 任务执行开始到结束任务数据都放在内存中； 选择数 据库模式时， 任务执 行开始到结束任务数据都放在数据库中。 10.根据权利要求9所述的一种基于JAVA线程的任务并行执行方法， 其特征在于： 还包 括： 断点重连步骤： 在任务中途暂停时， 判断并行执行器设置运行模式是否在数据库模式 下， 若是， 则从数据会中调取当前子任务参数以及上一子任务的执行结果并进 行任务重试； 还用于获取当前子任务的重试参数并根据重试参数判断执行过 的子任务是否需要重新执 行， 若不需要重新执 行， 则直接执 行后续未 执行的子任务， 直到最终任务执 行完成。权　利　要　求　书 2/2 页 3 CN 115292049 A 3