[發明專利]一種任務處理、分配、管理、計算的方法以及裝置

在審

• 申請號: 201611223651.2
• 申請日: 2016-12-27
• 公開（公告）號: CN108241534A
• 公開（公告）日: 2018-07-03
• 發明（設計）人: 李文鵬
• 申請（專利權）人: 阿里巴巴集團控股有限公司
• 主分類號: G06F9/50
• 分類號: G06F9/50
• 代理公司: 北京市清華源律師事務所 11441
• 代理人: 沈泳;王永秀

1.一種任務處理方法，其特征在于，包括；

全局主節點為每一分組主節點分配任務，并向每一分組主節點反饋分配的任務信息；

每一分組主節點根據所述全局主節點反饋的任務信息，為分組內的從節點分配子任務；

所述從節點計算所述子任務后，向同分組內的分組主節點反饋基于所述子任務計算后的計算結果；

每一分組主節點將接收到的所述計算結果向所述全局主節點進行轉發，并在每次轉發后向所述全局主節點發送獲取新的任務的請求；

所述全局主節點接收所述分組主節點發送的獲取新的任務的請求后，為所述分組主節點分配新的任務，并向所述分組主節點反饋分配的新的任務信息。

2.根據權利要求1所述的任務處理方法，其特征在于，所述全局主節點為每一分組主節點分配任務，并向每一分組主節點反饋分配的任務信息，包括：

所述全局主節點根據分組主節點的數目獲取對應數目的任務信息；所述任務信息，包括：所述任務的特征標識；

所述全局主節點為每一分組主節點分配獲取的所述任務信息，并向每一分組主節點反饋分配給該分組主節點的任務信息。

3.根據權利要求2所述的任務處理方法，其特征在于，所述每一分組主節點根據所述全局主節點反饋的任務信息，為分組內的從節點分配子任務，包括：

每一分組主節點根據所述全局主節點反饋的任務信息獲取相應的任務；

根據分組內的從節點數目，將所述任務劃分為對應從節點數目的子任務；

將所述子任務均勻分配在所述從節點上。

4.根據權利要求3所述的任務處理方法，其特征在于，所述每一分組主節點將接收到的所述計算結果向所述全局主節點進行轉發，包括:

每一分組主節點，將接收到的分組內所有從節點基于所述子任務計算后的計算結果進行整合；

將整合后的所述計算結果向所述全局主節點進行轉發。

5.根據權利要求1所述的任務處理方法，其特征在于，在所述每一分組主節點根據所述全局主節點反饋的任務信息，為分組內的從節點分配子任務的步驟之后，包括：

啟動計時器記錄時間信息；

在執行所述每一分組主節點將接收到的所述計算結果向所述全局主節點進行轉發的步驟之后，停止所述計時器；

將所述計時器記錄的所述時間信息作為所述任務信息的計算時間。

6.根據權利要求5所述的任務處理方法，其特征在于，在所述停止所述計時器的步驟之后，包括：

所述分組主節點向所述全局主節點發送已記錄的所述任務信息的計算時間。

7.根據權利要求6所述的任務處理方法，其特征在于，在所述分組主節點向所述全局主節點發送已記錄的所述任務信息的計算時間的步驟之后，包括：

所述全局主節點接收所述分組主節點發送的已記錄的所述任務信息的計算時間；

根據已接收的計算時間獲取每一分組主節點計算任務的總計算時間；

針對每一分組主節點獲取計算任務的平均計算時間；

獲取平均計算時間最短的分組主節點；

判斷其他分組主節點的平均計算時間是否大于已獲取的分組主節點計算任務的總計算時間；

若是，則去除所述分組主節點。

8.根據權利要求1-7任意一項所述的任務處理方法，其特征在于，所述全局主節點以及所述分組主節點之間基于消息傳遞接口進行數據通信。

9.根據權利要求8所述的任務處理方法，其特征在于，所述分組主節點是所述從節點中序號的數值最小的從節點。

10.根據權利要求8所述的任務處理方法，其特征在于，所述任務，包括：建模模型特征。