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

在審

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

本公開提供一種分布式任務的處理方法和裝置，涉及計算機技術領域，以至少解決現(xiàn)有技術中無法保證任務調度時間的均衡性的問題。該處理方法包括：在目標定時器的定時時長結束時，確定目標定時器的標識的余數(shù)和當前時間戳的余數(shù)；分布式系統(tǒng)中每一節(jié)點對應一個定時器，分布式系統(tǒng)中所有定時器的標識是連續(xù)的；目標定時器為所有定時器中的一個；若確定目標定時器的標識的余數(shù)等于當前時間戳的余數(shù)，調用目標定時器對應的節(jié)點處理目標任務；目標任務為在當前時間戳對應的時間執(zhí)行的任務。

技術領域

本公開涉及計算機技術領域，尤其涉及一種分布式任務的處理方法和裝置。

背景技術

分布式任務一般是依賴于分布式鎖機制來處理的，即分布式系統(tǒng)中不同節(jié)點進行搶鎖，搶鎖成功的節(jié)點處理對應的任務，并在任務處理完畢之后釋放鎖，與搶鎖失敗的節(jié)點共同進入下一個調度周期，進行下一輪搶鎖。

在上述分布式任務處理方法中，只有在搶鎖成功的節(jié)點釋放鎖之后，所有的節(jié)點才能夠在下一個調度周期，進行下一輪搶鎖。這樣，當任務比較復雜時，處理任務的時長會比較長，進而壓縮了下一輪搶鎖時間和任務的處理時間。因此，上述的分布式任務處理方法無法保證任務調度時間的均衡性。

發(fā)明內容

本公開提供一種分布式任務的處理方法和裝置，以至少解決現(xiàn)有技術中無法保證任務調度時間的均衡性的問題。本公開的技術方案如下：

根據(jù)本公開的第一方面，提供一種分布式任務的處理方法，應用于包括至少兩個節(jié)點的分布式系統(tǒng)。該處理方法包括：在目標定時器的定時時長結束時，確定目標定時器的標識的余數(shù)和當前時間戳的余數(shù)。之后，若確定目標定時器的標識的余數(shù)等于當前時間戳的余數(shù)，調用目標定時器對應的節(jié)點處理目標任務。

其中，分布式系統(tǒng)中每一節(jié)點對應一個定時器，分布式系統(tǒng)中所有定時器的標識是連續(xù)的；目標定時器為所有定時器中的一個；目標任務為在當前時間戳對應的時間執(zhí)行的任務。

可選的，上述“確定目標定時器的標識的余數(shù)和當前時間戳的余數(shù)”的方法，包括：根據(jù)分布式系統(tǒng)中定時器數(shù)量，分別對目標定時器的標識和當前時間戳按照預設的取余算法進行處理，得到目標定時器的標識的余數(shù)和當前時間戳的余數(shù)。

可選的，上述“調用目標定時器對應的節(jié)點處理目標任務”的方法包括：遍歷任務隊列，獲取任務隊列中與當前時間戳對應的目標任務，并調用目標定時器對應的節(jié)點處理目標任務。其中，任務隊列包括分布式系統(tǒng)中的所有待執(zhí)行任務。

可選的，該處理方法還包括：在確定目標任務處理成功后，移除任務隊列中的目標任務。

可選的，在上述“確定目標定時器的標識的余數(shù)等于當前時間戳的余數(shù)”之前，該處理方法還包括：確定當前時間戳對應的時長內不存在執(zhí)行任務的節(jié)點。

可選的，在上述“調用目標定時器對應的節(jié)點處理目標任務”之后，該處理方法還包括：為當前時間戳添加輪詢標識，輪詢標識用于表征在當前時間戳對應的時長內已存在執(zhí)行任務的節(jié)點。

可選的，在目標任務為定時任務的情況下，目標定時器的定時時長小于定時任務的最大處理時長。

可選的，該處理方法還包括：若目標定時器的標識的余數(shù)不等于當前時間戳的余數(shù)，則重新啟動目標定時器。

根據(jù)本公開的第二方面，提供一種分布式任務的處理裝置，應用于包括至少兩個節(jié)點的分布式系統(tǒng)，該處理裝置包括確定模塊和處理模塊。確定模塊，被配置為執(zhí)行在目標定時器的定時時長結束時，確定目標定時器的標識的余數(shù)和當前時間戳的余數(shù)。其中，分布式系統(tǒng)中每一節(jié)點對應一個定時器，分布式系統(tǒng)中所有定時器的標識是連續(xù)的；目標定時器為所有定時器中的一個。處理模塊，被配置為執(zhí)行若確定目標定時器的標識的余數(shù)等于當前時間戳的余數(shù)，調用目標定時器對應的節(jié)點處理目標任務。其中，目標任務為在當前時間戳對應的時間執(zhí)行的任務。