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

在審

• 申請?zhí)枺?/td>: 201611223651.2
• 申請日: 2016-12-27
• 公開（公告）號: CN108241534A
• 公開（公告）日: 2018-07-03
• 發(fā)明（設(shè)計）人: 李文鵬
• 申請（專利權(quán)）人: 阿里巴巴集團控股有限公司
• 主分類號: G06F9/50
• 分類號: G06F9/50
• 代理公司: 北京市清華源律師事務(wù)所 11441
• 代理人: 沈泳;王永秀

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

全局主節(jié)點為每一分組主節(jié)點分配任務(wù)，并向每一分組主節(jié)點反饋分配的任務(wù)信息；

每一分組主節(jié)點根據(jù)所述全局主節(jié)點反饋的任務(wù)信息，為分組內(nèi)的從節(jié)點分配子任務(wù)；

所述從節(jié)點計算所述子任務(wù)后，向同分組內(nèi)的分組主節(jié)點反饋基于所述子任務(wù)計算后的計算結(jié)果；

每一分組主節(jié)點將接收到的所述計算結(jié)果向所述全局主節(jié)點進(jìn)行轉(zhuǎn)發(fā)，并在每次轉(zhuǎn)發(fā)后向所述全局主節(jié)點發(fā)送獲取新的任務(wù)的請求；

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

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

所述全局主節(jié)點根據(jù)分組主節(jié)點的數(shù)目獲取對應(yīng)數(shù)目的任務(wù)信息；所述任務(wù)信息，包括：所述任務(wù)的特征標(biāo)識；

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

3.根據(jù)權(quán)利要求2所述的任務(wù)處理方法，其特征在于，所述每一分組主節(jié)點根據(jù)所述全局主節(jié)點反饋的任務(wù)信息，為分組內(nèi)的從節(jié)點分配子任務(wù)，包括：

每一分組主節(jié)點根據(jù)所述全局主節(jié)點反饋的任務(wù)信息獲取相應(yīng)的任務(wù)；

根據(jù)分組內(nèi)的從節(jié)點數(shù)目，將所述任務(wù)劃分為對應(yīng)從節(jié)點數(shù)目的子任務(wù)；

將所述子任務(wù)均勻分配在所述從節(jié)點上。

4.根據(jù)權(quán)利要求3所述的任務(wù)處理方法，其特征在于，所述每一分組主節(jié)點將接收到的所述計算結(jié)果向所述全局主節(jié)點進(jìn)行轉(zhuǎn)發(fā)，包括:

每一分組主節(jié)點，將接收到的分組內(nèi)所有從節(jié)點基于所述子任務(wù)計算后的計算結(jié)果進(jìn)行整合；

將整合后的所述計算結(jié)果向所述全局主節(jié)點進(jìn)行轉(zhuǎn)發(fā)。

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

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

在執(zhí)行所述每一分組主節(jié)點將接收到的所述計算結(jié)果向所述全局主節(jié)點進(jìn)行轉(zhuǎn)發(fā)的步驟之后，停止所述計時器；

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

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

所述分組主節(jié)點向所述全局主節(jié)點發(fā)送已記錄的所述任務(wù)信息的計算時間。

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

所述全局主節(jié)點接收所述分組主節(jié)點發(fā)送的已記錄的所述任務(wù)信息的計算時間；

根據(jù)已接收的計算時間獲取每一分組主節(jié)點計算任務(wù)的總計算時間；

針對每一分組主節(jié)點獲取計算任務(wù)的平均計算時間；

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

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

若是，則去除所述分組主節(jié)點。

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

9.根據(jù)權(quán)利要求8所述的任務(wù)處理方法，其特征在于，所述分組主節(jié)點是所述從節(jié)點中序號的數(shù)值最小的從節(jié)點。

10.根據(jù)權(quán)利要求8所述的任務(wù)處理方法，其特征在于，所述任務(wù)，包括：建模模型特征。