首页 > 其他分享 >MPI通信相关函数

MPI通信相关函数

时间：2023-04-07 11:23:21浏览次数：41  
标签：status count 函数 int Request 通信 MPI

MPI环境操作

初始化

MPI_INIT

结束

MPI_FIANLIZE

 

MPI通信子操作

MPI_COMM_SIZE

MPI数据类型

通信函数

SEND()函数

格式

int MPI_Send( void* buf, int count, MPI_Datatype datatype,int dest, int tag, MPI_Comm comm )

        • buf：发送数据buffer
        • count：发送数据长度
        • datatype：MPI数据类型
        • dest：发送的目的进程号
        • tag：发送数据的标记
        • comm：通信域

MPI_Isend()

Send的异步形式，多了个MPI_Request参数，用于异步返回消息的状态。

异步通信并不意味着异步发送消息后执行到MPI_Finailize()自动结束，而是在结尾等待这个异步的消息被接收，否则程序不会结束。

MPI_Recv()函数

格式

int MPI_Recv( void* buf, int count, MPI_Datatype datatype,int source, int tag, MPI_Comm comm, MPI_Status *status )

参数说明

        • buf：发送数据buffer
        • count：接收数据长度
        • datatype：MPI数据类型
        • source：接收数据的进程号
        • tag：接收数据的标记
        • comm：通信域
        • status：通信状态

缺点

阻塞式通信，可能会导致死锁。

MPI_Irecv()函数

MPI_Recv()的异步形式，多了个MPI_Request参数，用于异步返回消息的状态。

 

Sendrecv()函数

格式

int MPI_Sendrecv( void *sendbuf, int sendcount,MPI_Datatype sendtype, int dest, int sendtag,void *recvbuf, int recvcount, MPI_Datatype recvtype,int source,int recvtag,MPI_Comm comm,MPI_Status *status)

参数说明:

        • sendbuf：发送数据的buffer
        • sendcount：发送数据的长度，通常采用 sizeof() 计算
        • sendtype：发送数据的类型
        • dest：发送的目的地址
        • sendtag：发送数据的标签
        • recvbuf：接收数据的buffer
        • recvcount：接收数据的长度
        • recvtype：接收数据的类型
        • source：接收数据的地址
        • recvtag：接收数据的tag
        • comm：通讯域
        • status：状态

优点

不用管先发送还是先接收的问题，避免了死锁。

SENDRECV_REPLACE函数

格式

int MPI_Sendrecv_replace( void *buf, int count,MPI_Datatype type, int dest, int sendtag,int source,int recvtag,MPI_Comm comm,MPI_Status *status)

参数与Sendrecv基本一致，

缺少了接收数据的buffer，长度，类型。

作用

发送完用接收到的替换原本buffer。

缺点

只允许buffer一致。

效率低下，时间开销大，需要复制数据到buffer。

通配符

任意进程

source=MPI_ANY_SOURCE：接收来源于任意进程的消息

tag=MPI_ANY_TAG：接收任意tag的消息

空进程

MPI_PROC_NULL表示，并不是真正的接收或发送进程，解决边界进程阻塞通信的问题。

案例

0号进程接收所有进程的消息。


#include <iostream>
#include"mpi.h"
#include"string.h"
#define MESSAGESIZE 50
int main(int argc,char *argv[])
{
    MPI_Init(&argc,&argv);
    int id;
    int pronumber;
    MPI_Comm_rank(MPI_COMM_WORLD,&id);
    MPI_Comm_size(MPI_COMM_WORLD, &pronumber);

    if (id == 0) {
        char string[MESSAGESIZE];
        for (int i = 1;i < pronumber;i++) {
            MPI_Status status;
            MPI_Recv(string, MESSAGESIZE, MPI_CHAR, MPI_ANY_SOURCE, MPI_ANY_TAG, MPI_COMM_WORLD, &status);
            printf("%s\n", string);
        }
    }
    else {
        char string[] = "Bullshit! It is nonsense!";
        char thisid[MESSAGESIZE] = "From id:0：";
        thisid[8] = '0' + id;
        strcat_s(thisid, string);
        MPI_Request request;
        MPI_Isend(thisid, sizeof(thisid), MPI_CHAR, 0, id, MPI_COMM_WORLD, &request);
    }
    MPI_Finalize();
}

 

消息查询函数

MPI_PROBE

