[發明專利]一種動態優化的多線程數據同步方法及系統

有效

• 申請號: 201911308546.2
• 申請日: 2019-12-18
• 公開（公告）號: CN111190961B
• 公開（公告）日: 2023-09-29
• 發明（設計）人: 熊林欣;朱興;陳晶鑫;呂婉瑩;徐錦子
• 申請（專利權）人: 航天信息股份有限公司
• 主分類號: G06F16/27
• 分類號: G06F16/27;G06F9/52
• 代理公司: 北京工信聯合知識產權代理有限公司 11266
• 代理人: 姜麗樓

1.一種動態優化的多線程數據同步方法，其特征在于，所述方法包括：

主線程按照預設的時間間隔閾值，根據待同步數據中每個地區的地區標識確定每個地區對應的地區數據條數；

主線程根據每個地區對應的地區數據條數，按照預設的子線程分配策略為每個地區分配對應的子線程；

每個子線程根據已分配地區對應的地區數據條數，按照預設的同步策略進行數據同步;

其中，所述主線程根據每個地區對應的地區數據條數，按照預設的子線程分配策略為每個地區分配對應的子線程，包括：

當存在未分配子線程的地區時，判斷該地區對應的地區數據條數是否小于等于預設的數據同步條數閾值；若是，則創建單獨處理該地區的子線程；反之，則標記該地區為需合并處理的地區；以及

當存在需合并處理的地區時，根據需合并處理的地區的對應的數據條數，創建合并處理的子線程，以為每個地區分配對應的子線程；

其中，所述每個子線程根據已分配地區對應的地區數據條數，按照預設的同步策略進行數據同步，包括：

每個子線程將對應的已分配地區標記為正在處理狀態；

根據待同步數據的編號選取預設的數據同步條數閾值的數據，若選取的數據條數大于預設選取條數閾值，則直接調用接口同步數據，實現一次數據同步。

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

在每個子線程將對應的已分配地區標記為正在處理狀態之前，判斷該子線程對應的所有地區的處理狀態；若不存在已經為正在處理狀態的地區，則將該子線程對應的已分配地區標記為正在處理狀態；反之，則直接結束此次數據同步。

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

當該次數據同步成功時，若該次同步的數據條數小于預設的數據同步條數閾值，則表示數據已全部同步完成，將該子線程對應的已分配地區標記為未處理狀態；

當該次數據同步成功時，若該次同步的數據條數大于等于預設的數據同步條數閾值，則判斷是否滿足地區個數是否大于1且同步成功次數大于已分配的地區個數；若滿足，則表示存在數據積壓，將該子線程對應的已分配地區標記為未處理狀態，并立即結束當前線程，由主線程重新調度分配獨立處理子線程；若不滿足，則重新根據待同步數據的編號重新選取預設的數據同步條數閾值的數據，以進行下一次的數據同步。

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

若選取的數據條數大于預設選取條數閾值，則表示數據已全部同步完成，將該子線程對應的已分配地區標記為未處理狀態。

5.一種動態優化的多線程數據同步系統，其特征在于，所述系統包括：

待同步的地區數據確定單元，用于使主線程按照預設的時間間隔閾值，根據待同步數據中每個地區的地區標識確定每個地區對應的地區數據條數；

子線程分配單元，用于使主線程根據每個地區對應的地區數據條數，按照預設的子線程分配策略為每個地區分配對應的子線程；

數據同步單元，用于每個子線程根據已分配地區對應的地區數據條數，按照預設的同步策略進行數據同步；

其中，所述子線程分配單元，使主線程根據每個地區對應的地區數據條數，按照預設的子線程分配策略為每個地區分配對應的子線程，包括：

當存在未分配子線程的地區時，判斷該地區對應的地區數據條數是否小于等于預設的數據同步條數閾值；若是，則創建單獨處理該地區的子線程；反之，則標記該地區為需合并處理的地區；以及

當存在需合并處理的地區時，根據需合并處理的地區的對應的數據條數，創建合并處理的子線程，以為每個地區分配對應的子線程；

其中，所述數據同步單元，使每個子線程根據已分配地區對應的地區數據條數，按照預設的同步策略進行數據同步，包括：

每個子線程將對應的已分配地區標記為正在處理狀態；

根據待同步數據的編號選取預設的數據同步條數閾值的數據，若選取的數據條數大于預設選取條數閾值，則直接調用接口同步數據，實現一次數據同步。