[發(fā)明專利]一種協(xié)同過濾距離的處理方法和系統(tǒng)

有效

• 申請?zhí)枺?/td>: 201210517617.1
• 申請日: 2012-12-05
• 公開（公告）號: CN103049486A
• 公開（公告）日: 2013-04-17
• 發(fā)明（設(shè)計）人: 齊路;何銳邦;唐會軍
• 申請（專利權(quán)）人: 北京奇虎科技有限公司;奇智軟件（北京）有限公司
• 主分類號: G06F17/30
• 分類號: G06F17/30
• 代理公司: 北京潤澤恒知識產(chǎn)權(quán)代理有限公司 11319
• 代理人: 蘇培華

1.一種協(xié)同過濾距離的處理方法，其特征在于，包括：

針對至少兩個計算服務(wù)器，每個參與計算的計算服務(wù)器讀取并存儲相應(yīng)的分塊矩陣數(shù)據(jù)；所述分塊矩陣數(shù)據(jù)為從原始矩陣數(shù)據(jù)中分配給所述計算服務(wù)器的分塊矩陣數(shù)據(jù)；

每個參與計算計算服務(wù)器計算本地的分塊矩陣數(shù)據(jù)，獲得本地分塊矩陣數(shù)據(jù)的協(xié)同過濾距離子矩陣；

每個參與計算的計算服務(wù)器進(jìn)行各計算服務(wù)器間的循環(huán)通信計算，獲得本地分塊矩陣數(shù)據(jù)的協(xié)同過濾距離子矩陣；所述每個參與計算的計算服務(wù)器進(jìn)行各計算服務(wù)器間的循環(huán)通信計算，獲取協(xié)同過濾距離子矩陣具體包括：

針對每個參與計算的計算服務(wù)器，確認(rèn)當(dāng)前計算服務(wù)器對應(yīng)的目的計算服務(wù)器；所述目的計算服務(wù)器用于接收當(dāng)前計算服務(wù)器發(fā)送的本地的矩陣數(shù)據(jù)；

每個參與計算的計算服務(wù)器發(fā)送本地的分塊矩陣數(shù)據(jù)至目的計算服務(wù)器，并接收其他計算服務(wù)器發(fā)送的分塊矩陣數(shù)據(jù)；所述其他計算服務(wù)器為將當(dāng)前計算服務(wù)器確認(rèn)為目的服務(wù)器的計算服務(wù)器；

每個接收到分塊矩陣數(shù)據(jù)的計算服務(wù)器，結(jié)合本地的分塊矩陣數(shù)據(jù)，計算獲得本地的分塊矩陣數(shù)據(jù)和接收到的分塊矩陣數(shù)據(jù)之間的協(xié)同過濾距離子矩陣。

2.如權(quán)利要求1所述的方法，其特征在于，所述針對每個參與計算的計算服務(wù)器，確認(rèn)當(dāng)前計算服務(wù)器對應(yīng)的目的計算服務(wù)器包括：

所述針對每個參與計算的計算服務(wù)器，根據(jù)當(dāng)前的循環(huán)通信計算輪次、當(dāng)前計算服務(wù)器的標(biāo)識和計算服務(wù)器的總個數(shù)，確認(rèn)當(dāng)前計算服務(wù)器對應(yīng)的目的計算服務(wù)器。

3.如權(quán)利要求2所述的方法，其特征在于，所述針對每個參與計算的計算服務(wù)器，根據(jù)當(dāng)前的循環(huán)通信計算輪次、當(dāng)前計算服務(wù)器的標(biāo)識和計算服務(wù)器的總個數(shù)，確認(rèn)當(dāng)前計算服務(wù)器對應(yīng)的目的計算服務(wù)器包括：

將當(dāng)前各計算服務(wù)器間進(jìn)行循環(huán)通信計算的輪次p，與計算服務(wù)器的總個數(shù)N的一半N/2進(jìn)行比較；

