[發(fā)明專利]隊列控制方法及裝置

在審

• 申請?zhí)枺?/td>: 201810274801.5
• 申請日: 2018-03-29
• 公開（公告）號: CN110321215A
• 公開（公告）日: 2019-10-11
• 發(fā)明（設(shè)計）人: 單衛(wèi)華;董陽
• 申請（專利權(quán)）人: 華為技術(shù)有限公司
• 主分類號: G06F9/50
• 分類號: G06F9/50;G06F9/54
• 代理公司: 廣州三環(huán)專利商標(biāo)代理有限公司 44202
• 代理人: 郝傳鑫;熊永強

1.一種隊列控制方法，其特征在于，所述方法包括：

接收生產(chǎn)者線程發(fā)送的第一數(shù)據(jù)存儲請求；

確定所述第一數(shù)據(jù)存儲請求對應(yīng)的分片隊列；

將所述第一數(shù)據(jù)存儲請求所請求存儲的第一數(shù)據(jù)存儲到所述分片隊列中；

接收消費者線程發(fā)送的數(shù)據(jù)獲取請求；

根據(jù)所述數(shù)據(jù)獲取請求從所述分片隊列中獲取所述第一數(shù)據(jù)；

接收所述生產(chǎn)者線程發(fā)送的第二數(shù)據(jù)存儲請求；

將所述第二數(shù)據(jù)存儲請求所請求存儲的第二數(shù)據(jù)存儲到所述分片隊列中。

2.如權(quán)利要求1所述的方法，其特征在于，所述將所述第一數(shù)據(jù)存儲請求所請求存儲的第一數(shù)據(jù)存儲到所述分片隊列中之前，還包括：

建立所述生產(chǎn)者線程和所述分片隊列的關(guān)聯(lián)關(guān)系，所述關(guān)聯(lián)關(guān)系用于指示所述生產(chǎn)者線程獨占所述分片隊列的使用權(quán)。

3.如權(quán)利要求2所述的方法，其特征在于，所述建立所述生產(chǎn)者線程和所述分片隊列的關(guān)聯(lián)關(guān)系，包括：

在所述生產(chǎn)者線程的線程上下文中記錄所述分片隊列的隊列標(biāo)識信息；或者

在所述分片隊列中存儲所述生產(chǎn)者線程的線程標(biāo)識信息。

4.如權(quán)利要求1所述的方法，其特征在于，所述方法還包括：

接收所述生產(chǎn)者線程發(fā)送的第三數(shù)據(jù)存儲請求；

確定所述第三數(shù)據(jù)存儲請求對應(yīng)的分片隊列為所述分片隊列；

當(dāng)所述分片隊列的當(dāng)前數(shù)據(jù)量達到所述分片隊列的預(yù)設(shè)容量時，將所述分片隊列從第一分片隊列集合移動至第二分片隊列集合，所述第一分片隊列集合包含當(dāng)前數(shù)據(jù)量為零的分片隊列，所述第二分片隊列集合包含當(dāng)前數(shù)據(jù)量達到其預(yù)設(shè)容量的分片隊列；

在所述第一分片隊列集合中重新選取一個分片隊列；

將所述第三數(shù)據(jù)存儲請求所請求存儲的第三數(shù)據(jù)存儲到所述重新選取的分片隊列中。

5.如權(quán)利要求4所述的方法，其特征在于，所述確定所述第一數(shù)據(jù)存儲請求對應(yīng)的分片隊列之前，還包括：

設(shè)置參數(shù)信息，所述參數(shù)信息包括在所述第一分片隊列集合中待創(chuàng)建的分片隊列的數(shù)量以及所述預(yù)設(shè)容量；

在所述第一分片隊列集合中創(chuàng)建滿足所述數(shù)量的分片隊列，并為創(chuàng)建的各個分片隊列分配滿足所述預(yù)設(shè)容量的內(nèi)存資源。

6.如權(quán)利要求4所述的方法，其特征在于，所述方法還包括：

在獲取存儲在所述分片隊列中的所有數(shù)據(jù)之后，確定所述分片隊列的當(dāng)前數(shù)據(jù)量為零；

將所述分片隊列從所述第二分片隊列集合移動至所述第一分片隊列集合。

7.如權(quán)利要求1所述的方法，其特征在于，所述分片隊列所屬的分片隊列集合包括至少一個分片隊列；

所述方法還包括：

在滿足預(yù)設(shè)調(diào)整條件時，動態(tài)調(diào)整單位時間內(nèi)用于存儲數(shù)據(jù)的分片隊列的數(shù)量總和，單位時間內(nèi)用于獲取數(shù)據(jù)的分片隊列的數(shù)量總和，或者各個分片隊列的預(yù)設(shè)容量中的至少一種。

8.如權(quán)利要求7所述的方法，其特征在于，所述在滿足預(yù)設(shè)調(diào)整條件時，動態(tài)調(diào)整單位時間內(nèi)用于存儲數(shù)據(jù)的分片隊列的數(shù)量總和，單位時間內(nèi)用于獲取數(shù)據(jù)的分片隊列的數(shù)量總和，或者各個分片隊列的預(yù)設(shè)容量中的至少一種包括：

從最近一次動態(tài)調(diào)整開始經(jīng)過預(yù)設(shè)時間段之后，確定滿足所述預(yù)設(shè)調(diào)整條件；或者

當(dāng)存在當(dāng)前數(shù)據(jù)量大于零的分片隊列，且不存在當(dāng)前數(shù)據(jù)量達到其預(yù)設(shè)容量的分片隊列時，確定滿足所述預(yù)設(shè)調(diào)整條件。