[發明專利]一種數據處理方法、裝置及電子設備

在審

• 申請號: 202010175227.5
• 申請日: 2020-03-13
• 公開（公告）號: CN111400005A
• 公開（公告）日: 2020-07-10
• 發明（設計）人: 王帝;饒鑫淞;張強;王光武
• 申請（專利權）人: 北京搜狐新媒體信息技術有限公司
• 主分類號: G06F9/48
• 分類號: G06F9/48;G06F9/50
• 代理公司: 北京集佳知識產權代理有限公司 11227
• 代理人: 趙煥

本發明提供了一種數據處理方法、裝置及電子設備，在執行待執行任務時，會依據所述任務優先級，對所述待執行任務進行排序，得到排序結果，并按照所述排序結果，將所述待執行任務依次壓棧，得到待處理隊列，依據所述待處理隊列中的待執行任務的順序，依次執行所述待執行任務，由于本發明按照任務優先級進行任務處理，進而可以保證重要的任務能夠可以優先得到資源,并優先執行。

技術領域

本發明涉及數據處理領域，更具體的說，涉及一種數據處理方法、裝置及電子設備。

背景技術

在使用隊列處理任務時，傳統的隊列機制是先進先出(FIFO，First-In-First-Out).缺陷是無法滿足重要任務,優先執行的場景。

而大數據的廣告業務場景下,同一時刻會有大量任務產生，希望重要的任務可以優先得到資源,并優先執行。

發明內容

有鑒于此，本發明提供一種數據處理方法、裝置及電子設備，以解決在同一時刻大量任務產生時,重要的任務能夠可以優先得到資源,并優先執行的問題。

為解決上述技術問題，本發明采用了如下技術方案：

一種數據處理方法，包括：

獲取待執行任務的任務信息；所述任務信息包括任務標號以及任務優先級；所述待執行任務為多個；

依據所述任務優先級，對所述待執行任務進行排序，得到排序結果；

按照所述排序結果，將所述待執行任務依次壓棧，得到待處理隊列；

依據所述待處理隊列中的待執行任務的順序，依次執行所述待執行任務。

可選地，獲取待執行任務的任務信息，包括：

集群中的任一服務器接收客戶端發送的所述待執行任務。

可選地，依據所述任務優先級，對所述待執行任務進行排序，得到排序結果之后，還包括：

計算所述待執行任務的任務標號的哈希值；

依據所述哈希值，采用哈希路由方式將所述待執行任務存儲到所述集群中的一臺服務器中。

可選地，依據所述待處理隊列中的待執行任務的順序，依次執行所述待執行任務，包括：

按照所述待處理隊列中的待執行任務的順序，依次彈出所述待執行任務，以執行所述待執行任務。

可選地，所述任務信息包括任務生成時間；

依據所述任務優先級，對所述待執行任務進行排序，得到排序結果，包括：

在排序過程中，若出現對應的任務優先級相同的至少兩個所述待執行任務，篩選出對應的任務優先級相同的至少兩個所述待執行任務，并作為目標待執行任務；

將所述目標待執行任務按照任務生成時間的先后時間進行排序。

一種數據處理裝置，包括：

信息獲取模塊，用于獲取待執行任務的任務信息；所述任務信息包括任務標號以及任務優先級；所述待執行任務為多個；

排序模塊，用于依據所述任務優先級，對所述待執行任務進行排序，得到排序結果；

壓棧模塊，用于按照所述排序結果，將所述待執行任務依次壓棧，得到待處理隊列；

任務處理模塊，用于依據所述待處理隊列中的待執行任務的順序，依次執行所述待執行任務。

可選地，所述信息獲取模塊用于獲取待執行任務的任務信息時，具體用于：

集群中的任一服務器接收客戶端發送的所述待執行任務。