[發明專利]執行計算任務的方法和裝置

在審

• 申請號: 201811473744.X
• 申請日: 2018-12-04
• 公開（公告）號: CN111274067A
• 公開（公告）日: 2020-06-12
• 發明（設計）人: 姚思雨
• 申請（專利權）人: 北京京東尚科信息技術有限公司;北京京東世紀貿易有限公司
• 主分類號: G06F11/20
• 分類號: G06F11/20
• 代理公司: 中原信達知識產權代理有限責任公司 11219
• 代理人: 張一軍;李陽

1.一種執行計算任務的方法，其特征在于，包括：

向主節點發送計算指令，所述計算指令攜帶計算任務，并接收所述主節點返回的執行所述計算任務所生成的原數據；

若監測到所述主節點無法執行所述計算任務，則按照預設規則從從節點中選擇出新的主節點；

向所述新的主節點發送新的計算指令，所述新的計算指令攜帶所述原數據，并接收所述新的主節點返回的根據所述原數據繼續執行所述計算任務所生成的原數據。

2.根據權利要求1所述的方法，其特征在于，在向主節點發送計算指令之后，所述方法還包括：每隔一段時間向所述主節點發送記錄數據指令；

接收所述主節點返回的執行所述計算任務所生成的原數據，包括：

接收所述主節點根據所述記錄數據指令發送的執行所述計算任務所生成的原數據。

3.根據權利要求2所述的方法，其特征在于，所述方法還包括：預先按照各個從節點性能從高到低的順序對所述各個從節點進行排序；

按照預設規則從從節點中選擇出新的主節點，包括：

將排序中排在首位的從節點作為新的主節點。

4.根據權利要求1所述的方法，其特征在于，監測到所述主節點無法執行所述計算任務，包括：

向所述主節點發送監測指令，若在預設時間內未接收到所述主節點根據所述監測指令返回的響應消息，則確認所述主節點無法執行所述計算任務。

5.根據權利要求1所述的方法，其特征在于，在向所述新的主節點發送新的計算指令之后，所述方法還包括：

接收所述新的主節點執行完所述計算任務返回的結束指令，根據所述結束指令清除所述原數據。

6.一種執行計算任務的裝置，其特征在于，包括：

第一收發單元，用于向主節點發送計算指令，所述計算指令攜帶計算任務，并接收所述主節點返回的執行所述計算任務所生成的原數據；

處理單元，用于若監測到所述主節點無法執行所述計算任務，則按照預設規則從從節點中選擇出新的主節點；

第二收發單元，用于向所述新的主節點發送新的計算指令，所述新的計算指令攜帶所述原數據，并接收所述新的主節點返回的根據所述原數據繼續執行所述計算任務所生成的原數據。

7.根據權利要求6所述的裝置，其特征在于，所述裝置還包括：

預處理單元，用于在向主節點發送計算指令之后，每隔一段時間向所述主節點發送記錄數據指令；

所述第一收發單元具體用于：

接收所述主節點根據所述記錄數據指令發送的執行所述計算任務所生成的原數據。

8.根據權利要求7所述的裝置，其特征在于，所述預處理單元具體還用于：

預先按照各個從節點性能從高到低的順序對所述各個從節點進行排序；

所述處理單元具體用于：

將排序中排在首位的從節點作為新的主節點。

9.根據權利要求6所述的裝置，其特征在于，所述處理單元具體還用于：

向所述主節點發送監測指令，若在預設時間內未接收到所述主節點根據所述監測指令返回的響應消息，則確認所述主節點無法執行所述計算任務。

10.根據權利要求6所述的裝置，其特征在于，所述處理單元具體還用于：

在向所述新的主節點發送新的計算指令之后，若接收到所述新的主節點執行完所述計算任務返回的結束指令，則根據所述結束指令清除所述原數據。

11.一種電子設備，其特征在于，包括：

一個或多個處理器；

存儲裝置，用于存儲一個或多個程序，

當所述一個或多個程序被所述一個或多個處理器執行，使得所述一個或多個處理器實現如權利要求1-5中任一所述的方法。

12.一種計算機可讀介質，其上存儲有計算機程序，其特征在于，所述程序被處理器執行時實現如權利要求1-5中任一所述的方法。