2019獨角獸企業重金招聘Python工程師標準>>>

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

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

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

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

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

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

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

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

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

轉載于:https://my.oschina.net/fourinone/blog/70178

總結

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

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。