[發明專利]基于時間片調度的同步任務處理方法及裝置

有效

• 申請號: 201711478190.8
• 申請日: 2017-12-29
• 公開（公告）號: CN108108463B
• 公開（公告）日: 2021-08-24
• 發明（設計）人: 王康
• 申請（專利權）人: 北京奇虎科技有限公司
• 主分類號: G06F16/27
• 分類號: G06F16/27;G06F16/22;G06F9/50;G06F9/48
• 代理公司: 深圳市世紀恒程知識產權代理事務所 44287
• 代理人: 胡海國

本發明公開了一種基于時間片調度的同步任務處理方法及裝置。所述方法包括：根據至少一個從節點發送的同步請求，生成同步任務；將所述同步任務置入任務隊列中；由線程池中的任一空閑線程從所述任務隊列中獲取并執行同步任務；判斷同步任務的執行時間是否已到達預設時間片規定的時間，若是，將所述同步任務重置入所述任務隊列中。采用本方案，可實現線程數與主從關系個數的解耦，通過低于系統中主從同步關系個數的線程數完成系統中大量的主從同步工作，從而大幅降低系統開銷，節約系統資源。

技術領域

本發明涉及計算機技術領域，具體涉及一種基于時間片調度的同步任務處理方法及裝置。

背景技術

主從結構的分布式系統以其具有高靈活性，高數據可靠性，低服務節點負荷，較高的數據的讀寫效率，以及可實現讀寫分離等特點，已成為一種常用的數據庫結構。

在主從結構的分布式系統中，為實現系統中各個主從節點的數據同步，通常為已經建立的各個主從關系分配單獨的同步線程，每個主從同步關系中的主節點通過對應的同步線程順序地向從節點發送同步數據，從而實現主從節點間的數據同步。

然而，采用上述方法處理同步任務時，系統中的同步線程數與主從關系的個數一一對應，當系統中的主從關系數量較多時，會造成系統中線程數的膨脹，從而增加系統開銷，影響系統性能；并且，與每個主從關系對應的同步線程通常處于空閑狀態，從而引起系統資源的浪費。

發明內容

鑒于上述問題，提出了本發明以便提供一種克服上述問題或者至少部分地解決上述問題的基于時間片調度的同步任務處理方法及裝置。

根據本發明的一個方面，提供了一種基于時間片調度的同步任務處理方法，包括：

根據至少一個從節點發送的同步請求，生成同步任務；

將所述同步任務置入任務隊列中；

由線程池中的任一空閑線程從所述任務隊列中獲取并執行同步任務；

判斷同步任務的執行時間是否已到達預設時間片規定的時間，若是，將所述同步任務重置入所述任務隊列中。

根據本發明的另一方面，提供了一種基于時間片調度的同步任務處理裝置，包括：

生成模塊，適于根據至少一個從節點發送的同步請求，生成同步任務；

置入模塊，適于將所述同步任務置入任務隊列中；

執行模塊，適于由線程池中的任一空閑線程從所述任務隊列中獲取并執行同步任務；

重置模塊，適于判斷同步任務的執行時間是否已到達預設時間片規定的時間，若是，將所述同步任務重置入所述任務隊列中。

根據本發明的又一方面，提供了一種計算設備，包括：處理器、存儲器、通信接口和通信總線，所述處理器、所述存儲器和所述通信接口通過所述通信總線完成相互間的通信；

所述存儲器用于存放至少一可執行指令，所述可執行指令使所述處理器執行上述基于時間片調度的同步任務處理方法對應的操作。

根據本發明的再一方面，提供了一種計算機存儲介質，所述存儲介質中存儲有至少一可執行指令，所述可執行指令使處理器執行如上述基于時間片調度的同步任務處理方法對應的操作。

根據本發明提供的基于時間片調度的同步任務處理方法及裝置，首先根據至少一個從節點發送的同步請求，生成同步任務；并將同步任務置入任務隊列中；由線程池中的任一空閑線程從所述任務隊列中獲取并執行同步任務；最后判斷同步任務的執行時間是否已到達預設時間片規定的時間，若是，將所述同步任務重置入所述任務隊列中。采用本方案，可實現線程數與主從關系個數的解耦，通過低于系統中主從同步關系個數的線程數完成系統中大量的主從同步任務，從而大幅降低系統開銷，節約系統資源。