如果比較結(jié)果符合預(yù)設(shè)條件，則每個參與計算的計算服務(wù)器，根據(jù)當(dāng)前計算服務(wù)器的標(biāo)識i和輪次p，針對N進(jìn)行取模運(yùn)算得到結(jié)果u，將與u對應(yīng)的計算服務(wù)器作為當(dāng)前計算服務(wù)器的目標(biāo)計算服務(wù)器；

如果比較結(jié)果不符合預(yù)設(shè)條件，則結(jié)束獲得協(xié)同過濾距離子矩陣的計算。

4.如權(quán)利要求3所述的方法，其特征在于，所述將當(dāng)前各計算服務(wù)器間進(jìn)行循環(huán)通信計算的輪次p，與計算服務(wù)器的總個數(shù)N的一半N/2進(jìn)行比較之后還包括：

判斷計算服務(wù)器的總個數(shù)N是否為偶數(shù)；

如果計算服務(wù)器的總個數(shù)N為偶數(shù)，則判斷當(dāng)前通信輪次p是否為最后一輪通信；

如果當(dāng)前輪次p是最后一輪通信，則每個參與計算的計算服務(wù)器，判斷其標(biāo)識i是否小于N/2；

如果標(biāo)識i小于N/2，則標(biāo)識i小于N/2的計算服務(wù)器，進(jìn)入根據(jù)當(dāng)前計算服務(wù)器的標(biāo)識i和輪次p，針對N進(jìn)行取模運(yùn)算得到結(jié)果u，將與u對應(yīng)的計算服務(wù)器作為當(dāng)前計算服務(wù)器的目標(biāo)計算服務(wù)器的過程；

如果標(biāo)識i不小于N/2，則進(jìn)入判斷當(dāng)前各計算服務(wù)器間進(jìn)行循環(huán)通信計算的輪次p，是否小于計算服務(wù)器的總個數(shù)N的一半N/2的過程；

如果當(dāng)前輪次p是最后一輪通信，則進(jìn)入每個參與計算的計算服務(wù)器，根據(jù)當(dāng)前計算服務(wù)器的標(biāo)識i和輪次p，針對N進(jìn)行取模運(yùn)算得到結(jié)果u，將與u對應(yīng)的計算服務(wù)器作為當(dāng)前計算服務(wù)器的目標(biāo)計算服務(wù)器的過程；

如果計算服務(wù)器的總個數(shù)N為奇數(shù)，則進(jìn)入每個參與計算的計算服務(wù)器，根據(jù)當(dāng)前計算服務(wù)器的標(biāo)識i和輪次p，針對N進(jìn)行取模運(yùn)算得到結(jié)果u，將與u對應(yīng)的計算服務(wù)器作為當(dāng)前計算服務(wù)器的目標(biāo)計算服務(wù)器的過程。

5.如權(quán)利要求3或4所述的方法，其特征在于，

當(dāng)所述輪次從0開始計數(shù)，計算服務(wù)器的標(biāo)識i從0開始標(biāo)識，則所述根據(jù)當(dāng)前計算服務(wù)器的標(biāo)識i和輪次p，針對N進(jìn)行取模運(yùn)算得到結(jié)果u包括：

將當(dāng)前計算服務(wù)器的標(biāo)識i和輪次p，代入公式(i+p+1)％N計算得到結(jié)果u；

當(dāng)所述輪次從1開始計數(shù)，計算服務(wù)器的標(biāo)識i從0開始標(biāo)識，則所述根據(jù)當(dāng)前計算服務(wù)器的標(biāo)識i和輪次p，針對N進(jìn)行取模運(yùn)算得到結(jié)果u包括：

將當(dāng)前計算服務(wù)器的標(biāo)識i和輪次p，代入公式(i+p)％N計算得到結(jié)果u。

6.如權(quán)利要求1所述的方法，其特征在于，還包括：

將每個參與計算的計算服務(wù)器計算得到的所有協(xié)同過濾子矩陣進(jìn)行統(tǒng)一轉(zhuǎn)換，獲得完整的協(xié)同過濾矩陣。