并行程序设计实验

并行程序设计实验1数据接力传送#includempi.h#includestdio.hintmain(intargc,char**argv){intrank,value,size;MPI_Statusstatus;MPI_Init(&argc,&argv);MPI_Comm_rank(MPI_COMM_WORLD,&rank);MPI_Comm_size(MPI_COMM_WORLD,&size);/*得到当前进程标识和总的进程个数*//*循环执行直到输入的数据为负时才退出*/if(rank==0){fprintf(stderr,\nPleasegivenewvalue=\n);/*进程0读入要传递的数据*/scanf(%d,&value);fprintf(stderr,%dread--(%d)\n,rank,value);if(size1){MPI_Send(&value,1,MPI_INT,rank+1,0,MPI_COMM_WORLD);fprintf(stderr,%dsend(%d)--%d\n,rank,value,rank+1);/*若不少于一个进程则向下一个进程传递该数据*/}}else{MPI_Recv(&value,1,MPI_INT,rank-1,0,MPI_COMM_WORLD,&status);/*其它进程从前一个进程接收传递过来的数据*/fprintf(stderr,%dreceive(%d)--%d\n,rank,value,rank-1);if(rank==size-1){MPI_Send(&value,1,MPI_INT,0,0,MPI_COMM_WORLD);fprintf(stderr,%dsend(%d)--%d\n,rank,value,0);/*若当前进程不是最后一个进程则将该数据继续向后传递*/}if(ranksize-1){MPI_Send(&value,1,MPI_INT,rank+1,0,MPI_COMM_WORLD);fprintf(stderr,%dsend(%d)--%d\n,rank,value,rank+1);/*若当前进程不是最后一个进程则将该数据继续向后传递*/}}MPI_Barrier(MPI_COMM_WORLD);/*执行一下同步加入它主要是为了将前后两次数据传递分开*/MPI_Finalize();}3任意源和任意标识#includempi.h#includestdio.h#includestdlib.h/*使用了随机函数srand和rand*/#includetime.h/*使用了时间函数time*/intmain(intargc,char*argv[]){intrank,size,i,buf[1];MPI_Statusstatus;MPI_Init(&argc,&argv);/*得到当前进程标识和总的进程个数*/MPI_Comm_rank(MPI_COMM_WORLD,&rank);MPI_Comm_size(MPI_COMM_WORLD,&size);if(rank==0){/*进程0接收来自其他所有进程的消息，将各消息的内容、消息来源和消息标识打印出来。*/for(i=0;i10*(size-1);i++){MPI_Recv(buf,1,MPI_INT,MPI_ANY_SOURCE,MPI_ANY_TAG,MPI_COMM_WORLD,&status);fprintf(stderr,Msg=%d\tfrom%dwithtag%d.\n,buf[0],status.MPI_SOURCE,status.MPI_TAG);}}else{/*其他每个进程向进程0发送10个随机数*/srand((unsigned)time(NULL));/*以当前时间作为生成随机数的种子*/for(i=0;i10;i++){buf[0]=rand()%100;/*生成一个随机整数*/MPI_Send(buf,1,MPI_INT,0,i,MPI_COMM_WORLD);}}MPI_Finalize();}2.进程间相互问候#includempi.h#includestdio.h#includestdlib.hvoidHello(void);intmain(intargc,char*argv[]){intme,option,namelen,size;charprocessor_name[MPI_MAX_PROCESSOR_NAME];MPI_Init(&argc,&argv);MPI_Comm_rank(MPI_COMM_WORLD,&me);MPI_Comm_size(MPI_COMM_WORLD,&size);/*得到当前进程标识和总的进程数*/if(size2){/*若总进程数小于2则出错退出*/fprintf(stderr,systestrequiresatleast2processes);MPI_Abort(MPI_COMM_WORLD,1);}MPI_Get_processor_name(processor_name,&namelen);/*得到当前机器名字*/fprintf(stderr,Process%disaliveon%s\n,me,processor_name);MPI_Barrier(MPI_COMM_WORLD);/*同步*/Hello();/*调用问候过程*/MPI_Finalize();}voidHello(void)/*任意两个进程间交换问候信息问候信息由发送进程标识和接收进程标识组成*/{intnproc,me;inttype=1;intbuffer[2],node;MPI_Statusstatus;MPI_Comm_rank(MPI_COMM_WORLD,&me);MPI_Comm_size(MPI_COMM_WORLD,&nproc);/*得到当前进程标识和总的进程数*/if(me==0){/*进程0负责打印提示信息*/printf(\nHellotestfromalltoall\n);fflush(stdout);}for(node=0;nodenproc;node++){/*循环对每一个进程进行问候*/if(node!=me){/*得到一个和自身不同的进程标识*/buffer[0]=me;/*将自身标识放入消息中*/buffer[1]=node;/*将被问候的进程标识也放入消息中*/MPI_Send(buffer,2,MPI_INT,node,type,MPI_COMM_WORLD);/*首先将问候消息发出*/MPI_Recv(buffer,2,MPI_INT,node,type,MPI_COMM_WORLD,&status);/*然后接收被问候进程对自己发送的问候消息*/if((buffer[0]!=node)||(buffer[1]!=me)){/*若接收到的消息的内容不是问候自己的或不是以被问候方的身份问候自己则出错*/(void)fprintf(stderr,Hello:%d!=%dor%d!=%d\n,buffer[0],node,buffer[1],me);printf(Mismatchonhelloprocessids;node=%d\n,node);}printf(Hellofrom%dto%d\n,me,node);/*打印出问候对方成功的信息*/fflush(stdout);}}}4.2#includempi.h#includestdio.hintmain(intargc,char**argv){intrank,value,size;MPI_Requestrreq,sreq;MPI_Statusstatus;MPI_Init(&argc,&argv);MPI_Comm_rank(MPI_COMM_WORLD,&rank);MPI_Comm_size(MPI_COMM_WORLD,&size);/*得到当前进程标识和总的进程个数*//*循环执行直到输入的数据为负时才退出*/if(rank==0){fprintf(stderr,\nPleasegivenewvalue=\n);/*进程0读入要传递的数据*/scanf(%d,&value);fprintf(stderr,%dread--(%d)\n,rank,value);if(size1){MPI_Issend(&value,1,MPI_INT,rank+1,0,MPI_COMM_WORLD,&sreq);fprintf(stderr,%dsend(%d)--%d\n,rank,value,rank+1);/*若不少于一个进程则向下一个进程传递该数据*/}}else{MPI_Irecv(&value,1,MPI_INT,rank-1,0,MPI_COMM_WORLD,&rreq);/*其它进程从前一个进程接收传递过来的数据*/fprintf(stderr,%dreceive(%d)--%d\n,rank,value,rank-1);if(rank==size-1){MPI_Issend(&value,1,MPI_INT,0,0,MPI_COMM_WORLD,&sreq);fprintf(stderr,%dsend(%d)--%d\n,rank,value,0);/*若当前进程不是最后一个进程则将该数据继续向后传递*/}if(ranksize-1){MPI_Issend(&value,1,MPI_INT,rank+1,0,MPI_COMM_WORLD,&sreq);fprintf(stderr,%dsend(%d)--%d\n,rank,value,rank+1);/*若当前进程不是最后一个进程则将该数据继续向后传递*/}}MPI_Barrier(MPI_COMM_WORLD);/*执行一下同步加入它主要是为了将前后两次数据传递分开*/MPI_Finalize();}4.3#includempi.h#includestdio.h#includestdlib.h/*使用了随机函数srand和rand*/#includetime.h/*使用了时间函数time*/intmain(intargc,char*argv[]){intrank,size,i,buf[1];MPI_Statusstatus;MPI_Requestrreq;MPI_Init(&argc,&argv);/*得到当前进程标识和总的进程个数*/MPI_Comm_rank(MPI_COMM_WORLD,&rank);MPI_Comm_size(MPI_COMM_WORLD,&size);if(rank==0){/*进程0接收来自其他所有进程的消息，将各消息的内容、消息来源和消息标识打印出来。*/for(i=0;i10*(size-1);i++){MPI_Irecv(buf,1,MPI_INT,MPI_ANY_SOURCE,MPI_ANY_TAG,MPI_COMM_WORLD,&rreq);fprintf(stderr,Msg=%d\tfrom%dwithtag%d.\n,buf[0],status.MPI_SOURCE,status.MPI_TAG);MPI_Wait(&rreq,&status);}}else{/*其他每个进程向进程0发送10个随机数*/srand((unsigned)time(NULL));/*以当前时间作为生成随机数的种子*/for(i=0;i10;i++){buf[0]=rand()%100;/*生成一个随机整数*/MPI_Rsend(buf,1,MPI_INT,0,i,MPI_COMM_WORLD);}}MPI_Finalize();return0;}5点积计算#includestdio.h#includempi.h#defineMAX_LOCAL_ORDER100m