[發(fā)明專利]一種數(shù)據(jù)處理方法、裝置、電子設(shè)備及存儲介質(zhì)

在審

• 申請?zhí)枺?/td>: 202010415047.X
• 申請日: 2020-05-15
• 公開（公告）號: CN111767281A
• 公開（公告）日: 2020-10-13
• 發(fā)明（設(shè)計）人: 張云龍
• 申請（專利權(quán)）人: 北京奇藝世紀科技有限公司
• 主分類號: G06F16/22
• 分類號: G06F16/22;G06F9/48
• 代理公司: 北京華夏泰和知識產(chǎn)權(quán)代理有限公司 11662
• 代理人: 杜欣

1.一種數(shù)據(jù)處理方法，其特征在于，所述方法包括：

利用生產(chǎn)者線程處理待處理任務(wù)，得到生產(chǎn)數(shù)據(jù)；

在暫存索引數(shù)組中查找與所述生產(chǎn)者線程對應(yīng)的索引位置；

根據(jù)所述索引位置查找與所述索引位置對應(yīng)的暫存鏈表；

利用與所述生產(chǎn)者線程對應(yīng)的消費者線程消費所述暫存鏈表中的所述生產(chǎn)數(shù)據(jù)。

2.根據(jù)權(quán)利要求1所述的數(shù)據(jù)處理方法，其特征在于，在暫存索引數(shù)組中查找與所述生產(chǎn)者線程對應(yīng)的索引位置的步驟，包括：

獲取所述生產(chǎn)者線程的線程標識；

確定所述線程標識是否位于預(yù)設(shè)路由表中；

若所述線程標識位于預(yù)設(shè)路由表中，將所述預(yù)設(shè)路由表中與所述線程標識對應(yīng)的索引位置確定為與所述生產(chǎn)者線程對應(yīng)的索引位置。

3.根據(jù)權(quán)利要求2所述的數(shù)據(jù)處理方法，其特征在于，在暫存索引數(shù)組中查找與所述生產(chǎn)者線程對應(yīng)的索引位置的步驟，還包括：

若所述線程標識不位于所述預(yù)設(shè)路由表中，為所述線程標識分配對應(yīng)的索引位置；

將為所述線程標識分配的索引位置確定為與所述生產(chǎn)者線程對應(yīng)的索引位置；

將所述線程標識與所述索引位置之間的對應(yīng)關(guān)系存儲至所述預(yù)設(shè)路由表中。

4.根據(jù)權(quán)利要求1所述的數(shù)據(jù)處理方法，其特征在于，所述方法還包括：

判斷所述暫存鏈表中當前待消費的數(shù)據(jù)量是否達到預(yù)設(shè)允許最大數(shù)據(jù)量；

若所述暫存鏈表中當前待消費的數(shù)據(jù)量達到預(yù)設(shè)允許最大數(shù)據(jù)量，等待消費者線程消費生產(chǎn)數(shù)據(jù)，直至所述暫存鏈表中當前待消費的數(shù)據(jù)量小于所述預(yù)設(shè)允許最大數(shù)據(jù)量。

5.根據(jù)權(quán)利要求4所述的數(shù)據(jù)處理方法，其特征在于，所述方法還包括：

若所述暫存鏈表中當前待消費的數(shù)據(jù)量小于預(yù)設(shè)允許最大數(shù)據(jù)量，執(zhí)行利用生產(chǎn)者線程處理所述待處理任務(wù)，得到生產(chǎn)數(shù)據(jù)的步驟；

在得到生產(chǎn)數(shù)據(jù)后，向所述消費者線程發(fā)送數(shù)據(jù)消費通知。

6.根據(jù)權(quán)利要求1所述的數(shù)據(jù)處理方法，其特征在于，所述方法還包括：

判斷所述暫存鏈表中是否存在待消費的生產(chǎn)數(shù)據(jù)；

若所述暫存鏈表中不存在待消費的生產(chǎn)數(shù)據(jù)，等待生產(chǎn)者線程處理所述待處理任務(wù)，直至所述暫存鏈表中存在待消費的生產(chǎn)數(shù)據(jù)。

7.根據(jù)權(quán)利要求6所述的數(shù)據(jù)處理方法，其特征在于，所述方法還包括：

若所述暫存鏈表中存在待消費的生產(chǎn)數(shù)據(jù)，執(zhí)行利用與所述生產(chǎn)者線程對應(yīng)的消費者線程消費所述暫存鏈表中的所述生產(chǎn)數(shù)據(jù)的步驟；

在消費所述生產(chǎn)數(shù)據(jù)完成后，向所述生產(chǎn)者線程發(fā)送數(shù)據(jù)生產(chǎn)通知。

8.一種數(shù)據(jù)處理裝置，其特征在于，所述裝置包括：

生產(chǎn)模塊，用于利用生產(chǎn)者線程處理待處理任務(wù)，得到生產(chǎn)數(shù)據(jù)；

第一查找模塊，用于在暫存索引數(shù)組中查找與所述生產(chǎn)者線程對應(yīng)的索引位置；

第二查找模塊，用于根據(jù)所述索引位置查找與所述索引位置對應(yīng)的暫存鏈表；

消費模塊，用于利用與所述生產(chǎn)者線程對應(yīng)的消費者線程消費所述暫存鏈表中的所述生產(chǎn)數(shù)據(jù)。

9.一種電子設(shè)備，其特征在于，包括處理器、通信接口、存儲器和通信總線，其中，處理器，通信接口，存儲器通過通信總線完成相互間的通信；

存儲器，用于存放計算機程序；

處理器，用于執(zhí)行存儲器上所存放的程序時，實現(xiàn)權(quán)利要求1～7任一所述的數(shù)據(jù)處理方法。

10.一種計算機可讀存儲介質(zhì)，其特征在于，所述計算機可讀存儲介質(zhì)上存儲有數(shù)據(jù)處理方法的程序，所述數(shù)據(jù)處理方法的程序被處理器執(zhí)行時實現(xiàn)權(quán)利要求1-7任一所述的數(shù)據(jù)處理方法的步驟。