MPI分布内存并行程序开发-课件.pptVIP

* 数据类型（type） MPI定义了一些缺省的数据类型，用户也可以根据需要建立自己的数据类型 * 续上页 * 目的地 （dest） 发送进程指定的接收该消息的目的进程，也就是接收进程的进程号（注意组间通讯的情况）。 * 源 （source） 接收进程指定的发送该消息的源进程，也就是发送进程的进程号。如果该值为MPI_ANY_SOURCE表示接收任意源进程发来的消息。 * 标识符（tag） 由程序员指定地为标识一个消息的唯一非负整数值（0-32767），发送操作和接收操作的标识符一定要匹配，但对于接收操作来说，如果tag指定为MPI_ANY_TAG则可与任何发送操作的tag相匹配。 * 通信因子（comm） 包含源与目的进程的一组上下文相关的进程集合，除非用户自己定义（创建）了新的通信因子，否则一般使用系统预先定义的全局通信因子MPI_COMM_WORLD。 * 状态（status） 对于接收操作，包含了接收消息的源进程（source）和消息的标识符（tag）。在FORTRAN程序中，这个参数是包含MPI_STATUS_SIZE个整数的数组，status（MPI_SOURCE）、status（MPI_TAG）和status（MPI_ERROR）分别表示数据的进程标识、发送数据使用tag 标识和接收操作返回的错误代码。 相当于一种在接受方对消息的监测机制，并且以其为依据对消息作出不同的处理（当用通配符接受消息时）。 * 程序1、简单例子 #include “mpi.h” main(int argc, char **argv) { int numprocs,myrank,i,j,k; MPI_Status status; char msg[20]; MPI_Init(argc,argv); MPI_Comm_size(MPI_COMM_WORLD,numprocs); MPI_Comm_rank(MPI_COMM_WORLD,myrank); if(myrank == 0){ strcpy(msg,”Hello World”); MPI_Send(msg,strlen(msg) + 1,MPI_CHAR,1,99,MPI_COMM_WORLD); }else if(myrank ==1）{ MPI_Recv(msg,20,MPI_CHAR,0,99,MPI_COMM_WORLD,status); printf(“Receive message = %s\n”,msg); } MPI_Finalize(); } * 程序2、 π的计算 #include “mpi.h” #include stdio.h #include math.h double f(double x);/*定义函数f(x) */ { return(4.0/(1.0+x*x)); } int main (int argc,char * argv[]) { int done =0,n,myid,numprocs,i; double PI25DT=3.141592653589793238462643; double mypi,pi,h,sum,x; double startwtime=0.0,endwtime; int namelen; char processor_name[MPI_MAXPROCESSOR_NAME]; MPI_Status status; 0 1 -1 -1 1 * MPI_Init(argc,argv); MPI_Comm_size(MPI_COMM_WORLD,numprocs); MPI_Comm_rank(MPI_COMM_WORLD,myid); MPI_Get_processor_name(processor_name,namelen); fprint(stdout,”Process %d of %d on % s\n”,myid,numprocs, processor_name); n=0; if (myid==0) {