作用：探测source地址，标记为tag的消息。直到source地址发送了标记为tag的消息，否则一致阻塞在这一步。

格式：int MPI_Probe(int source, int tag, MPI_Comm comm,MPI_Status *status )

MPI_IPROBE

int MPI_Iprobe(int source, int tag, MPI_Comm comm,int* flag, MPI_Status *status )

Probe的异步形式

MPI_GET_COUNT

作用：获取消息的大小，从前文接收到消息后的status中获取，通常与Probe一起使用。

格式：int MPI_Get_count( MPI_Status *status, MPI_Datatype type,int *count )

消息请求完成函数

MPI_Wait()函数

作用：等待上一个未完成的操作完成。

格式：int MPI_Wait( MPI_Request *request, MPI_Status *status )

MPI_WaitAny()函数

作用：等待未完成的多个操作中，其中一个完成即可继续。

格式：int MPI_Waitany( int count, MPI_Request *requests,int *index, MPI_Status *status )

      • count：多个未完成操作的句柄MPI_Request集合的大小
      • requests：多个未完成操作的句柄MPI_Request集合
      • index：指向其中一个完成操作的下标，返回。

MPI_Waitall()函数

作用：等待所有未完成的操作完成。

格式：int MPI_Waitaall( int count, MPI_Request *requests, MPI_Status *status )

      • count：多个未完成操作的句柄MPI_Request集合的大小
      • requests：多个未完成操作的句柄MPI_Request集合
      • statuses：所有未完成操作的status集合

MPI_WaitSome()函数

作用：等待未完成的多个操作中，完成指定个数即可继续。

格式：int MPI_Waitany( int incount, MPI_Request *requests,int *outcount,int *indices, MPI_Status *statuses)

      • incount：多个未完成操作的句柄MPI_Request集合的大小
      • requests：多个未完成操作的句柄MPI_Request集合
      • outcount：等待完成操作的个数
      • indeices：已完成操作的索引数组
      • statuses：所有未完成操作的status集合

消息请求检查函数

MPI_Test()函数

作用：测试指定request是否完成，结果保存在flag中，非0表示完成。

格式：int MPI_Test( MPI_Request *request, int *flag, MPI_Status *status )

MPI_Testany()函数

作用：测试指定requests集合中是否有其中的一个完成，完成结果保存在flag中，非0表示完成，完成的request下标保存在index中。

格式：int MPI_Test( int count, MPI_Request *requests, int *index, int *flag, MPI_Status *status)

MPI_Testall()函数

作用：测试指定requests集合中所有request是否完成，完成结果保存在flag中，非0表示所有的都完成。

格式：int MPI_Test(int count, MPI_Request *requests, int *flag, MPI_Status *statuses)

MPI_Testsome()函数

作用：测试指定requests集合中指定outcount个数的request是否完成，indices保存已完成的request索引数组

格式：int MPI_Testsome(int incount, MPI_Request *requests,int *outcount,int *indices, MPI_Status *statuses )

MPI_Send_INIT()函数

作用：建立发送消息请求通道，当调用MPI_Start()函数时才开始发送。

格式：int MPI_Send_init(void* buf, int count, MPI_Datatype type,int dest, int tag, MPI_Comm comm, MPI_Request *request)

参数与Send相同。

MPI_Recv_INIT()函数

作用：建立接收消息请求通道，当调用MPI_Start()函数时才开始发送。

格式：MPI__Recv_init(void* buf, int count, MPI_Datatype type,int src, int tag, MPI_Comm comm, MPI_Request *request)

参数与Recv相同。

消息请求的释放与取消

MPI_Start()函数

作用：启动request的消息请求。

格式：int MPI_Start( MPI_Request *request )

MPI_Startall()函数

作用：启动大小为count的requests中所有的消息请求。

格式：int MPI_Start( int count, MPI_Request *requests )

MPI_Cancel()函数

作用：取消request的消息请求。

格式：int MPI_Cancel( MPI_Request *request )

 

MPI_Test_Cancelled()函数

作用：测试请求status的状态，保存在flag中，非0表示请求已经完成。

格式：int MPI_Test_Cancelled( MPI_Status *status, int *flag )

 

释放句柄函数Request_Free()

作用：释放句柄。使用Send_init或Recv_init后，句柄还在系统中，为了避免系统资源枯竭，可是使用此函数释放

格式：int MPI_Request_Free( MPI_Request request )

