mpi分布內(nèi)存并行程序開(kāi)發(fā)(參考版)
2025-07-20 15:46本頁(yè)面
【正文】 } 44 謝謝！ 。 fflush(stdout)。 endwtime=MPI_Wtime()。 pi=pi+mypi。mypi,1,MPI_DOUBLE,MPI_ANY_SOURCE, MPI_ANY_TAG,MPI_COMM_WORLD,amp。jnumprocs。 pi=pi+mypi。 /*各進(jìn)程并行計(jì)算得到的部分和 */ /*將部分和累加得到所有矩形的面積，該面積和即為近似 PI值 */ if (myid != 0) MPI_Send(amp。 sum+=f(x)。i=n。 sum=。status)。 } } 41 else { MPI_Recv(amp。j++) { MPI_Send(amp。 for (j=1。n)。 if (myid==0) { printf(“Please give N=”)。 fprint(stdout,”P(pán)rocess %d of %d on % s\n”,myid,numprocs, processor_name)。 MPI_Get_processor_name(processor_name,amp。 MPI_Comm_rank(MPI_COMM_WORLD,amp。 MPI_Comm_size(MPI_COMM_WORLD,amp。argc,amp。 MPI_Status status。 int namelen。 double mypi,pi,h,sum,x。 } int main (int argc,char * argv[]) { int done =0,n,myid,numprocs,i。 } 39 程序 π的計(jì)算 include “” include include double f(double x)。 printf(“Receive message = %s\n”,msg)。 }else if(myrank ==1） { MPI_Recv(msg,20,MPI_CHAR,0,99,MPI_COMM_WORLD,amp。 if(myrank == 0){ strcpy(msg,”Hello World”)。 MPI_Comm_rank(MPI_COMM_WORLD,amp。 MPI_Comm_size(MPI_COMM_WORLD,amp。argc,amp。 char msg[20]。 38 程序 簡(jiǎn)單例子 include “” main(int argc, char **argv) { int numprocs,myrank,i,j,k。 在FORTRAN 程序中 ， 這個(gè)參數(shù)是包含MPI_STATUS_SIZE 個(gè)整數(shù)的數(shù)組 ， status（ MPI_SOURCE） 、 status（ MPI_TAG） 和status（ MPI_ERROR） 分別表示數(shù)據(jù)的進(jìn)程標(biāo)識(shí) 、發(fā)送數(shù)據(jù)使用 tag 標(biāo)識(shí)和接收操作返回的錯(cuò)誤代碼 。 36 通信因子（ m） ? 包含源與目的進(jìn)程的一組上下文相關(guān)的進(jìn)程集合 ， 除非用戶(hù)自己定義 （ 創(chuàng)建 ） 了新的通信因子 ， 否則一般使用系統(tǒng)
高考資料相關(guān)推薦
鄂ICP備17016276號(hào)-1