[發明專利]任務處理方法及系統

在審

• 申請號: 201510149237.0
• 申請日: 2015-03-31
• 公開（公告）號: CN104699542A
• 公開（公告）日: 2015-06-10
• 發明（設計）人: 邵明星;邢常亮;張志偉
• 申請（專利權）人: 北京奇藝世紀科技有限公司
• 主分類號: G06F9/50
• 分類號: G06F9/50
• 代理公司: 北京柏杉松知識產權代理事務所(普通合伙) 11413
• 代理人: 馬敬;項京

技術領域

本發明涉及任務處理技術領域，特別是涉及任務處理方法及系統。

背景技術

隨著科學技術的發展，具有任務處理能力的各種智能電子設備的性能也越來越高。通過將一個復雜的任務拆分為多個子任務，并將子任務分配到多個任務處理節點上進行處理，可以提高任務的處理速度。

具體的過程為：

首先將復雜的任務平均拆分為多個子任務，每個子任務的大小相同；

在任務拆分完畢后，將各個子任務平均分配到各任務處理節點上進行處理，每個任務處理節點上的子任務數量也是相同的。

申請人研究發現：不同的任務處理節點的處理能力并不相同，由于每個任務處理節點上分配的子任務的大小和數量均相同，因此處理能力較高的任務處理節點在處理任務完畢后將處于空閑狀態，以等待處理能力較低的任務處理節點處理完畢，只有全部子任務均處理完畢后，該復雜的任務才處理完畢，這無疑浪費了資源，不利于任務的快速處理。

發明內容

本發明實施例的目的在于提供一種任務處理方法及系統，以實現任務的快速處理。

為達到上述目的，本發明實施例公開了一種任務處理方法，應用于任務分發服務器中，所述任務分發服務器與多個任務處理節點相連接，所述方法包括：

獲得待處理任務，對所述待處理任務進行拆分，獲得多個子任務，其中，任一所述子任務的顆粒度均為預設的多個顆粒度中的一個；

從與所述任務分發服務器相連接的各任務處理節點中選擇第一數目的任務處理節點作為采用節點組，根據存儲的所述采用節點組中各任務處理節點的任務處理能力記錄，將拆分的各子任務分別分配到所述采用節點組中具有與該子任務的顆粒度匹配的任務處理能力的任務處理節點進行處理。

可選的，還包括：

接收相連接的所述多個任務處理節點發送的任務處理能力；

根據所接收的任務處理能力更新任務處理節點的任務處理能力記錄。

可選的，將對所述待處理任務進行拆分，獲得多個子任務后，所述方法還包括：按照顆粒度大小，將拆分得到的各子任務放入分別與不同顆粒度對應的多個任務隊列中；

所述根據存儲的所述采用節點組中各任務處理節點的任務處理能力記錄，將拆分的各子任務分別分配到所述采用節點組中具有與該子任務的顆粒度匹配的任務處理能力的任務處理節點進行處理，包括：

根據存儲的所述采用節點組中各任務處理節點的任務處理能力記錄，將各任務隊列中的子任務分別分配到所述采用節點組中具有與該任務隊列對應的顆粒度匹配的任務處理能力的任務處理節點進行處理。

可選的，所述對所述待處理任務進行拆分，獲得多個子任務，包括：

當所述多個任務隊列中存在處于未滿狀態的任務隊列時，對所述待處理任務進行拆分直至所述多個任務隊列中不再存在處于未滿狀態的任務隊列，得到具有處于未滿狀態的任務隊列對應的顆粒度的多個子任務。

可選的，所述對所述待處理任務進行拆分直至所述多個任務隊列中不再存在處于未滿狀態的任務隊列，包括：

調用第一線程對所述待處理任務進行拆分直至所述多個任務隊列中不再存在處于未滿狀態的任務隊列；

所述將各任務隊列中的子任務分別分配到所述采用節點組中具有與該任務隊列對應的顆粒度匹配的任務處理能力的任務處理節點進行處理，包括：

調用第二線程將各任務隊列中的子任務分別分配到所述采用節點組中具有與該任務隊列對應的顆粒度匹配的任務處理能力的任務處理節點進行處理。

一種任務處理系統，應用于任務分發服務器中，所述任務分發服務器與多個任務處理節點相連接，所述系統包括：任務拆分模塊和任務分配模塊，

所述任務拆分模塊，用于獲得待處理任務，對所述待處理任務進行拆分，獲得多個子任務，其中，任一所述子任務的顆粒度均為預設的多個顆粒度中的一個；

所述任務分配模塊，用于從與所述任務分發服務器相連接的各任務處理節點中選擇第一數目的任務處理節點作為采用節點組，根據存儲的所述采用節點組中各任務處理節點的任務處理能力記錄，將拆分的各子任務分別分配到所述采用節點組中具有與該子任務的顆粒度匹配的任務處理能力的任務處理節點進行處理。

可選的，還包括：處理能力接收模塊和記錄更新模塊，

所述處理能力接收模塊，用于接收相連接的所述多個任務處理節點發送的任務處理能力；

所述記錄更新模塊，用于根據所接收的任務處理能力更新任務處理節點的任務處理能力記錄。