超时任务调度系统及方法.pdf

(19)中华人民共和国国家知识产权局(12)发明专利申请(10)申请公布号CN108509264A(43)申请公布日2018.09.07(21)申请号201810295889.9(22)申请日2018.03.30(71)申请人浙江口碑网络技术有限公司地址310012浙江省杭州市西湖区西斗门路3号天堂软件园A幢11楼G座(72)发明人王晓卫(74)专利代理机构北京市浩天知识产权代理事务所(普通合伙)11276代理人宋菲陈翠(51)Int.Cl.G06F9/48(2006.01)权利要求书2页说明书10页附图3页(54)发明名称超时任务调度系统及方法(57)摘要本发明公开了一种超时任务调度系统及方法。其中，系统包括：调度引擎提供超时任务注册服务；根据注册信息或任一超时任务执行器返回的结束轮询通知消息利用预设算法将超时任务分发给对应的超时任务执行器或提供回调通知服务；超时任务执行器根据调度引擎分发的超时任务，以超时任务执行器的时间粒度轮询该超时任务，在轮询结束后向调度引擎返回结束轮询通知消息，以不固定的时间间隔轮询该超时任务，不仅保证了超时任务的时效性，能够被及时调用，还节省了系统资源，克服了按照固定时间间隔轮询时，由于时间间隔设置太大而导致超时任务超时严重的问题，以及时间间隔设置太小而导致轮询过于频繁，而导致的系统资源浪费等问题。CN108509264ACN108509264A权利要求书1/2页1.一种超时任务调度系统，包括：调度引擎以及多个超时任务执行器，其中，各个超时任务执行器按照不同的时间粒度轮询超时任务；所述调度引擎用于：提供超时任务注册服务；根据注册信息或任一超时任务执行器返回的结束轮询通知消息利用预设算法将所述超时任务分发给对应的超时任务执行器或提供回调通知服务；各个超时任务执行器用于：根据所述调度引擎分发的超时任务，以各自的时间粒度轮询该超时任务，在轮询结束后向所述调度引擎返回结束轮询通知消息。2.根据权利要求1所述的系统，其中，所述调度引擎进一步用于：根据注册信息或任一超时任务执行器返回的结束轮询通知消息，计算超时任务的超时时间与当前时间的时间间隔；根据所述时间间隔将超时任务分发给对应的超时任务执行器或提供回调通知服务。3.根据权利要求1或2所述的系统，其中，所述各个超时任务执行器进一步用于：在时间粒度对应的定时时间到达时，比较所述超时任务的超时时间与当前时间之间的时间间隔是否大于或等于超时任务执行器的时间粒度；若是，则等待定时时间到达；若否，则向所述调度引擎返回结束轮询通知消息。4.根据权利要求1-3任一项所述的系统，其中，所述系统还包括：配置中心，用于存储超时任务及超时任务执行器的轮询执行进度。5.根据权利要求1-4任一项所述的系统，其中，所述超时任务执行器选自以下任务执行器中的任意一种：每天超时任务执行器、每小时超时任务执行器、每分钟超时任务执行器、每秒超时任务执行器，且时间层级依次降低。6.一种超时任务调度方法，包括：步骤1，所述调度引擎提供超时任务注册服务；步骤2，所述调度引擎根据注册信息或任一超时任务执行器返回的结束轮询通知消息利用预设算法将所述超时任务分发给对应的超时任务执行器或提供回调通知服务；步骤3，超时任务执行器根据所述调度引擎分发的超时任务，以超时任务执行器的时间粒度轮询该超时任务，在轮询结束后向所述调度引擎返回结束轮询通知消息，并跳转执行步骤2。7.根据权利要求6所述的方法，其中，所述根据注册信息或任一超时任务执行器返回的结束轮询通知消息利用预设算法将所述超时任务分发给对应的超时任务执行器或提供回调通知服务进一步包括：根据注册信息或超时任务执行器返回的结束轮询通知消息，计算所述超时任务的超时时间与当前时间的时间间隔；根据所述时间间隔将超时任务分发给对应的超时任务执行器或提供回调通知服务。8.根据权利要求6或7所述的方法，其中，所述超时任务执行器根据调度引擎分发的超时任务，以超时任务执行器的时间粒度轮询该超时任务进一步包括：步骤4，超时任务执行器在时间粒度对应的定时时间到达时，比较所述超时任务的超时时间与当前时间之间的时间间隔是否大于或等于超时任务执行器的时间粒度；若是，则执行步骤5，等待定时时间到达，并在定时时间到达时跳转执行步骤4；2CN108509264A权利要求书2/2页若否，则向所述调度引擎返回结束轮询通知消息，并跳转执行步骤2。9.一种计算设备，包括：处理器、存储器、通信接口和通信总线，所述处理器、所述存储器和所述通信接口通过所述通信总线完成相互间的通信；所述存储器用于存放至少一可执行指令，所述可执行指令使所述处理器执行如权利要求6-8中任一项所述的超时任务调度方法对应的操作。10.一种计算机存储介质，所述存储介质中存储有至少一可执行指令，所述可执行指令使处理器执行如权利要求6-8