[發(fā)明專利]數(shù)據(jù)處理的方法、網(wǎng)絡(luò)設(shè)備、計(jì)算節(jié)點(diǎn)和系統(tǒng)

有效

• 申請?zhí)枺?/td>: 201910362340.1
• 申請日: 2019-04-30
• 公開（公告）號(hào): CN111865831B
• 公開（公告）日: 2022-05-13
• 發(fā)明（設(shè)計(jì)）人: 林偉彬;侯新宇;李濤
• 申請（專利權(quán)）人: 華為技術(shù)有限公司
• 主分類號(hào): H04L49/901
• 分類號(hào): H04L49/901
• 代理公司: 北京龍雙利達(dá)知識(shí)產(chǎn)權(quán)代理有限公司 11329
• 代理人: 周喬;王君

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

網(wǎng)絡(luò)設(shè)備根據(jù)第一隊(duì)列的標(biāo)識(shí)，從計(jì)算節(jié)點(diǎn)的隊(duì)列信息存儲(chǔ)空間中讀取所述第一隊(duì)列的指針信息，其中所述網(wǎng)絡(luò)設(shè)備和所述計(jì)算節(jié)點(diǎn)相連，所述隊(duì)列信息存儲(chǔ)空間設(shè)置于所述計(jì)算節(jié)點(diǎn)的內(nèi)存中，所述網(wǎng)絡(luò)設(shè)備用于實(shí)現(xiàn)所述計(jì)算節(jié)點(diǎn)和其他計(jì)算節(jié)點(diǎn)之間基于隊(duì)列對進(jìn)行通信，所述隊(duì)列對包括多個(gè)隊(duì)列，所述第一隊(duì)列為所述多個(gè)隊(duì)列中任意一個(gè)，所述第一隊(duì)列的指針信息包括第一寫指針和讀指針，所述讀指針用于指示所述網(wǎng)絡(luò)設(shè)備需要處理的下一個(gè)單元的位置，所述第一寫指針用于指示所述第一隊(duì)列中當(dāng)前時(shí)刻允許所述計(jì)算節(jié)點(diǎn)存儲(chǔ)數(shù)據(jù)的最后一個(gè)單元的位置；

所述網(wǎng)絡(luò)設(shè)備根據(jù)所述讀指針獲取所述第一隊(duì)列中待處理數(shù)據(jù)，并處理所述待處理數(shù)據(jù)；

所述網(wǎng)絡(luò)設(shè)備根據(jù)所述第一寫指針更新所述讀指針?biāo)甘镜膯卧奈恢谩?/p>

2.如權(quán)利要求1所述的方法，其特征在于，所述網(wǎng)絡(luò)設(shè)備根據(jù)第一隊(duì)列的標(biāo)識(shí)，從計(jì)算節(jié)點(diǎn)的隊(duì)列信息存儲(chǔ)空間中讀取所述第一隊(duì)列的指針信息，包括：

所述網(wǎng)絡(luò)設(shè)備根據(jù)所述第一隊(duì)列的標(biāo)識(shí)，從所述計(jì)算節(jié)點(diǎn)的隊(duì)列信息存儲(chǔ)空間中的第一存儲(chǔ)空間讀取所述第一寫指針，所述第一存儲(chǔ)空間為用于存儲(chǔ)所述第一寫指針。

3.如權(quán)利要求1或2所述的方法，其特征在于，在所述網(wǎng)絡(luò)設(shè)備根據(jù)所述第一寫指針更新所述讀指針?biāo)甘镜膯卧奈恢弥?，所述方法還包括：

所述網(wǎng)絡(luò)設(shè)備根據(jù)第一隊(duì)列的標(biāo)識(shí)，從所述網(wǎng)絡(luò)設(shè)備的緩存中讀取第二寫指針，其中所述第二寫指針是所述網(wǎng)絡(luò)設(shè)備緩存的所述第一隊(duì)列的指針信息中的寫指針，所述網(wǎng)絡(luò)設(shè)備的緩存用于存儲(chǔ)所述網(wǎng)絡(luò)設(shè)備已讀取的所述第一隊(duì)列的指針信息；

