[發明專利]一種分布式異步任務調度方法及電子設備

在審

• 申請號: 201910903256.6
• 申請日: 2019-09-24
• 公開（公告）號: CN110851245A
• 公開（公告）日: 2020-02-28
• 發明（設計）人: 林維鎮
• 申請（專利權）人: 廈門網宿有限公司
• 主分類號: G06F9/48
• 分類號: G06F9/48
• 代理公司: 上海晨皓知識產權代理事務所(普通合伙) 31260
• 代理人: 成麗杰

1.一種分布式異步任務調度方法，其特征在于，包括：

從用于給各個進程進行任務配置的配置中心獲取任務信息，其中，所述任務信息至少包括給當前進程配置的目標任務隊列，所述目標任務隊列中存儲有待執行的異步任務；

從所述目標任務隊列中獲取批量的目標任務；

調取所述目標任務并執行。

2.根據權利要求1所述的分布式異步任務調度方法，其特征在于，

所述配置中心還用于給各個任務隊列配置任務并發規則，所述任務信息還包括所述目標任務隊列對應的任務并發規則；

所述從所述目標任務隊列中獲取批量的目標任務具體為：

根據所述目標任務隊列對應的任務并發規則從所述目標任務隊列中獲取批量的目標任務。

3.根據權利要求2所述的分布式異步任務調度方法，其特征在于，

所述配置中心通過任務配置表和任務隊列管理表給各個任務隊列配置任務并發規則，并且所述任務配置表還用于記錄為各個進程配置的任務類型，所述任務隊列管理表還用于記錄各個任務類型分別對應的任務隊列；

所述從用于給各個進程進行任務配置的配置中心獲取任務信息，具體為：

從所述配置中心中的任務配置表和任務隊列管理表中獲取任務信息。

4.根據權利要求3所述的分布式異步任務調度方法，其特征在于，給所述各個任務隊列配置的所述任務并發規則至少包括處理所述各個任務隊列中任務的并發線程數；并且所述處理所述各個任務隊列中任務的并發線程數根據線程池處理任務的速度實時調整。

5.根據權利要求3所述的分布式異步任務調度方法，其特征在于，給所述各個任務隊列配置的所述任務并發規則還包括任務高峰時間段，并且對于存儲非核心任務的任務隊列，在所述任務高峰時間段的并發線程數低于非任務高峰時間段的并發線程數。

6.根據權利要求1所述的分布式異步任務調度方法，其特征在于，所述任務信息還包括每次從所述目標任務隊列中獲取的任務數，所述每次從所述目標任務隊列中獲取的任務數通過以下方式得到：

每次從所述目標任務隊列中獲取的任務數＝所述目標任務隊列的處理線程數*線程池負載系數–等待處理任務數–正在處理任務數。

7.根據權利要求1所述的異步任務調度方法，其特征在于，所述方法還包括：所述配置中心還用于更改任務并發規則和任務狀態。

8.根據權利要求1所述的分布式異步任務調度方法，其特征在于，所述調取所述目標任務并執行，至少包括：

若有任務執行失敗，判斷所述任務的重試次數是否未達到預設閾值，若是，則將重試任務重新加入任務隊列當中，其中，所述預設閾值根據所述任務業務類型的不同而不同。

9.根據權利要求1所述的分布式異步任務調度方法，其特征在于，

所述目標任務隊列中的任務按優先級順序排列。

10.一種電子設備，其特征在于，包括：

至少一個處理器；以及，

與所述至少一個處理器通信連接的存儲器；其中，

所述存儲器存儲有可被所述至少一個處理器執行的指令，所述指令被所述至少一個處理器執行，以使所述至少一個處理器能夠執行如權利要求1至9中任一所述的分布式異步任務調度方法。