[發明專利]一種行集數據的處理方法、裝置及數據處理系統

有效

• 申請號: 200910189019.4
• 申請日: 2009-12-16
• 公開（公告）號: CN101714099A
• 公開（公告）日: 2010-05-26
• 發明（設計）人: 鄭學明
• 申請（專利權）人: 金蝶軟件(中國)有限公司
• 主分類號: G06F9/46
• 分類號: G06F9/46
• 代理公司: 深圳中一專利商標事務所 44237
• 代理人: 張全文

1.一種行集數據的處理方法，其特征在于，所述方法包括以下步驟：

將待處理的行集數據傳入起始任務節點的輸入緩沖區；

從所述輸入緩沖區中逐行取出數據進行處理，將處理完的數據傳輸至中繼 任務節點的中轉緩沖區；

當存在下一個中繼任務節點時，從當前中繼任務節點的中轉緩沖區中逐行 取出數據進行處理，將處理完的數據傳輸至下一個中繼任務節點的中轉緩沖區， 以此類推；

當不存在下一個中繼任務節點時，從當前中繼任務節點的中轉緩沖區中逐 行取出數據進行處理，將處理完的數據傳輸至終止任務節點的輸出緩沖區；

將終止任務節點輸出緩沖區的數據輸出。

2.如權利要求1所述的方法，其特征在于，所述方法還包括以下步驟：

為數據處理任務流中的所有任務節點均開啟一個處理線程。

3.如權利要求1所述的方法，其特征在于，所述方法還包括以下步驟：

設置起始任務節點的輸入緩沖區；

設置每個中繼任務節點的中轉緩沖區；

設置終止任務節點的輸出緩沖區。

4.如權利要求1所述的方法，其特征在于，所述方法還包括以下步驟：

當處理完一行數據后，將其從起始任務節點的輸入緩沖區中清除。

5.如權利要求2所述的方法，其特征在于，所述方法還包括以下步驟：

當終止任務節點標識為完成時，關閉所有任務節點的處理線程，釋放內存。

6.一種行集數據的處理裝置，其特征在于，所述裝置包括：

數據傳輸模塊，用于將待處理的行集數據傳入起始任務節點的輸入緩沖區；

用于從所述輸入緩沖區中逐行取出數據進行處理，將處理完的數據傳輸至 中繼任務節點的中轉緩沖區的模塊；

用于當存在下一個中繼任務節點時，從當前中繼任務節點的中轉緩沖區中 逐行取出數據進行處理，將處理完的數據傳輸至下一個中繼任務節點的中轉緩 沖區的模塊；

用于當不存在下一個中繼任務節點時，從當前中繼任務節點的中轉緩沖區 中逐行取出數據進行處理，將處理完的數據傳輸至終止任務節點的輸出緩沖區 的模塊；

數據輸出模塊，用于將終止任務節點輸出緩沖區的數據輸出。

7.如權利要求6所述的裝置，其特征在于，所述裝置還包括：

處理線程開啟模塊，用于為數據處理任務流中的所有任務節點均開啟一個 處理線程。

8.如權利要求6所述的裝置，其特征在于，所述裝置還包括：

數據清除模塊，用于當處理完一行數據后，將其從起始任務節點的輸入緩 沖區中清除。

9.如權利要求7所述的裝置，其特征在于，所述裝置還包括：

內存釋放模塊，用于當終止任務節點標識為完成時，關閉所有任務節點的 處理線程，釋放內存。

10.一種包括權利要求6至9任一項所述的行集數據的處理裝置的數據處 理系統。