所述網(wǎng)絡(luò)設(shè)備比較所述第一寫指針和所述第二寫指針；

所述網(wǎng)絡(luò)設(shè)備在確定所述第一寫指針指示的單元為在第二寫指針?biāo)甘镜膯卧鎯?chǔ)指令之后再存儲(chǔ)指令的單元時(shí)，將所述網(wǎng)絡(luò)設(shè)備緩存的所述第一隊(duì)列的指針信息中的寫指針更新為所述第一寫指針。

4.根據(jù)權(quán)利要求3所述的方法，其特征在于，所述網(wǎng)絡(luò)設(shè)備比較所述第一寫指針和所述第二寫指針，包括：

所述網(wǎng)絡(luò)設(shè)備比較所述第一寫指針的時(shí)間信息與所述第二寫指針的時(shí)間信息；

所述網(wǎng)絡(luò)設(shè)備在確定所述第一寫指針指示的單元是為在第二寫指針?biāo)甘镜膯卧鎯?chǔ)指令之后再存儲(chǔ)指令的單元時(shí)，將所述網(wǎng)絡(luò)設(shè)備緩存的所述第一隊(duì)列的指針信息中的寫指針更新為所述第一寫指針，包括：

所述網(wǎng)絡(luò)設(shè)備在確定所述第一寫指針的時(shí)間信息早于所述第二寫指針的時(shí)間信息的情況下，將所述網(wǎng)絡(luò)設(shè)備緩存的所述第一隊(duì)列的指針信息中的寫指針更新為所述第一寫指針。

5.如權(quán)利要求4所述的方法，其特征在于，所述網(wǎng)絡(luò)設(shè)備比較所述第一寫指針和所述第二寫指針，包括：

當(dāng)所述隊(duì)列中工作隊(duì)列元素未循環(huán)使用時(shí)，所述網(wǎng)絡(luò)設(shè)備比較第一距離和第二距離，其中所述第一距離是所述第一寫指針與所述讀指針之間間隔的單元的數(shù)目，所述第二距離是所述第二寫指針與所述讀指針之間間隔的單元的數(shù)目；

所述網(wǎng)絡(luò)設(shè)備在確定所述第一寫指針指示的單元是為在第二寫指針?biāo)甘镜膯卧鎯?chǔ)指令之后再存儲(chǔ)指令的單元時(shí)，將所述網(wǎng)絡(luò)設(shè)備緩存的所述第一隊(duì)列的指針信息中的寫指針更新為所述第一寫指針，包括：

所述網(wǎng)絡(luò)設(shè)備在確定所述第一距離大于所述第二距離的情況下，將所述網(wǎng)絡(luò)設(shè)備緩存的所述第一隊(duì)列的指針信息中的寫指針更新為所述第一寫指針。

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

計(jì)算節(jié)點(diǎn)根據(jù)待處理的隊(duì)列數(shù)目以及隊(duì)列信息的大小，確定隊(duì)列信息存儲(chǔ)空間以及所述隊(duì)列信息存儲(chǔ)空間中的第一存儲(chǔ)空間，其中所述計(jì)算節(jié)點(diǎn)通過網(wǎng)絡(luò)設(shè)備實(shí)現(xiàn)和其他計(jì)算節(jié)點(diǎn)基于隊(duì)列對進(jìn)行通信，所述隊(duì)列對包括多個(gè)隊(duì)列，所述計(jì)算節(jié)點(diǎn)能夠直接對所述第一存儲(chǔ)空間進(jìn)行寫入操作；

所述計(jì)算節(jié)點(diǎn)將第一隊(duì)列的寫指針存儲(chǔ)至所述第一存儲(chǔ)空間，其中，所述第一隊(duì)列為所述多個(gè)隊(duì)列中的任一個(gè)隊(duì)列，所述第一隊(duì)列的寫指針用于指示所述第一隊(duì)列中當(dāng)前時(shí)刻允許所述計(jì)算節(jié)點(diǎn)存儲(chǔ)數(shù)據(jù)的最后一個(gè)單元的位置；

所述計(jì)算節(jié)點(diǎn)向所述網(wǎng)絡(luò)設(shè)備發(fā)送所述第一隊(duì)列的標(biāo)識(shí)。