2019獨角獸企業(yè)重金招聘Python工程師標(biāo)準(zhǔn)>>>

假設(shè)你已經(jīng)看過 分布式計算上手demo指南,對fourinone基本的分布式并行計算方式有了初步了解。

本demo演示了工頭和幾個工人之間互相sayhello的簡單例子，從而了解到集群計算節(jié)點之間互相交互，以及工頭批量處理和工人互相傳遞數(shù)據(jù)（多用于合并）的功能。

HelloCtor：是一個工頭實現(xiàn)，它實現(xiàn)giveTask接口，它首先通過getWaitingWorkers獲取到一個線上工人的集合，然后通過doTaskBatch進行批量任務(wù)處理，這里工頭向每個工人說句“hello”打招呼。doTaskBatch有兩個參數(shù)，分別是工人集合和任務(wù)，該方法會等到每個工人都執(zhí)行完該任務(wù)才返回，因此使用doTaskBatch不需要輪循檢查每一個調(diào)用結(jié)果，它是一個批量處理。為了節(jié)省資源利用，工頭運行結(jié)束后不會退出jvm，可以使用exit方法強行退出。

HelloWorker：是一個工人實現(xiàn)，這里它實現(xiàn)了doTask和receive接口，分別用于被工頭和其他工人調(diào)用。doTask實現(xiàn)了被工頭調(diào)用執(zhí)行任務(wù)的內(nèi)容，這里該工人向工頭和其他工人“say hello”招呼，并告訴自己的名字。它通過getWorkerElse獲取到集群中除自己以外的其他工人，getWorkerElse可以傳入一個參數(shù)指定工人類型，然后依次調(diào)用其他工人的receive方法傳遞信息。receive實現(xiàn)了該工人被其他工人調(diào)用的處理內(nèi)容，參數(shù)WareHouse由其他工人傳入，它返回一個boolean值，可以代表接收和處理是否成功。這里簡單的將其他工人的問候輸出。

運行步驟：
1、啟動ParkServerDemo（它的IP端口已經(jīng)在配置文件的PARK部分的SERVERS指定）
2、運行一到多個HelloWorker（傳入3個參數(shù)，依次是該工人的名字、ip或者域名、端口）
3、運行HelloCtor

注意：doTaskBatch會等集群中最慢的一個工人完成任務(wù)才統(tǒng)一返回，如果希望能讓機器運行快的機器在完成后能馬上又分配新的任務(wù)，而不用等待，實現(xiàn)能者多勞，可以不使用doTaskBatch，而采用逐個調(diào)用每個工人的doTask并輪循結(jié)果狀態(tài)的方式實現(xiàn)，具體請參考 分布式計算完整demo

實際上，工頭對工人的調(diào)用是通過doTask，工人對工人的調(diào)用是通過receive。doTask用于工頭分配任務(wù)，receive多用于工人之間合并傳遞數(shù)據(jù)，每個工人都可以同時向其他工人傳遞數(shù)據(jù)，并接收來自其他工人的數(shù)據(jù)。集群中每個工人向其他工人傳遞數(shù)據(jù)都完成了，也就意味著每個工人都接收完成了。

附件是demo
企鵝群:241116021
郵箱:Fourinone@yeah.net

開發(fā)包及指南下載地址：
http://www.skycn.com/soft/68321.html

轉(zhuǎn)載于:https://my.oschina.net/fourinone/blog/70178

總結(jié)

以上是生活随笔為你收集整理的分布式计算互相sayhello的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。