[發明專利]一種基于多線程的分布式數據處理方法及服務器

有效

• 申請號: 201811039237.5
• 申請日: 2018-09-06
• 公開（公告）號: CN109284193B
• 公開（公告）日: 2022-12-09
• 發明（設計）人: 任練
• 申請（專利權）人: 平安科技（深圳）有限公司
• 主分類號: G06F9/52
• 分類號: G06F9/52
• 代理公司: 深圳中一專利商標事務所 44237
• 代理人: 官建紅

本發明適用于計算機技術領域，提供了一種基于多線程的分布式數據處理方法及服務器，包括：獲取信息庫所存儲的增量數據，并確定與增量數據的數據類型匹配的工作線程；若匹配的工作線程的數目為至少兩個，則根據預設的線程令牌表確定匹配的工作線程的執行順序；根據匹配的工作線程各自的執行順序控制目標分布式設備啟動目標工作線程，以通過目標工作線程對增量數據進行處理；接收目標分布式設備返回的用于標識目標工作線程執行完成的確認信息；確認信息用于重新確定目標工作線程以及啟動所述重新確定的目標工作線程。本發明實施例能夠避免工作線程搶占資源，節省系統資源，也避免了同一線程重復執行擾亂制證操作流程的情況發生，能夠提高制證效率。

技術領域

本發明屬于計算機技術領域，尤其涉及一種基于多線程的分布式數據處理方法及服務器。

背景技術

傳統的制證方法是通過人工手動采集業務數據，再對該業務數據進行格式審核和添加必要的制證信息(如制證日期等)，最終將經過格式審核的業務數據和添加的制證信息一起存儲到制證表中，從而完成制證。在整個制證過程中，業務數據涉及調取數據、核算以及制證等多個階段的操作流程，而每一階段的流程分別由相應的工作線程來進行處理。

然而，現有技術中，當業務數據出現錯誤時，工作線程的整個處理流程也會受到影響，可能會出現同一業務數據被多個工作線程同時存取的情況，因增加數據處理壓力而造成系統資源浪費，可能導致同一線程重復執行擾亂制證操作流程，同時也降低了制證效率。

發明內容

有鑒于此，本發明實施例提供了一種基于多線程的分布式數據處理方法及服務器，以解決現有技術中，當業務數據出現錯誤時，可能會出現同一業務數據被多個工作線程同時存取的情況，從而導致同一線程重復執行擾亂制證操作流程，也降低了制證效率的問題。

本發明實施例的第一方面提供了一種基于多線程的分布式數據處理方法，包括：

獲取信息庫所存儲的增量數據，并確定與所述增量數據的數據類型匹配的工作線程；

若所述匹配的工作線程的數目為至少兩個，則根據預設的線程令牌表確定所述匹配的工作線程的執行順序；

根據所述匹配的工作線程各自的執行順序控制目標分布式設備啟動目標工作線程，以通過所述目標工作線程對所述增量數據進行處理；其中，分布式設備用于為工作線程提供運行環境，所述目標工作線程為當前需要啟動的工作線程，所述目標分布式設備為用于執行所述目標工作線程的分布式設備，任意時刻只有一個工作線程處于啟動狀態；

接收所述目標分布式設備返回的用于標識所述目標工作線程執行完成的確認信息；所述確認信息用于重新確定目標工作線程以及啟動所述重新確定的目標工作線程。

本發明實施例的第二方面提供了一種服務器，包括存儲器、處理器以及存儲在所述存儲器中并可在所述處理器上運行的計算機程序，所述處理器執行所述計算機程序時實現以下步驟：

獲取信息庫所存儲的增量數據，并確定與所述增量數據的數據類型匹配的工作線程；

若所述匹配的工作線程的數目為至少兩個，則根據預設的線程令牌表確定所述匹配的工作線程的執行順序；

根據所述匹配的工作線程各自的執行順序控制目標分布式設備啟動目標工作線程，以通過所述目標工作線程對所述增量數據進行處理；其中，分布式設備用于為工作線程提供運行環境，所述目標工作線程為當前需要啟動的工作線程，所述目標分布式設備為用于執行所述目標工作線程的分布式設備，任意時刻只有一個工作線程處于啟動狀態；

接收所述目標分布式設備返回的用于標識所述目標工作線程執行完成的確認信息；所述確認信息用于重新確定目標工作線程以及啟動所述重新確定的目標工作線程。

本發明實施例的第三方面提供了一種計算機可讀存儲介質，所述計算機可讀存儲介質存儲有計算機程序，所述計算機程序被處理器執行時實現以下步驟：