计算任务处理方法、装置、服务器及存储介质.pdf

(19)中华人民共和国国家知识产权局(12)发明专利申请(10)申请公布号CN111522635A(43)申请公布日2020.08.11(21)申请号201911421294.4(22)申请日2019.12.31(71)申请人支付宝实验室（新加坡）有限公司地址新加坡珊顿大道8号安盛大厦45-01号(72)发明人秦昌雷(74)专利代理机构北京众达德权知识产权代理有限公司11570代理人张桂蓉(51)Int.Cl.G06F9/48(2006.01)G06Q40/00(2012.01)权利要求书4页说明书13页附图4页(54)发明名称计算任务处理方法、装置、服务器及存储介质(57)摘要本说明书实施例提供了一种计算任务处理方法、装置、服务器及存储介质，调用与计算任务匹配的目标任务模版，目标任务模版包含对计算任务中每个计算单元的定义信息以及表征计算任务中各计算单元之间关联逻辑的关系链信息，根据目标任务模版中对计算任务中每个计算单元的定义信息以及关系链信息，对计算任务进行处理。CN111522635ACN111522635A权利要求书1/4页1.一种计算任务处理方法，包括：获取计算任务，所述计算任务包含存在关联逻辑的一个以上计算单元；通过计算引擎从预先配置的一种以上任务模版中，调用与所述计算任务匹配的目标任务模版，所述目标任务模版包含对所述计算任务中每个计算单元的定义信息以及表征所述计算任务中各计算单元之间关联逻辑的关系链信息；根据所述目标任务模版中对所述计算任务中每个计算单元的定义信息以及所述关系链信息，对所述计算任务进行处理。2.如权利要求1所述的方法，所述根据所述目标任务模版中对所述计算任务中每个计算单元的定义信息以及所述关系链信息，对所述计算任务进行处理，包括：根据所述目标任务模版中对所述计算任务中每个计算单元的定义信息以及所述关系链信息，对所述计算任务进行循环关联计算，其中，所述目标任务模版为循环关联任务模版，所述循环关联计算包含对所述计算任务中至少一个计算单元的多次计算，或者根据所述目标任务模版中对所述计算任务中每个计算单元的定义信息以及所述关系链信息，对所述计算任务进行顺序关联计算，其中，所述目标任模版为顺序关联任务模版，所述顺序关联计算包含对所述计算任务中每个计算单元的单次计算。3.如权利要求1所述的方法，所述计算任务包含N个，所述根据所述目标任务模版中对所述计算任务中每个计算单元的定义信息以及所述关系链信息，对所述计算任务进行处理，包括：将每个所述计算任务放入预先创建的线程池中，使得在所述线程池中存在N个计算任务对应的N个待执行队列，每个所述计算任务的待执行队列中包含该计算任务中未执行的计算单元，N为正整数；基于所述线程池的线程调度，从所述N个待执行队列中并发调度所述N个计算任务中每个计算任务的当前计算单元；针对所述N个计算任务中每个计算任务的当前计算单元，根据与所述计算任务匹配的目标任务模版中关系链信息以及所述当前计算单元的定义信息，对所述当前计算单元进行计算，得到每个所述当前计算单元的计算结果。4.如权利要求3所述的方法，在从所述N个待执行队列中并发调度所述N个计算任务中每个计算任务的当前计算单元的步骤中，每个计算任务的当前计算单元，通过如下步骤进行调度：从所述计算任务的待执行队列中串行调度所述计算任务的当前计算单元时，检查所述当前计算单元的前置计算单元是否计算完成，所述当前计算单元与所述前置计算单元属于同一计算任务；如果所述前置计算单元已经计算完成，则执行所述当前计算单元；否则，重新将所述当前计算单元添加至所述计算任务的待执行队列中，以等待所述线程池的下一次调度。5.如权利要求4所述的方法，所述从所述计算任务的待执行队列中串行调度所述计算任务的当前计算单元，包括：根据所述关系链信息，从所述计算任务的待执行队列中获取该计算任务的当前计算单元，以及2CN111522635A权利要求书2/4页根据所述关系链信息，确定所述当前计算单元的前置计算单元。6.如权利要求4所述的方法，所述计算任务中每个计算单元的定义信息包括：该计算单元在所述计算任务中的唯一身份标识、该计算单元的计算基准依据以及计算规则；所述计算任务的每个计算单元中记录有该计算单元的关联计算单元和循环次数，所述关系链信息基于所述计算任务的每个计算单元中记录的关联计算单元和循环次数形成。7.如权利要求6所述的方法，所述执行所述当前计算单元，包括：根据所述当前计算单元的计算基准依据确定所述当前计算单元的当前次计算基准量；根据所述当前计算单元的计算规则以及当前次计算基准量，执行对所述当前计算单元的本次计算，得到所述当前计算单元的本次计算结果；向数据使用方输出所述当前计算单元的本次计算结果，其中，所述数据使用方为所述当前计算单元或者所述当前计算单元的关联计算单元。8.如权