MATLAB并行計算簡介(是幾個機子并行的).ppt

Windows環(huán)境下的分布式并行計算平臺搭建,MATLAB并行平臺底層架構(gòu) MATLAB并行平臺搭建 并行程序的編寫與實例 實驗室MATLAB并行集群,1,MATLAB并行平臺底層架構(gòu)（一）,并行平臺上的三種角色 “警察”：維護整個平臺。 (mdce：底層維護和通信進程) “老板”：接任務(wù)，雇傭工人并分配任務(wù)。 （jobmanager：負責(zé)對計算機資源的管理， 接收用戶發(fā)過來的并行計算任務(wù)。） “工人”：努力工作。 （worker：工作進程）,我負責(zé)維護整個并行平臺,接生意咯，客戶要什么我就叫工人搞定它。,聽老板的話， 努力干活！,2,MATLAB并行平臺底層架構(gòu)（二）,MATLAB并行平臺底層架構(gòu)圖,3,MATLAB R2009b的安裝及啟動（一）,安裝時注意，MDCS，License Manager，并行計算工具箱Parallel Computing Toolbox等為必裝的產(chǎn)品和工具箱，（子節(jié)點機可不用裝License Manager）如下圖所示。,4,MATLAB R2009b的安裝及啟動（二）,裝好軟件在啟動之前，雙擊主節(jié)點機的matlabrootflexlm文件夾下的lmtool.exe（matlabroot表示matlab軟件的安裝目錄），開啟Matlab License Server，如下圖。,5,關(guān)閉防火墻 為方便平臺搭建，將目錄matlabroottoolboxdistcompbin添加到環(huán)境變量中的path里邊，如右圖設(shè)置。,6,MATLAB并行平臺搭建（一）,MATLAB并行平臺搭建（二）,安裝和開啟mdce（分布式計算引擎） 運行-cmd 安裝mdce: mdce install 開啟mdce: mdce start 注意：mdce安裝后會下次開機自動啟動,警察來了！,7,MATLAB并行平臺搭建（三）,配置jobmanager 打開matlab軟件，菜單選ParallelManage Configurations，彈出對話框； Filenewjobmanager，彈出對話框： Scheduler項，LookupURL處填寫所用計算機的名稱，如node5；Name項為自擬的jobmanager的名稱，如myjobmanager Jobs項，Number of Workers處表示該jobmanager運行并行程序時需要最小worker數(shù)目（即最小worker數(shù)目才執(zhí)行），以及該jobmanager可擁有的最大worker數(shù)目； 3. 點擊OK，完成配置。,完善資料，合法經(jīng)營。,8,MATLAB并行平臺搭建（三）,打開jobmanager 命令行下輸入： startjobmanager name myjobmanager 即前面配置時的名字 附：關(guān)閉jobmanager stopjobmanager name myjobmanager,正式登場！,9,MATLAB并行平臺搭建（四）,創(chuàng)建worker進程(雇傭工人) 同樣在命令行下輸入： startworker jobmanagerhost node5 jobmanager myjobmanager name worker1 remotehost node1 node5:本地計算機名字 myjobmanager：jobmanager的名字 worker1:worker進程的名字 node1:遠程計算機的名字 注意：可開啟多個不同名字的worker進程； 若在本地上創(chuàng)建則不需后面的-remotehost node1。 附：關(guān)閉worker 進程： stopworkername worker1 remotehost node1,我聘請你。,好。,平臺搭建完畢！可用nodestatus指令查看。,10,MATLAB并行程序編寫, 資源查找，創(chuàng)建對象； 創(chuàng)建工作（job）； 指定工作任務(wù)（task）； 提交工作； 等待； 返回計算任務(wù)結(jié)果。,findResource(),createJob(),createTask(),submit(),getAllOutputArguments(),waitForState(),程序結(jié)構(gòu)和相關(guān)函數(shù)調(diào)用,11,MATLAB并行程序示例,%程序功能，并行計算求2+4，5+8，1+7的和。 資源查找，創(chuàng)建對象。 jm = findResource(scheduler, type, jobmanager, name, myjobmanager, LookupURL, node5); 需要修改的是紅色劃線參數(shù)，第一個即前面jobmanager的名字，第二個 即本地主機的名字 創(chuàng)建工作，并將該工作所需的數(shù)據(jù)、程序發(fā)到各個worker處。 job1=createJob(jm);%工作名為job1 %set(job1, FileDependencies, bb1.m,bb2.m,bb3.m, W_FDJ1.mat,W_FDJ2.mat,W_FDJ3.mat); 注：set()函數(shù)就是將該工作所需的數(shù)據(jù)、程序發(fā)到各個worker處,本程序不需要用到。 創(chuàng)建任務(wù) createTask(job1, sum, 1, 2,4); createTask(job1, sum, 1, 5,8); createTask(job1, sum, 1, 1,7); 為job1創(chuàng)建了3個任務(wù)， sum代表函數(shù)頭，1代表返回參數(shù)個數(shù)，此處為1個， 2,4代表函數(shù)sum的輸入?yún)?shù)。,12,提交工作 submit(job1); 等待 waitForState(job1, finished); 返回結(jié)果 results = getAllOutputArguments(job1); 其中results1代表任務(wù)1的結(jié)果，本程序則為6。(2+4) results2代表任務(wù)2的結(jié)果，本程序則為13。(5+8) results3代表任務(wù)3