预览加载中,请您耐心等待几秒...
1/10
2/10
3/10
4/10
5/10
6/10
7/10
8/10
9/10
10/10

亲,该文档总共15页,到这已经超出免费预览范围,如果喜欢就直接下载吧~

如果您无法下载资料,请参考说明:

1、部分资料下载需要金币,请确保您的账户上有足够的金币

2、已购买过的文档,再次下载不重复扣费

3、资料包下载后请先用软件解压,在使用对应软件打开

(19)中华人民共和国国家知识产权局(12)发明专利申请(10)申请公布号CN112685166A(43)申请公布日2021.04.20(21)申请号202110263725.X(22)申请日2021.03.11(71)申请人北京首都在线科技股份有限公司地址100102北京市朝阳区紫月路18号院9号楼(72)发明人许涛(74)专利代理机构北京市铸成律师事务所11313代理人王姗姗金爱静(51)Int.Cl.G06F9/48(2006.01)权利要求书2页说明书8页附图4页(54)发明名称分布式任务调度的方法、装置、设备和存储介质(57)摘要本申请提出一种分布式任务调度的方法、装置、设备和存储介质,涉及任务调度领域。该方法包括:从当前任务流中获取当前任务,若所述当前任务在执行之前发生异常,则将所述当前任务设置为熔断状态,禁止所述当前任务被调用。本申请杜绝了异常任务仍被频繁调用的情况发生,避免了系统资源的浪费,提高了任务的执行效率,能够适配云计算平台中复杂多变的任务调用。CN112685166ACN112685166A权利要求书1/2页1.一种分布式任务调度的方法,其特征在于,包括:从当前任务流中获取当前任务;若所述当前任务在执行之前发生异常,则将所述当前任务设置为熔断状态,禁止所述当前任务被调用。2.根据权利要求1所述的方法,其特征在于,所述方法还包括:若所述当前任务未发生异常,则执行所述当前任务,在所述当前任务无法执行的情况下,将所述当前任务设置为熔断状态。3.根据权利要求2所述的方法,其特征在于,所述方法还包括:执行所述当前任务之后,若所述当前任务超时未执行完成或执行失败的次数达到指定次数,则确定所述当前任务无法执行。4.根据权利要求1或2所述的方法,其特征在于,所述方法还包括:将所述当前任务设置为熔断状态之后,定时再次执行所述当前任务,若执行成功,则解除所述当前任务的熔断状态,允许所述当前任务被调用。5.根据权利要求1或2所述的方法,其特征在于,将所述当前任务设置为熔断状态,包括:将所述当前任务从任务队列中删除并加入到熔断队列中。6.根据权利要求1所述的方法,其特征在于,所述方法还包括:在所述当前任务流执行完成后,若所述当前任务流有订阅者,则将所述当前任务流的执行结果发送给所述订阅者。7.根据权利要求1所述的方法,其特征在于,所述方法还包括:在所述当前任务流执行完成后,若所述当前任务流有回调请求,则执行所述当前任务流的回调操作。8.根据权利要求1所述的方法,其特征在于,所述方法还包括:预先根据业务需求生成串行任务流或并行任务流,所述串行任务流包括多个阶段的任务且同步执行,所述并行任务流包括多个阶段的任务且异步执行,在上一个阶段的任务执行完成后再执行本阶段的任务。9.根据权利要求1所述的方法,其特征在于,所述方法还包括:预先根据业务需求生成任务流,所述任务流包括一个或多个任务,其中每个任务对应一个实现相应业务逻辑的服务。10.根据权利要求1所述的方法,其特征在于,所述方法还包括:在所述当前任务流的执行过程中,若收到针对所述当前任务流中的一个或多个任务的单独调用请求,则单独调用所述一个或多个任务。11.一种分布式任务调度的装置,其特征在于,包括:获取模块,用于从当前任务流中获取当前任务;处理模块,用于若所述当前任务在执行之前发生异常,则将所述当前任务设置为熔断状态,禁止所述当前任务被调用。12.根据权利要求11所述的装置,其特征在于,所述处理模块还用于:若所述当前任务未发生异常,则执行所述当前任务,在所述当前任务无法执行的情况下,将所述当前任务设置为熔断状态。2CN112685166A权利要求书2/2页13.根据权利要求12所述的装置,其特征在于,所述处理模块还用于:执行所述当前任务之后,若所述当前任务超时未执行完成或执行失败的次数达到指定次数,则确定所述当前任务无法执行。14.根据权利要求11或12所述的装置,其特征在于,所述处理模块还用于:将所述当前任务设置为熔断状态之后,定时再次执行所述当前任务,若执行成功,则解除所述当前任务的熔断状态,允许所述当前任务被调用。15.根据权利要求11或12所述的装置,其特征在于,所述处理模块将所述当前任务设置为熔断状态时具体用于:将所述当前任务从任务队列中删除并加入到熔断队列中。16.根据权利要求11所述的装置,其特征在于,所述装置还包括:订阅模块,用于在所述当前任务流执行完成后,若所述当前任务流有订阅者,则将所述当前任务流的执行结果发送给所述订阅者。17.根据权利要求11所述的装置,其特征在于,所述装置还包括:回调模块,用于在所述当前任务流执行完成后,若所述当前任务流有回调请求,则执行所述当前任务流的回调操作。18.根据权利要求11所述的装置,其特征在于,所述装置还包括:第一生成模块,