使用注意：使用Isend或Irecv等产生的句柄，若将其取消了后，函数将失去作用。

 

 

 

 

标签：status,count,函数,int,Request,通信,MPI
From： https://www.cnblogs.com/RedNoseBo/p/17294877.html

相关文章

  • freemarker处理list的内置函数
    freemarker处理list的内置函数first没有括号last没有括号seq_containsseq_index_ofsize没有括号reversesortsort_by如果list中放置的是对象的话,可以根据某个属性来排序chunk将list分块<#assignlistVar=[1,2,3,4,5,6,7,8,9,0,1,2]/><#listlistVa......
  • 怎么在WPS表格中创建自定义函数
    1]环境win7的32位wps表格2019(11.8.2.10158)2]打开VB编辑器 新建模块函数   输入自定义函数，保存并关闭VB窗口Functionzz(ByValRngAsRange)AsIntegerzz=Rng+1EndFunction引用自定义函数    ......
  • SqlServer中PATINDEX()函数
    SQLServer的PATINDEX()函数用于在字符串中查找某个模式的位置，并返回该模式第一个匹配项的起始位置。它接受两个参数：要查找的模式和要查找的字符串。下面是语法格式：PATINDEX('%pattern%',expression)其中，'%pattern%'是模式，expression是要查找的字符串。模式中可以含有通配......
  • C# javascript中调用自定义函数function
    Default.aspx1<script>2//自定义函数3functionpageInit(){4letdata=[];5varsource_data=my_source_data2();//my_source_data2是一般程序Handler.ashx中，自定义的方法6varmy_data=source_data.split('###');......
  • 第1节 可测函数及其性质
    学习要求：掌握可测函数的定义和函数可测的等价条件.掌握几乎处处的定义.重要知识点:定义  设f(x)是定义在可测集E⊂Rn的实函数，如果对于任何有限实数a，E[f>a]都是可测集，则称f(x)为定义在E上的可测函数.定理  设f(x)是定义在可测集E上的实函数，下列任一条件都是f(x)在E上可测的......
  • chr( )函数和ord( )函数
    一、chr()函数为内置函数参数：i为10进制或16进制的整数返回值：字符串1.取32~40之间的字符，注意：range()函数取前不取后foriinrange(32,40):print(chr(i),end='')#打印结果!"#$%&'有人有疑问了，不是应该打印8个吗，怎么只有7个呢？因为在'叹号'前面还有一个空......
  • flask请求上下文分析，源码request原理，wtforms，精确导出依赖，函数和方法，threading.locl对
    内容回顾蓝图第一步：导入第二步：实例化得到对象，可以指定static和templates第三步：app中注册蓝图，注册蓝图时，可以指定前缀第四步：使用蓝图，注册路由，注册请求扩展g对象当次请求的全局对象，在当次请求中可以放值和取值跟session的区别是session可以在多次请求中使用，g对象只在当次请......
  • Django笔记十八之save函数的继承操作和指定字段更新等实例方法
    本文首发于微信公众号：Hunter后端原文链接：Django笔记十八之save函数的继承操作和指定字段更新等实例方法这篇笔记主要介绍Django一些实例方法。什么是实例，我们知道通过filter()的一些筛选方法，得到的是QuerySet，而QuerySet取单条数据，通过索引，或者first()或者last()等......
  • 今日总结 Android与硬件设备通信（一）
    今天看了看Android与硬件通信的原理1、建立连接的原理在实现软件与硬件交互的时候，首先需要了解该硬件的构造，运行流程等相关操作，熟读相关的文档，知道硬件开发商那边给出了哪些接口，分别对应我们项目中的那些模块等等就拿我这个项目的硬件来说，供应商给出的连接流程如下图：  我......
  • flask之请求上下文分析之导出项目依赖-函数和方法的区别-threading.local对象-偏函数-
    目录flask之请求上下文分析之导出项目依赖-函数和方法的区别-threading.local对象-偏函数-flask整个生命执行流程--wtforms今日内容详细1请求上下文分析(源码：request原理)1.1导出项目的依赖1.2函数和方法1.3threading.local对象1.4偏函数1.5flask整个生命执行流程(1.1.4版本......

赞助商

阅读排行

网站主页关于我们联系我们网站地图

本网站内容转载自其他媒体，侵权联系[admin##ips99.com]。

Copyright © 2020-2023 IPS99 版权所有 IPS99