[發(fā)明專利]一種多線程處理數(shù)據(jù)的方法及裝置

有效

• 申請(qǐng)?zhí)枺?/td>: 201610027674.X
• 申請(qǐng)日: 2016-01-15
• 公開（公告）號(hào): CN105700938B
• 公開（公告）日: 2019-02-19
• 發(fā)明（設(shè)計(jì)）人: 馮賓華
• 申請(qǐng)（專利權(quán)）人: 浪潮通用軟件有限公司
• 主分類號(hào): G06F9/46
• 分類號(hào): G06F9/46
• 代理公司: 濟(jì)南信達(dá)專利事務(wù)所有限公司 37100
• 代理人: 李世喆

1.一種多線程處理數(shù)據(jù)的方法，其特征在于，預(yù)先確定線程池的大小和線程的第一數(shù)量，其中，所述線程的第一數(shù)量不大于所述線程池的大小，該方法還包括：

初始化所述線程池，創(chuàng)建所述第一數(shù)量的線程；

針對(duì)所述第一數(shù)量的線程中的每一個(gè)目標(biāo)線程，均執(zhí)行：記錄所述目標(biāo)線程的狀態(tài)信息；

將待處理的至少一個(gè)數(shù)據(jù)分配至所述目標(biāo)線程，以使所述目標(biāo)線程處理所述至少一個(gè)數(shù)據(jù)中的每一個(gè)目標(biāo)數(shù)據(jù)；

監(jiān)控所述目標(biāo)線程中是否存在處理失敗的所述目標(biāo)數(shù)據(jù)，若存在，則記錄所述目標(biāo)數(shù)據(jù)的處理狀態(tài)，更新所述目標(biāo)線程的狀態(tài)信息，并結(jié)束所述目標(biāo)線程;

在所述確定線程池的大小和線程的第一數(shù)量之前，進(jìn)一步包括：首次創(chuàng)建線程參數(shù)配置規(guī)則，確定服務(wù)器的配置；

所述確定線程池的大小和線程的第一數(shù)量，包括：根據(jù)所述服務(wù)器的配置，利用所述線程參數(shù)配置規(guī)則，確定線程池的大小和線程的第一數(shù)量;

所述確定線程池的大小和線程的第一數(shù)量，包括：確定所述線程池的大小等于所述服務(wù)器的CPU核心數(shù)再加1，所述線程的第一數(shù)量等于所述服務(wù)器的CPU核心數(shù)再減1;

在所述記錄所述目標(biāo)線程的狀態(tài)信息之前，進(jìn)一步包括：首次創(chuàng)建線程狀態(tài)記錄規(guī)則；

所述記錄所述目標(biāo)線程的狀態(tài)信息，包括：根據(jù)所述線程狀態(tài)記錄規(guī)則，記錄所述目標(biāo)線程的狀態(tài)信息;

所述將待處理的至少一個(gè)數(shù)據(jù)分配至所述目標(biāo)線程，包括：根據(jù)所述線程的第一數(shù)量和企業(yè)實(shí)際應(yīng)用需求，將待處理的至少一個(gè)數(shù)據(jù)分配至所述目標(biāo)線程；

所述目標(biāo)數(shù)據(jù)，包括：企業(yè)年金賬戶管理系統(tǒng)中用于交易申購的業(yè)務(wù)單據(jù)。

2.一種多線程處理數(shù)據(jù)的裝置，其特征在于，包括：

第一確定單元，用于確定線程池的大小和線程的第一數(shù)量，其中，所述線程的第一數(shù)量不大于所述線程池的大小；

處理單元，用于初始化所述線程池，創(chuàng)建所述第一數(shù)量的線程，并向第一記錄單元輸出第一觸發(fā)信號(hào)；在接收到由所述第一記錄單元輸出的第二觸發(fā)信號(hào)之后，將待處理的至少一個(gè)數(shù)據(jù)分配至第一數(shù)量的線程中的每一個(gè)目標(biāo)線程，以使所述目標(biāo)線程處理所述至少一個(gè)數(shù)據(jù)中的每一個(gè)目標(biāo)數(shù)據(jù)；監(jiān)控所述目標(biāo)線程中是否存在處理失敗的所述目標(biāo)數(shù)據(jù)，若存在，則向第二記錄單元輸出第三觸發(fā)信號(hào)，以使所述第二記錄單元記錄所述目標(biāo)數(shù)據(jù)的處理狀態(tài)，向所述第一記錄單元輸出第四觸發(fā)信號(hào)，以使所述第一記錄單元更新所述目標(biāo)線程的狀態(tài)信息，并結(jié)束所述目標(biāo)線程；

所述第一記錄單元，用于在接收到由所述處理單元輸出的第一觸發(fā)信號(hào)之后，針對(duì)所述第一數(shù)量的線程中的每一個(gè)目標(biāo)線程，均執(zhí)行：記錄所述目標(biāo)線程的狀態(tài)信息，并向所述處理單元輸出第二觸發(fā)信號(hào)；在接收到由所述處理單元輸出的第四觸發(fā)信號(hào)之后，更新所述目標(biāo)線程的狀態(tài)信息；

所述第二記錄單元，用于在接收到由所述處理單元輸出的第三觸發(fā)信號(hào)之后，記錄所述目標(biāo)數(shù)據(jù)的處理狀態(tài);

還包括：

創(chuàng)建單元，用于首次創(chuàng)建線程參數(shù)配置規(guī)則；

第二確定單元，用于確定服務(wù)器的配置；

所述第一確定單元，具體用于根據(jù)所述服務(wù)器的配置，利用所述線程參數(shù)配置規(guī)則，確定線程池的大小和線程的第一數(shù)量;

所述創(chuàng)建單元，進(jìn)一步用于首次創(chuàng)建線程狀態(tài)記錄規(guī)則；

所述第一記錄單元，具體用于根據(jù)所述線程狀態(tài)記錄規(guī)則，記錄所述目標(biāo)線程的狀態(tài)信息;

所述處理單元，具體用于根據(jù)所述線程的第一數(shù)量和企業(yè)實(shí)際應(yīng)用需求，將待處理的至少一個(gè)數(shù)據(jù)分配至所述目標(biāo)線程。