任务处理方法、装置、电子设备及存储介质与流程

allin2025-11-25  11


本申请属于任务调度,具体涉及一种任务处理方法、装置、电子设备及存储介质。


背景技术:

1、在很多业务场景下会出现延时任务,比如,网站新注册用户一周内未完成信息认证则发送短信提醒,每月生成一个使用情况分析发送给用户,设置20分钟后开始执行计算任务,等等。

2、虽然随着业务量以及用户的增加,延时任务的数量也在增加,但对于包含多个计算节点的云平台来说,若用户对延时任务的执行时间的精确度要求不太高,并发执行基本都可以满足其要求。但是,还存在一些延时任务,用户对其执行时间的精确度有一定的要求,比如定期执行数据同步并给出反馈信息,用户不希望存在较大的滞后。并且,根据调研,对于同样的任务内容的实时任务和延时任务,用户对于延时任务的滞后执行容忍度更低。

3、而相关技术中,服务器一般按照任务放入待执行队列的顺序依次提供服务。该技术应用在在待执行的任务数量较多且服务器资源有限的场景下,往往会出现延时任务的滞后执行且滞后执行时间较长的情况,导致用户体验差。

4、也就是说,相关技术中存在延时任务的滞后执行时间较长,导致用户体验差的问题。


技术实现思路

1、本申请实施例提供一种任务处理方法、装置、电子设备及存储介质,能够解决相关技术中存在延时任务的滞后执行时间较长,导致用户体验差的问题。

2、第一方面,本申请实施例提供了一种任务处理方法,所述方法包括:确定接收到的延时任务对应的任务类别标签和执行时间,并存储所述延时任务;所述任务类别标签用于标识与任务滞后程度相关的任务类别;基于所述任务类别标签,确定第一延时任务,并为所述第一延时任务预分配目标节点;在被预分配目标节点的第一延时任务达到其对应的执行时间的情况下,将所述被预分配目标节点的第一延时任务送入预分配的目标节点,以执行所述被预分配目标节点的第一延时任务。

3、第二方面,本申请实施例提供了一种任务处理装置,所述装置包括:任务接收模块,用于确定接收到的延时任务对应的任务类别标签和执行时间,并存储所述延时任务;所述任务类别标签用于标识与任务滞后程度相关的任务类别;预分配模块,用于基于所述任务类别标签,确定第一延时任务,并为所述第一延时任务预分配目标节点;调度模块,用于在被预分配目标节点的第一延时任务达到其对应的执行时间的情况下,将所述被预分配目标节点的第一延时任务送入预分配的目标节点,以执行所述被预分配目标节点的第一延时任务。

4、第三方面,本申请实施例提供了一种电子设备,该电子设备包括:处理器;以及被安排成存储计算机可执行指令的存储器,所述可执行指令被配置由所述处理器执行,所述可执行指令包括用于执行如第一方面所述的任务处理方法。

5、第四方面,本申请实施例提供了一种存储介质,所述存储介质用于存储计算机可执行指令,所述计算机可执行指令使得计算机执行如第一方面所述的任务处理方法。

6、第五方面,本申请实施例提供了一种芯片,所述芯片包括处理器和通信接口,所述通信接口和所述处理器耦合,所述处理器用于运行程序或指令,实现如第一方面所述的任务处理方法。

7、第六方面,本申请实施例提供了一种计算机程序产品,包括计算机程序,该计算机程序被处理器执行时实现如第一方面所述的任务处理方法。

8、在本申请实施例中,通过确定接收到的延时任务对应的任务类别标签和执行时间,并存储延时任务,任务类别标签用于标识与任务滞后程度相关的任务类别;之后,基于任务类别标签,确定第一延时任务,并为第一延时任务预分配目标节点;再在被预分配目标节点的第一延时任务达到其对应的执行时间的情况下,将被预分配目标节点的第一延时任务送入预分配的目标节点,以执行被预分配目标节点的第一延时任务。本方案通过设置任务类别标签对延时任务进行分类,按照不同的策略进行处理,提高了任务调度管理的精细化程度,管理更加灵活,其中,针对第一延时任务(基于任务类别标签确定的)执行预分配策略,为第一延时任务预分配目标节点,能够在被预分配目标节点的第一延时任务达到其对应的执行时间时,直接将其分配到预分配的目标节点,有效降低了第一延时任务到达执行时间时无可用节点的可能性,从而降低了第一延时任务被滞后执行的可能性,缩短了第一延时任务的滞后执行时间,解决了相关技术中存在延时任务的滞后执行时间较长,导致用户体验差的问题。



技术特征:

1.一种任务处理方法,其特征在于,所述方法包括:

2.根据权利要求1所述的方法,其特征在于,在所述为所述第一延时任务预分配目标节点之后,还包括:

3.根据权利要求1所述的方法,其特征在于,所述延时任务中设置了目标分配标记,用于标识是否进行预分配;所述为所述第一延时任务预分配目标节点,包括:

4.根据权利要求1或3所述的方法,其特征在于,所述存储所述延时任务,包括:

5.根据权利要求4所述的方法,其特征在于,所述基于所述等待队列对应的目标状态位,为所述等待队列中的所述目标延时任务预分配目标节点,包括:

6.根据权利要求5所述的方法,其特征在于,在存在多个所述第一节点的情况下,所述被分配的所述第一节点为空闲资源量小于预设阈值的第一节点。

7.一种任务处理装置,其特征在于,所述装置包括:

8.一种电子设备,其特征在于,包括:

9.一种存储介质,其特征在于,所述存储介质用于存储计算机可执行指令,所述计算机可执行指令使得计算机执行如权利要求1-6任一项所述的任务处理方法。

10.一种计算机程序产品,其特征在于,包括计算机程序,所述计算机程序被处理器执行时实现如权利要求1-6任一项所述的任务处理方法。


技术总结
本申请公开了一种任务处理方法、装置、电子设备及存储介质。所述方法包括:确定接收到的延时任务对应的任务类别标签和执行时间,并存储所述延时任务;所述任务类别标签用于标识与任务滞后程度相关的任务类别;基于所述任务类别标签,确定第一延时任务,并为所述第一延时任务预分配目标节点;在被预分配目标节点的第一延时任务达到其对应的执行时间的情况下,将所述被预分配目标节点的第一延时任务送入预分配的目标节点,以执行所述第一延时任务。

技术研发人员:史露强,王晓征,郭岳,潘宇虹,王淼鑫,钟储建
受保护的技术使用者:中国移动通信集团浙江有限公司
技术研发日:
技术公布日:2024/10/31
转载请注明原文地址: https://www.8miu.com/read-24890.html

最新回复(0)