公开(公告)号：CN116541164A

公开(公告)日：2023-08-04

申请号：CN202310414122.4

申请日：2023-04-18

Applicant: 北京明朝万达科技股份有限公司

Inventor： 路晓梦 ,  王世彪 ,  王志海 ,  喻波 ,  安鹏

IPC: G06F9/50 ,  G06F16/182

Abstract: 本发明实施例提供了一种异步任务的处理方法、装置、电子设备以及存储介质，方法包括：客户端获取针对目标服务的线程信息和可用内存信息；并在线程信息表征为存在可用线程且可用内存信息大于预设的内存指标信息时，从分布式数据库中根据一个异步任务的优先级获取目标异步任务，并执行目标异步任务，进而在目标异步任务执行失败时，调整目标异步任务的优先级，并根据调整后的优先级，更新用于触发执行目标异步任务的内存指标信息。通过本发明实施例，实现了在异步任务失败后动态调整任务优先级以及内存指标信息，从而增加异步任务系统的稳定性和可用性。

公开(公告)号：CN116055563B

公开(公告)日：2024-10-29

申请号：CN202211467908.4

申请日：2022-11-22

Applicant: 北京明朝万达科技股份有限公司

Inventor： 路晓梦 ,  王世彪 ,  王志海 ,  喻波 ,  董晓斌

IPC: H04L67/60 ,  G06F9/48 ,  G06F16/28 ,  H04L67/1042

Abstract: 本发明公开了一种基于Raft协议的任务调度方法、系统、电子设备和介质，所述方法包括如下步骤：所述调度服务根据Raft协议从多个节点中选举出leader节点，所述leader节点用于将任务分发给执行器，所述leader节点与数据库双主架构的其中一台服务器保持长连接；每个执行器通过调度服务获取leader节点的信息，并向leader节点发送该执行器的注册信息，所述leader节点根据注册信息在数据库中插入一条执行器信息，然后该执行器与follower节点保持心跳，所述follower节点根据心跳在数据库中更新该执行器对应的心跳时间；所述leader节点获取待执行任务，并根据数据库中的执行器信息将待执行任务分发给相应的执行器；所述执行器接收到待执行任务后，执行待执行任务并向leader节点发送任务接收响应。

公开(公告)号：CN116055563A

公开(公告)日：2023-05-02

申请号：CN202211467908.4

申请日：2022-11-22

Applicant: 北京明朝万达科技股份有限公司

Inventor： 路晓梦 ,  王世彪 ,  王志海 ,  喻波 ,  董晓斌

IPC: H04L67/60 ,  G06F9/48 ,  G06F16/28 ,  H04L67/1042

Abstract: 本发明公开了一种基于Raft协议的任务调度方法、系统、电子设备和介质，所述方法包括如下步骤：所述调度服务根据Raft协议从多个节点中选举出leader节点，所述leader节点用于将任务分发给执行器，所述leader节点与数据库双主架构的其中一台服务器保持长连接；每个执行器通过调度服务获取leader节点的信息，并向leader节点发送该执行器的注册信息，所述leader节点根据注册信息在数据库中插入一条执行器信息，然后该执行器与follower节点保持心跳，所述follower节点根据心跳在数据库中更新该执行器对应的心跳时间；所述leader节点获取待执行任务，并根据数据库中的执行器信息将待执行任务分发给相应的执行器；所述执行器接收到待执行任务后，执行待执行任务并向leader节点发送任务接收响应。