[發明專利]一種分布式計算方法

在審

• 申請號: 201611101654.9
• 申請日: 2016-11-29
• 公開（公告）號: CN106600220A
• 公開（公告）日: 2017-04-26
• 發明（設計）人: 葉飛;殷作偉;張岑
• 申請（專利權）人: 葉飛
• 主分類號: G06Q10/10
• 分類號: G06Q10/10
• 代理公司: 暫無信息
• 代理人: 暫無信息

技術領域

本發明屬于計算技術領域，具體涉及一種分布式計算方法。

背景技術

隨著計算技術的發展，有些應用需要非常巨大的計算能力才能完成，如果采用傳統的集中式計算，需要耗費相當長的時間來完成。分布式計算將該應用分解成許多小的部分，分配給多臺計算機進行處理。這樣可以節約整體計算時間，大大提高計算效率。

但是，雖然現有的分布式計算已經大大提高了計算效率，但是在實際應用中仍然面臨一些問題：由于要將應用分解成小部分，再分配給多臺計算機進行處理，因此便存在分配是否合理的問題，另外，對項目方來說，參加分布式計算的志愿者畢竟不是項目方自己的人員，并不是全體可信任，可能存在計算錯誤、惡意作弊等問題。

鑒于此，提出一種分布式計算方法本發明所要研究的課題。

發明內容

針對上述問題，本發明的目的在于提供一種分布式計算系統和分布式計算方法，旨在解決現有技術中存在任務分配不合理、計算錯誤以及惡意作弊等問題。

為了實現上述目的，本發明采用以下技術方案：一種分布式計算方法，包括以下步驟：

S1：從等待的隊列中取出待分配的新任務，將其放入當前工作組；

S2：將該新任務按照計算量平均分割成若干個任務單元，每個任務單元標記為Ai，其中，i＝1、2、3……n，其中A1＝A2＝A3……＝An；

S3：提取其中之一的任務單元，并計算出運算單個任務單元所需的時間t；

S4：統計該新任務中任務單元的個數n；

S5：根據該新任務中任務單元的個數n以及計算每個任務單元所需的時間t，統計出一響應閾值

S6：查找當前可用的計算裝置，并將當前所用可用的計算裝置集中至一集合S中，并移除當前所有不可用的計算裝置；

S7：統計每個計算裝置的響應時間T’，并將集合S中每個計算裝置的響應時間T’的值分別與響應閾值相比較，判定T’的值是否小于閾值若Ti’的值小于或等于閾值則將該響應時間Ti’所對應的計算裝置放入另一集合M中，否則將不放入集合M中；

S8：統計集合M中計算裝置的個數N；

S9：判定集合M中每個計算裝置的當前負載，并計算出每個計算裝置能夠承擔的剩余負載L：

S10：將每個計算裝置的剩余負載L平均分割成若干單元負載Ly，其中，y＝i＝1、2、3……m，其中L1＝L2＝L3……＝Ln，并統計每個計算裝置中單元負載的個數m；

S11：將所述待分配的新任務按照的比例給對應的計算裝置分配計算任務。

作為本發明的進一步改進，在所述S11后，還包括一檢測步驟S12：當需要進行下次分布式計算的時，對被移除集合S的計算裝置進行重新檢測，在檢測結果表明計算裝置可用的情況下，將該計算裝置放入集合S中，等待下次使用。

作為本發明的進一步改進，所述分布式計算方法還包括容錯步驟，將在計算過程進行時，出現響應慢或沒有響應的計算裝置移除集合M，計算移出集合M的計算裝置的個數b，并重新按照的比例給對應的計算裝置沖重新分配計算任務。

作為本發明的進一步改進，所述分布式計算方法還包括定時檢查步驟S13，對所有計算裝置進行定時檢查，以確保在任務分配時集合S中的計算裝置可用。

作為本發明的進一步改進，在被選擇的計算裝置在預定時間后未作出響應的情況下，對于被分配給該計算裝置的若干任務單元，重新分配計算裝置。

作為本發明的進一步改進，根據所述待分配的新任務路徑對該新任務進行分配處理，當分配任務完成后，自動生成一任務分配報告，并通過該任務分配報告輸出處理結果。

本發明工作原理以及效果如下：

本發明涉及一種分布式計算方法，從等待的隊列中取出待分配的新任務；將該新任務平均分割成若干個任務單元，計算單個任務單元所需的時間t；根據該個數n及時間t統計出響應閾值T；將當前所用可用的計算裝置集中至集合S中；統計每個計算裝置的響應時間T’，并將集合S中每個計算裝置的T’與T相比較，若Ti’小于或等于T，則將該Ti’所對應的計算裝置放入另一集合M中；統計集合M中計算裝置的個數N；判定集合M中每個計算裝置的當前負載，計算出每個計算裝置能承擔的剩余負載：將每個計算裝置的剩余負載平均分割成若干單元負載；將待分配的新任務按照比例給對應的計算裝置分配計算任務。本發明可靠性好，能夠有效確保任務的合理分配。