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

在審

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

1.一種任務處理方法，其特征在于，應用于任務分發服務器中，所述任務分發服務器與多個任務處理節點相連接，所述方法包括：

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

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

2.根據權利要求1所述的方法，其特征在于，還包括：

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

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

3.根據權利要求1或2所述的方法，其特征在于，將對所述待處理任務進行拆分，獲得多個子任務后，所述方法還包括：按照顆粒度大小，將拆分得到的各子任務放入分別與不同顆粒度對應的多個任務隊列中；

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

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

4.根據權利要求3所述的方法，其特征在于，所述對所述待處理任務進行拆分，獲得多個子任務，包括：

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

5.根據權利要求4所述的方法，其特征在于，所述對所述待處理任務進行拆分直至所述多個任務隊列中不再存在處于未滿狀態的任務隊列，包括：

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

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

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

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

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

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

7.根據權利要求6所述的系統，其特征在于，還包括：處理能力接收模塊和記錄更新模塊，

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

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

8.根據權利要求6或7所述的系統，其特征在于，所述系統還包括：入列模塊，用于在所述任務拆分模塊將對所述待處理任務進行拆分，獲得多個子任務后，按照顆粒度大小，將拆分得到的各子任務放入分別與不同顆粒度對應的多個任務隊列中；

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