[發(fā)明專利]分布式并行計算方法、裝置及系統(tǒng)

有效

• 申請?zhí)枺?/td>: 201110299597.0
• 申請日: 2011-10-08
• 公開（公告）號: CN103034475A
• 公開（公告）日: 2013-04-10
• 發(fā)明（設(shè)計）人: 簡勤;郭正平;王全禮;曾東;廖勤耘;肖巍;楊俊拯;鄭長松
• 申請（專利權(quán)）人: 中國移動通信集團四川有限公司
• 主分類號: G06F9/38
• 分類號: G06F9/38;G06F9/50
• 代理公司: 北京德琦知識產(chǎn)權(quán)代理有限公司 11018
• 代理人: 王一斌;王琦

1.一種分布式并行計算方法，其特征在于，包括：

接收兩個以上步驟處理器發(fā)送的步驟請求消息，所述步驟請求消息用于請求待處理任務(wù)中的待處理執(zhí)行步驟，并且，所述步驟請求消息中包括所述步驟處理器的步驟處理類型；

如果所述步驟處理類型對應(yīng)的執(zhí)行步驟依賴于所述待處理任務(wù)中的已處理執(zhí)行步驟，向所述步驟處理器發(fā)送步驟響應(yīng)消息，所述步驟響應(yīng)消息中包括所述待處理執(zhí)行步驟以及所述待處理執(zhí)行步驟的唯一標(biāo)識；

接收所述步驟處理器發(fā)送的所述待處理執(zhí)行步驟的步驟處理結(jié)果，所述步驟處理結(jié)果中包括所述待處理執(zhí)行步驟的唯一標(biāo)識；

根據(jù)所述步驟處理結(jié)果，生成所述待處理任務(wù)的任務(wù)處理結(jié)果。

2.根據(jù)權(quán)利要求1所述的方法，其特征在于，還包括：

向服務(wù)端任務(wù)容器發(fā)送任務(wù)請求消息，所述任務(wù)請求消息用于請求所述待處理任務(wù)；

接收所述服務(wù)端任務(wù)容器回復(fù)的任務(wù)響應(yīng)消息，所述任務(wù)響應(yīng)消息中包括所述待處理任務(wù)，其中，所述待處理任務(wù)中包括兩個以上預(yù)先分解的具有依賴關(guān)系的所述待處理執(zhí)行步驟。

3.根據(jù)權(quán)利要求2所述的方法，其特征在于，在所述生成所述待處理任務(wù)的任務(wù)處理結(jié)果之后，還包括：

將所述任務(wù)處理結(jié)果發(fā)送給所述服務(wù)端任務(wù)容器。

4.根據(jù)權(quán)利要求3所述的方法，其特征在于，具體包括：

在向所述步驟處理器發(fā)送步驟響應(yīng)消息之后，將所述待處理執(zhí)行步驟標(biāo)記為正在處理執(zhí)行步驟；

在接收到所述步驟處理結(jié)果之后，將所述正在處理執(zhí)行步驟標(biāo)記為已處理執(zhí)行步驟。

5.根據(jù)權(quán)利要求2所述的方法，其特征在于，所述向服務(wù)端任務(wù)容器發(fā)送任務(wù)請求消息包括：

檢查自身包括的所述待處理任務(wù)的任務(wù)數(shù)量；

如果所述任務(wù)數(shù)量少于預(yù)設(shè)閾值，則向所述服務(wù)端任務(wù)容器發(fā)送所述任務(wù)請求消息。

6.根據(jù)權(quán)利要求2所述的方法，其特征在于，在所述向服務(wù)端任務(wù)容器發(fā)送任務(wù)請求消息之前，還包括：

向所述服務(wù)端任務(wù)容器發(fā)送注冊請求消息；

接收所述服務(wù)端任務(wù)容器回復(fù)的注冊響應(yīng)消息。

7.一種分布式并行計算方法，其特征在于，包括：

向執(zhí)行端任務(wù)容器發(fā)送步驟請求消息，所述步驟請求消息用于請求待處理任務(wù)中的待處理執(zhí)行步驟，并且，所述步驟請求消息中包括步驟處理類型；

接收所述執(zhí)行端任務(wù)容器回復(fù)的步驟響應(yīng)消息，所述步驟響應(yīng)消息中包括所述待處理執(zhí)行步驟以及所述待處理執(zhí)行步驟的唯一標(biāo)識；

處理所述待處理執(zhí)行步驟，得到所述待處理執(zhí)行步驟的步驟處理結(jié)果；

將所述步驟處理結(jié)果發(fā)送給所述執(zhí)行端任務(wù)容器。

8.根據(jù)權(quán)利要求7所述的方法，其特征在于，還包括：

記錄接收到所述步驟響應(yīng)消息的時間，并且記錄將所述步驟處理結(jié)果發(fā)送給所述執(zhí)行端任務(wù)容器的時間；

根據(jù)所述接收到所述步驟響應(yīng)消息的時間和所述將所述步驟處理結(jié)果發(fā)送給所述執(zhí)行端任務(wù)容器的時間，計算所述將所述步驟處理結(jié)果發(fā)送給所述執(zhí)行端任務(wù)容器的時間與所述接收到所述步驟響應(yīng)消息的時間的的時間差值，得到所述待處理執(zhí)行步驟的處理時間。

9.根據(jù)權(quán)利要求8所述的方法，其特征在于，所述處理所述待處理執(zhí)行步驟，還包括：根據(jù)所述待處理執(zhí)行步驟的處理時間，按照預(yù)定的調(diào)整策略調(diào)整在處理所述待處理執(zhí)行步驟時使用的計算資源。

10.根據(jù)權(quán)利要求7所述的方法，其特征在于，在向執(zhí)行端任務(wù)容器發(fā)送步驟請求消息之前，還包括：

向所述執(zhí)行端任務(wù)容器發(fā)送注冊請求消息；

接收所述執(zhí)行端任務(wù)容器回復(fù)的注冊響應(yīng)消息。