[發明專利]一種分布式任務的處理方法和裝置

在審

• 申請號: 202110198569.3
• 申請日: 2021-02-22
• 公開（公告）號: CN112925618A
• 公開（公告）日: 2021-06-08
• 發明（設計）人: 田軍
• 申請（專利權）人: 北京達佳互聯信息技術有限公司
• 主分類號: G06F9/48
• 分類號: G06F9/48
• 代理公司: 北京中博世達專利商標代理有限公司 11274
• 代理人: 申健

1.一種分布式任務的處理方法，其特征在于，應用于包括至少兩個節點的分布式系統，包括：

在目標定時器的定時時長結束時，確定所述目標定時器的標識的余數和當前時間戳的余數；所述分布式系統中每一節點對應一個定時器，所述分布式系統中所有定時器的標識是連續的；所述目標定時器為所述所有定時器中的一個；

若確定所述目標定時器的標識的余數等于所述當前時間戳的余數，調用所述目標定時器對應的節點處理目標任務；所述目標任務為在所述當前時間戳對應的時間執行的任務。

2.根據權利要求1所述的處理方法，其特征在于，所述確定所述目標定時器的標識的余數和當前時間戳的余數，包括：

根據所述分布式系統中定時器數量，分別對所述目標定時器的標識和所述當前時間戳按照預設的取余算法進行處理，得到所述目標定時器的標識的余數和所述當前時間戳的余數。

3.根據權利要求1所述的處理方法，其特征在于，所述調用所述目標定時器對應的節點處理目標任務，包括：

遍歷任務隊列，獲取任務隊列中與所述當前時間戳對應的目標任務；所述任務隊列包括所述分布式系統中的所有待執行任務；

調用所述目標定時器對應的節點處理所述目標任務。

4.根據權利要求1所述的處理方法，其特征在于，所述處理方法還包括：

在確定所述目標任務處理成功后，移除任務隊列中的目標任務。

5.根據權利要求1-4任一項所述的處理方法，其特征在于，在確定所述目標定時器的標識的余數等于所述當前時間戳的余數之前，所述處理方法還包括：

確定所述當前時間戳對應的時長內不存在執行任務的節點。

6.根據權利要求5所述的處理方法，其特征在于，所述調用所述目標定時器對應的節點處理目標任務之后，所述處理方法還包括：

為所述當前時間戳添加輪詢標識，所述輪詢標識用于表征在所述當前時間戳對應的時長內已存在執行任務的節點。

7.一種分布式任務的處理裝置，其特征在于，應用于包括至少兩個節點的分布式系統，所述處理裝置包括確定模塊和處理模塊；

所述確定模塊，被配置為執行在目標定時器的定時時長結束時，確定所述目標定時器的標識的余數和當前時間戳的余數；所述分布式系統中每一節點對應一個定時器，所述分布式系統中所有定時器的標識是連續的；所述目標定時器為所述所有定時器中的一個；

所述處理模塊，被配置為執行若確定所述目標定時器的標識的余數等于所述當前時間戳的余數，調用所述目標定時器對應的節點處理目標任務；所述目標任務為在所述當前時間戳對應的時間執行的任務。

8.一種分布式任務的處理裝置，應用于包括至少兩個節點的分布式系統，其特征在于，所述處理裝置包括：

處理器；

用于存儲所述處理器可執行指令的存儲器；

其中，所述處理器被配置為執行所述指令，以實現如權利要求1-6中任一項所述的分布式任務的處理方法。

9.一種計算機可讀存儲介質，所述計算機可讀存儲介質上存儲有指令，其特征在于，當所述計算機可讀存儲介質中的指令由分布式任務的處理裝置的處理器執行時，使得所述分布式任務的處理裝置能夠執行如權利要求1-6中任一項所述的分布式任務的處理方法。

10.一種計算機程序產品，包括計算機指令，其特征在于，當所述計算機指令被分布式任務的處理裝置的處理器執行時，使得所述分布式任務的處理裝置執行如權利要求1-6中任一項所述的分布式任務的處理方法。