[發明專利]一種多隊列的自動售檢票數據處理方法

有效

• 申請號: 201310128727.3
• 申請日: 2013-04-15
• 公開（公告）號: CN103218254A
• 公開（公告）日: 2013-07-24
• 發明（設計）人: 王子龍;陳朝暉;張少文
• 申請（專利權）人: 廣州新科佳都科技有限公司
• 主分類號: G06F9/46
• 分類號: G06F9/46
• 代理公司: 暫無信息
• 代理人: 暫無信息

1.一種多隊列的自動售檢票數據處理方法，其特征在于，具體步驟包括：

步驟一、在計算機設備數據處理過程中首先建立：一級隊列和分發線程池，以及二級隊列和與二級隊列對應的業務處理線程池；

步驟二、利用所述一級隊列接收前端車站設備的實時數據包；

步驟三、通過所述分發線程池從所述一級隊列獲取數據，解析數據包并判斷類型后放入所述二級隊列；

步驟四、所述二級隊列從所述分發線程池接收符合預設類型的數據包；

步驟五、所述業務處理線程池從對應的所述二級隊列獲取的數據包進行業務處理，完成數據處理過程；

若數據包要求返回，則對業務處理完成的數據組裝返回的數據包，并通過網絡通信送回。

2.根據權利要求1所述的一種多隊列的自動售檢票數據處理方法，其特征在于，所述一級隊列和分發線程池的數量各為一個，分發線程池的線程以并發或并行方式執行；

所述二級隊列的數量為一個或多個；所述業務處理線程池的數量與所述二級隊列數量相同并一一對應，相應的業務處理線程池只負責處理一個對應的二級隊列中的數據；所述業務處理線程池的線程以并發或并行方式執行。

3.根據權利要求2所述的方法，其特征在于，所述一級隊列的容量和二級隊列的容量分別從相應的計算機設備內存容量和預期數據包處理量計算得出，公式如下：

其中，N為二級隊列的個數，DT₁...DT_n為每個隊列每秒預期處理的數據條數，PM為預期每條數據的大小，TM為計算機設備內存大小，FQ為一級隊列分配大小，SQ_i為第i個二級隊列的分配大小。

4.根據權利要求2所述的方法，其特征在于，所述分發線程池中線程數量和所述業務處理線程池中線程數量分別從計算機設備的CPU數量和預期數據包處理效率計算得出，公式如下：

其中N為二級隊列的個數，DT₁...DT_n為每個隊列每秒預期處理的數據條數，UT為計算機設備中CPU總數，FT為分發線程池分配的線程數量，ST_i為第i個二級隊列業務處理線程池中線程分配數量。

5.根據權利要求2所述的一種多隊列的自動售檢票數據處理方法，其特征在于，所述分發線程池中的線程和所述業務處理線程池中的線程，

如在單個CPU的計算機設備中，線程以并發方式執行；

如在多個CPU的計算機設備中，線程以并行或并發方式執行。

6.根據權利要求1所述的一種多隊列的自動售檢票數據處理方法，其特征在于，步驟二還包括：所述一級隊列提供阻塞機制使用計算機設備的CPU，具體過程為：

如所述一級隊列中沒有數據，所述分發線程池中的線程在獲取數據時會阻塞，直到獲取數據后才繼續執行；

如所述一級隊列中數據包數量達到上限后，將不再接收數據包。

7.根據權利要求1所述的一種多隊列的自動售檢票數據處理方法，其特征在于，步驟四還包括：所述二級隊列提供阻塞機制使用計算機設備的CPU，具體過程為：

如所述二級隊列中沒有數據，所述對應的業務處理線程池中的線程在獲取數據時會阻塞，直到獲取數據后才繼續執行；

如所述二級隊列中數據包數量達到上限后，所述分發線程池在存入數據時會發送阻塞，直到等待存入成功后才繼續執行。

8.根據權利要求1所述的一種多隊列的自動售檢票數據處理方法，其特征在于，所述計算機設備包括個人計算機、服務器或其它網絡設備。