第5讲-MPI并行程序设计语言.ppt

下载文档 降价啦

4
0
约 115页
2017-06-18 发布于湖北
举报
版权申诉
保障服务

第5讲-MPI并行程序设计语言.ppt

1、本文档共115页，可阅读全部内容。
2、有哪些信誉好的足球投注网站（book118）网站文档一经付费（服务费），不意味着购买了该文档的版权，仅供个人/单位学习、研究之用，不得用于商业用途，未经授权，严禁复制、发行、汇编、翻译或者网络传播等，侵权必究。
3、本站所有内容均由合作方或网友上传，本站不对文档的完整性、权威性及其观点立场正确性做任何保证或承诺！文档内容仅供研究参考，付费前请自行鉴别。如您付费，意味着您自己接受本站规则且自行承担风险，本站不退款、不进行额外附加服务；查看《如何避免下载的几个坑》。如果您已付费下载过本站文档，您可以点击这里二次下载。
4、如文档侵犯商业秘密、侵犯著作权、侵犯人身权等，请点击“版权申诉”（推荐），也可以打举报电话：400-050-0827(电话支持时间：9:00-18:30)。

第5讲-MPI并行程序设计语言资料

* * * MPI并行程序设计数据聚集 Reduce Allreduce Reduce-scatter Scan MPI 预定义全局数据运算符: MPI_MAX / MPI_MIN; MPI_SUM 求和 MPI_PROD 求积MPI_LAND 逻辑与 MPI_LOR 逻辑或 MPI_MAXLOC/MPI_MINLOC 最大/小值求下相应位置… … * MPI并行程序设计 int p, myrank; float buf; MPI_Comm comm; MPI_Init(argc, argv); /*得进程编号*/ MPI_Comm_rank(comm, my_rank); /* 得进程总数 */ MPI_Comm_size(comm, p); if(myrank==0) buf = 1.0; MPI_Bcast(buf,1,MPI_FLOAT,0, comm); Broadcast -- 数据广播 data buf . . MPI_Bcast(); . data . . MPI_Bcast(); . data . . MPI_Bcast(); . Process 0 myrank = 0 Process 1 myrank = 1 Process p-1 myrank = p-1 int MPI_Bcast ( void *buffer,/*发送/接收buf*/ int count, /*元素个数*/ MPI_Datatype datatype, int root, /*指定根进程*/ MPI_Comm comm) 根进程既是发送缓冲区也是接收缓冲区 Broadcast程序示例 * MPI并行程序设计 Gather -- 数据收集 int p, myrank; float data[10]; /*分布变量*/ float* buf; MPI_Comm comm; MPI_Init(argc, argv); /*得进程编号*/ MPI_Comm_rank(comm,my_rank); /* 得进程总数 */ MPI_Comm_size(comm, p); if(myrank==0) buf=(float*)malloc(p*10*sizeof(float); /*开辟接收缓冲区*/ MPI_Gather(data,10,MPI_FLOAT, buf,10,MPI_FlOAT,0,comm); data . MPI_Gather(); . data . MPI_Gather(); . data . MPI_Gather(); . Process 0 myrank = 0 Process 1 myrank = 1 Process p-1 myrank = p-1 根进程接收其他进程来的消息(包括根进程),按每个进程在通信组中的编号依次联接在一起,存放在根进程的接收缓冲区中. int MPI_Gather ( void *sendbuf, int sendcnt, MPI_Datatype sendtype, void *recvbuf, int recvcount, MPI_Datatype recvtype, int root, MPI_Comm comm ) buf * MPI并行程序设计 Scatter -- 数据分散 int p, myrank; float data[10]; float* buf; MPI_Comm comm; MPI_Init(argc, argv); /*得进程编号*/ MPI_Comm_rank(comm,my_rank); /* 得进程总数 */ MPI_Comm_size(comm, p); if(myrank==0) buf =(float*)malloc(p*10*sizeof(float); /*开辟发送缓冲区*/ MPI_Scatter(buf,10,MPI_FLOAT, data,10,MPI_FlOAT,0,comm); data . MPI_Scatter(); . data . MPI_ Scatter(); . data . MPI_ Scatter(); . Process 0 myrank = 0 Process 1 myrank = 1 Process p-1 myrank = p-1 根进程中存储了p个消息,第i个消息将传给第i个进程. int MPI_Scatter ( void *sendbuf, int sendcnt, MPI_Datatype sendtype, void *recvbuf, in