[發(fā)明專利]一種任務(wù)處理方法、裝置及系統(tǒng)

有效

• 申請?zhí)枺?/td>: 201610681355.0
• 申請日: 2016-08-17
• 公開（公告）號: CN107766129B
• 公開（公告）日: 2021-04-16
• 發(fā)明（設(shè)計）人: 吳崢
• 申請（專利權(quán)）人: 北京金山云網(wǎng)絡(luò)技術(shù)有限公司;北京金山云科技有限公司
• 主分類號: G06F9/48
• 分類號: G06F9/48
• 代理公司: 北京柏杉松知識產(chǎn)權(quán)代理事務(wù)所(普通合伙) 11413
• 代理人: 馬敬;項京

1.一種任務(wù)處理方法，應(yīng)用于任務(wù)調(diào)度節(jié)點，所述方法包括：

獲取目標任務(wù)；

估算處理所述目標任務(wù)的處理時間，根據(jù)所述處理時間，確定所述目標任務(wù)的任務(wù)類型；

將所述目標任務(wù)添加至所述任務(wù)類型對應(yīng)的任務(wù)隊列，以使每個任務(wù)處理節(jié)點根據(jù)自身處理任務(wù)的目標任務(wù)類型及任務(wù)數(shù)量信息表，從所有任務(wù)隊列中確定目標任務(wù)隊列；在所述目標任務(wù)隊列中獲取任務(wù)，對所獲取的任務(wù)進行處理，其中，所述目標任務(wù)類型是由所述任務(wù)調(diào)度節(jié)點確定的，所述任務(wù)數(shù)量信息表由所述任務(wù)調(diào)度節(jié)點配置，用于存儲各個任務(wù)隊列的任務(wù)數(shù)量；

其中，所述目標任務(wù)類型是從所述任務(wù)調(diào)度節(jié)點存儲的優(yōu)先處理信息表中獲得的，所述優(yōu)先處理信息表用于存儲任務(wù)處理節(jié)點的標識信息、處理的用戶信息及處理任務(wù)的目標任務(wù)類型之間的對應(yīng)關(guān)系；

所述目標任務(wù)類型是任務(wù)處理節(jié)點確定自身的標識信息在優(yōu)先處理信息表中，且根據(jù)所述優(yōu)先處理信息表，判斷存在優(yōu)先處理的用戶時，根據(jù)所述優(yōu)先處理信息表中記錄的信息，確定的自身處理任務(wù)的目標任務(wù)類型；

所述目標任務(wù)隊列包括第一用戶的目標任務(wù)類型對應(yīng)的任務(wù)隊列和第二用戶的第二任務(wù)類型對應(yīng)的任務(wù)隊列；

其中，所述第一用戶為任務(wù)處理節(jié)點根據(jù)所述目標任務(wù)類型、所述任務(wù)數(shù)量信息表及優(yōu)先處理用戶組，判斷優(yōu)先處理用戶組的目標任務(wù)類型對應(yīng)的任務(wù)總數(shù)量不為零時，根據(jù)所述任務(wù)數(shù)量信息表及所述優(yōu)先處理用戶組，確定的獲取任務(wù)的第一用戶；所述優(yōu)先處理用戶組是任務(wù)處理節(jié)點確定自身的標識信息在優(yōu)先處理信息表中，且根據(jù)所述優(yōu)先處理信息表，判斷存在優(yōu)先處理的用戶時，根據(jù)所述優(yōu)先處理信息表中記錄的信息確定的，其中，所述優(yōu)先處理用戶組包括至少一個用戶；

所述第二用戶為任務(wù)處理節(jié)點根據(jù)所述目標任務(wù)類型、所述任務(wù)數(shù)量信息表及所述優(yōu)先處理用戶組，判斷優(yōu)先處理用戶組的目標任務(wù)類型對應(yīng)的任務(wù)總數(shù)量為零時，根據(jù)所述任務(wù)數(shù)量信息表及所述優(yōu)先處理用戶組，確定的獲取任務(wù)的第二用戶；所述第二任務(wù)類型為任務(wù)處理節(jié)點根據(jù)所述目標任務(wù)類型、所述任務(wù)數(shù)量信息表及所述優(yōu)先處理用戶組，判斷優(yōu)先處理用戶組的目標任務(wù)類型對應(yīng)的任務(wù)總數(shù)量為零時，根據(jù)所述任務(wù)數(shù)量信息表，在所述目標任務(wù)類型之外的其他任務(wù)類型中確定的。

2.根據(jù)權(quán)利要求1所述的方法，其特征在于，將所述目標任務(wù)添加至所述任務(wù)類型對應(yīng)的任務(wù)隊列，包括：

根據(jù)所述任務(wù)類型及所述目標任務(wù)的目標用戶，將所述目標任務(wù)添加至所述目標用戶對應(yīng)的任務(wù)隊列。

3.根據(jù)權(quán)利要求2所述的方法，其特征在于，所述方法還包括：

在檢測到至少一種以下情況時，更新所述優(yōu)先處理信息表：

新增任務(wù)處理節(jié)點；

更新任一任務(wù)處理節(jié)點處理的用戶信息；

更新任一任務(wù)處理節(jié)點處理的任務(wù)類型。

4.根據(jù)權(quán)利要求2所述的方法，其特征在于，在所述將所述目標任務(wù)添加至所述目標用戶對應(yīng)的任務(wù)隊列之后，所述方法還包括：

設(shè)置所述任務(wù)數(shù)量信息表針對第一線程為可寫入狀態(tài)，設(shè)置所述任務(wù)數(shù)量信息表針對除所述第一線程之外的其他線程為不可寫入狀態(tài)，通過調(diào)用所述第一線程更新所述任務(wù)數(shù)量信息表，設(shè)置更新后的任務(wù)數(shù)量信息表針對所述第一線程為不可寫入狀態(tài)。

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

按照預設(shè)的第一時間間隔掃描各個任務(wù)隊列的隊列長度；

根據(jù)掃描的結(jié)果，更新所述任務(wù)數(shù)量信息表。

6.根據(jù)權(quán)利要求5所述的方法，其特征在于，所述根據(jù)掃描的結(jié)果，更新所述任務(wù)數(shù)量信息表，包括：

設(shè)置所述任務(wù)數(shù)量信息表針對第二線程為可寫入狀態(tài)，設(shè)置所述任務(wù)數(shù)量信息表針對除所述第二線程之外的其他線程為不可寫入狀態(tài)，通過調(diào)用所述第二線程根據(jù)掃描結(jié)果并根據(jù)掃描結(jié)果更新所述任務(wù)數(shù)量信息表；

設(shè)置更新后的任務(wù)數(shù)量信息表針對所述第二線程為不可寫入狀態(tài)。