2回答
我有一个MPI程序，由一个主进程组成，它将命令传递给一组从进程。在接收到命令时，从节点只需调用system()来执行此操作。当奴隶在等待命令时，他们消耗了各自CPU的100%。探测()似乎处于一个紧密的循环中，但这只是猜测。你认为是什么导致了这一切，我能做些什么来解决这个问题呢？
下面是等待命令的从进程中的代码。同时观察日志和top命令表明，当奴隶使用他们的CPU时，他们就在这个函数中。
MpiMessage
Mpi::BlockingRecv() {
LOG(8, "BlockingRecv");
MpiMessage result;
MPI::Status s
浏览 3提问于2013-01-28得票数 10
回答已采纳
据我所知，，意思是MPI_Send(.)可以由MPI_Ircv(.)接收。
也就是说，我不能使用MPI_Bcast(.)使用MPI_Ibcast(.)，如下例所示：
#include <mpi.h>
#include <stdio.h>
#include <stdlib.h>
int main(void) {
MPI_Init(NULL, NULL); int world_rank;
MPI_Comm_rank(MPI_COMM_WORLD, &world_rank);
MPI_Request req;
int i;
if
浏览 3提问于2020-09-29得票数 0
回答已采纳
我试图用MPI_Win_lock和MPI_Win_unlock对MPI的RMA操作做一个简单的测试。程序只允许进程0更新进程1中的整数值并显示它。
以下程序运行正常(至少在我看来结果是正确的)：
#include "mpi.h"
#include "stdio.h"
#define root 0
int main(int argc, char *argv[])
{
int myrank, nprocs;
int send, recv, err;
MPI_Win nwin;
int *st;
MPI_Init(&argc, &
浏览 4提问于2014-01-28得票数 2
回答已采纳
在一方不知道另一方的等级的情况下，是否可以进行MPI_Sendrecv交换？如果不是，那么最好的方法是什么(我的下一个猜测将是一对发送和记录)？
例如，在C中，如果我想在秩0和其他秩之间交换整数，这种类型的东西能工作吗？：
MPI_Status stat;
if(rank){
int someval = 0;
MPI_Sendrecv(&someval, 1, MPI_INT, 0, 1, &recvbuf, 1, MPI_INT, 0, MPI_ANY_TAG, MPI_COMM_WORLD, &stat);
}else{
int someotherval
浏览 0提问于2015-04-06得票数 5
回答已采纳
1回答
开放中的同步通信
、、、
在阻塞和非阻塞操作(在OpenMPI中)的上下文中，我稍微混淆了同步-异步的概念：
：MPI_Isend是，不一定是异步的(所以它可以同步吗?)
：MPI_Isend()和MPI_Irecv()是MPI的异步通信原语。
我已经看过了以前关于堆栈溢出()的同步异步阻塞-非阻塞问题，但是对我没有任何帮助。据我所知：
立即 (MPI_Isend)：方法返回并执行下一行->非阻塞
Standard/non-immediate (MPI_Send)：对于大型消息，它阻塞直到传输完成
同步操作块()
asynchronous操作是非阻塞的()。
那么，为什么M
浏览 6提问于2014-11-12得票数 8
1回答
我要在这个夏天掌握MPI。我开始阅读彼得·帕切科( Pacheco )的“并行编程入门”，并解决它的练习。在其中一个MPI练习中，他要求用MPI_Scan实现简单的前缀和，但我不能用MPI_Scan实现它。我通过使用MPI_Scatter和MPI_Gather找到了一个解决方案。请帮我找到MPI_Scan的答案。
// declaring array and result
// generating random array
MPI_Bcast( &array, n, MPI_FLOAT, 0, MPI_COMM_WORLD);
MPI_Barrier(MPI_COMM_WORLD);
浏览 0提问于2012-08-06得票数 0
回答已采纳
1回答
我有一个打算从根目录(rank==(FIELD=0))广播的int。
int winner
if (rank == FIELD) {
winner = something;
}
MPI_Barrier(MPI_COMM_WORLD);
MPI_Bcast(&winner, 1, MPI_INT, FIELD, MPI_COMM_WORLD);
MPI_Barrier(MPI_COMM_WORLD);
if (rank != FIELD) {
cout << rank << " informed that winner is "
浏览 0提问于2012-11-08得票数 5
回答已采纳
1回答
我试图以以下方式使用mpi读取txt文件：
主节点应该加载数据，并在工作处理器之间进行划分和分发。
然而，我的代码并没有结束。
下面是相应的代码片段：
MPI_File_open(MPI_COMM_WORLD, argv[1], MPI_MODE_RDONLY, MPI_INFO_NULL, &in);
if (rank == 0){
printf("OK\n");
MPI_Offset filesize;
MPI_Offset localsize;
MPI_Offset start;
MPI_Offset end;
浏览 0提问于2014-12-27得票数 0
回答已采纳
在算法的每一步中，我必须从其他处理器收集大量的根数据，而某些处理器的数据大小可能为零。
因此，我想知道当缓冲区不是空的时候，使用MPI_Igatherv还是使用(MPI_Isend & MPI_Irecv)更有效和更快。
MPI内部是否负责MPI_Igatherv中的零缓冲区？
使用单边通信而不是MPI_Igatherv或MPI_Isend是否更好和可能？
浏览 0提问于2015-03-24得票数 0
回答已采纳
我正在发送一个整数，它通过MPI_Bcast触发终止。根将一个名为“运行”的变量设置为零，并发送BCast。Bcast似乎已经完成，但我看不出该值被发送到其他进程。其他进程似乎在等待MPI_Scatter完成。他们甚至不应该到达这里。
我对MPI_Bcast做了很多研究，据我所知，它应该是阻塞的。这让我很困惑，因为根中的MPI_Bcast似乎已经完成了，尽管我无法找到其他进程的匹配(接收) MPI_Bcasts。我已经用printfs包围了我的所有MPI_Bcasts，并且这些printfs的输出( 1)、print和2)从根目录中打印出正确的值。
根目录如下：
while (running
浏览 1提问于2019-05-03得票数 0
回答已采纳
1回答
我写了一个小程序，我把一些随机的值从我的主进程发送到奴隶。奴隶们在计算小方程式，他们应该把结果发回给主人。现在，主人应该将结果按正确的顺序放置到新的结果数组中。我在使用信息标签。以下是一些方法：
将任务列表中的一个元素发送给奴隶
void Ccalculation::masterSend(int * tasklist)
{
for (int i = 1; i < this->world_size; i++) {
MPI_Send(&tasklist[current], 1, MPI_INT, i, current, MPI_COMM_WORLD);
浏览 3提问于2016-05-16得票数 1
回答已采纳
我的应用程序使用单边通信(MPI_Rget、MPI_Raccumulate)和同步原语(如MPI_Win_Lock和MPI_Win_Unlock )来实现被动目标同步。
我分析了我的应用程序，发现大部分时间都花在MPI_Win_Unlock函数(而不是MPI_Win_Lock)上，我不明白为什么。
(1)有人知道为什么MPI_Win_Unlock函数花费这么多时间吗？(可能是实现问题) (2)如果我采用S/C/P/W同步模型，这种情况会变得更好吗？我只需要确保所有的单边操作不会同时重叠。
我正在使用英特尔的MPI库ver5.1，它实现了MPI V3。
我附加了一些代码片段(实际上是:D)
Ea
浏览 3提问于2016-01-26得票数 2
回答已采纳
我正在编写使用PMPI (配置文件MPI接口)分析MPI代码的示例代码。虽然C语言中的示例运行良好，但Fortran中类似的简单代码却无法正常工作。
下面是我的C代码：
#include "mpi.h"
#include <stdio.h>
int main (int argc, char *argv[]) {
int size;
int rank;
char b[100];
MPI_Status st;
MPI_Init (&argc, &argv);
MPI_Pcontrol
浏览 1提问于2021-05-21得票数 3
我有一个数据需要广播给工人。但是，即使我使用MPI_Wait而不是MPI_Test，也无法接收到它，除非我使用阻塞MPI_Bcast。
我不知道会发生什么，我试过很多方法，但都没有用。
我的代码有什么问题吗？
#include <stdio.h>
#include <unistd.h>
#include <mpi.h>
int main()
{
int rank, size;
int data;
MPI_Init(NULL, NULL);
MPI_Comm_rank(MPI_COMM_WORLD, &rank);
浏览 8提问于2017-07-19得票数 0
回答已采纳
2回答
我正在尝试启动一系列MPI_Igather调用(来自MPI 4的非阻塞集合)，做一些工作，然后每当一个Igather完成时，对这些数据做一些更多的工作。
这很好，除非我在每个MPI级别上从不同的线程启动Igather。在这种情况下，我经常会遇到死锁，即使我调用MPI_Init_thread以确保提供MPI_THREAD_MULTIPLE。非阻塞集合没有匹配的标记发送和接收，但我认为这是由与每个集体操作相关联的MPI_Request对象处理的？
我发现失败的最简单的例子是：
给定np MPI等级，其中每个元素都有一个长度为np的局部数组，为每个元素启动一个MPI_Igather，在进程i .上收
浏览 8提问于2022-01-13得票数 4
回答已采纳
我想用MPI风格编写我自己的扫描函数，这意味着我必须从MPI_Op参数访问关联操作。我无法真正找到MPI_Op结构的定义，因此不知道使用什么偏移量来访问函数。我希望这样做，因为我还想处理用户定义的函数，这些函数是用MPI_Op_Create函数创建和绑定到处理的，并且尽可能接近MPI_Scan的MPI实现。到目前为止，我尝试了以下片段，假设函数的地址保存在例如MPI_SUM句柄中，没有偏移：
int asize = 10;
int inArray[asize];
int outArray[asize];
for(int i = 0; i < asize; i++) {
inArr
浏览 2提问于2020-07-27得票数 1
回答已采纳
每个进程都在构建某个数组，并使用mpi_file_write_at()将该数组写到“正确”的位置。在写入文件后，我从相同的位置读取，但它不是我写入的内容。代码附在附件中。我只是MPI的初学者，所以如果问题不够聪明，我很抱歉。
program output
use mpi
implicit none
integer :: ierr,i,proc_num,file,intsize
integer :: status(mpi_status_size)
integer,parameter :: count=10
integer,dimension(count) :: buf
integer,dimen
浏览 2提问于2015-08-13得票数 2
我正在尝试做一些简单的MPI项目(w MPICH)，但在这样做的过程中，我遇到了一个我既不理解也不能解决的问题(可能是bc我误解了文档)。因此，我基本上想要做的是将一个结构传递给MPI_Reduce，以便对其进行一些操作，并将结果返回到根进程。
为此，我尝试了两种不同的方法。第一种方法是使用MPI_Pack在缓冲区中连续打包结构的元素，然后在我的user函数中将它们解包。
#include <mpi.h>
#include <stdio.h>
#include <stdlib.h>
#include <stdarg.h>
#define MAX
浏览 0提问于2018-05-01得票数 0
我试图让每个进程都以这种方式向所有其他进程广播
#include "mpi.h"
#include <stdio.h>
int main(argc,argv)
int argc;
char **argv;
{
int MyProc, size,tag=1;
int msg_recpt;
MPI_Status status;
MPI_Init(&argc, &argv);
MPI_Comm_rank(MPI_COMM_WORLD, &MyProc);
MPI_Comm_size(MPI_COMM_WORLD, &a
浏览 0提问于2018-11-18得票数 0
回答已采纳
1回答
我在我的混合MPI/OpenMP代码中发现了一个问题，这个问题在下面引用的代码中以最简单的形式再现。我使用2个线程每MPI排名。然后，这两个线程在一个OpenMP“节”中进行几个计算，其中一个是对两个不同的向量A和B进行"mpi_allreduce“调用，它们的结果存储在W和WW中。问题是，每次运行程序时，我都会得到不同的输出。我的想法是，MPI调用是重叠的，减少的数组W和WW即使有不同的名称也合并在一起，但我不确定。任何关于如何克服这个问题的意见都是欢迎的。
详细信息: MPI线程级别在代码中初始化为MPI_THREAD_MULTIPLE，但我也尝试过串行和漏斗(同样的问题)。
我编
浏览 3提问于2015-11-07得票数 3
回答已采纳
1回答
MPI_Init(&argc, &argv);
int size,rank,i,*a,*b,*c,N;
double t1,t2;
MPI_Comm_size(MPI_COMM_WORLD, &size);
MPI_Comm_rank(MPI_COMM_WORLD, &rank);
srand(time(NULL));
if(rank==0)
{
printf("Input an integer for arrays size\n");
scanf
浏览 0提问于2018-03-26得票数 0
1回答
我刚开始学习MPI，我不太清楚问题的原因。
#include <stdio.h>
#include <stdlib.h>
#include <assert.h>
#include <mpi.h>
int main(int argc, char *argv[])
{
int myRank, size;
double myLeftBound, myRightBound;
MPI_Status status1;
MPI_Status status2;
MPI_Request request1;
MPI
浏览 4提问于2017-02-25得票数 1
回答已采纳
1回答
我完全卡住了。这段代码
MPI_Comm_rank(MPI_COMM_WORLD, &myrank);
if(myrank==0) i=1;
if(myrank==1) i=0;
MPI_Send(sendbuf, 1, MPI_INT, i, 99, MPI_COMM_WORLD);
MPI_Recv(recvbuf, 1, MPI_INT, i, 99, MPI_COMM_WORLD,&status);
在两个进程上运行的工作。为什么没有死锁？非阻塞版本也是如此
MPI_Comm_rank(MPI_COMM_WORLD, &myrank);
if(myrank==0
浏览 3提问于2020-10-17得票数 0
我是MPI的新手，我想做一个问题，我有两个数组A和B，有15个元素，我有16个进程，每个进程代表数组中的一个元素(我不使用进程0)。数组A存储了一个位置8.15的输入数据，该位置表示一棵树的叶子，在第一步中，我在数组中进行压缩，其中叶子将数字发送给来自所有儿子的父和父，并将这些数字添加到父亲。数组at是在过程1中完成的，其中是数组中所有元素的总和。在第二步中，我进行前缀计算，从进程0开始，在叶处结束。为了计算数组B，所有其他进程都需要等待进程1来完成工作，为此我使用了一个MPI_Barrier，但是在执行代码时有一个错误。
int m = 3;
int n = (int)pow(2, m);
浏览 8提问于2017-11-03得票数 0
1回答
我试图从rank =0的进程向所有其他进程(1,2,3,4)发送一个向量n_pointsBuffer中的值。问题是，只有进程0获得了它的值，而其他进程没有。有没有人能告诉我，如果可能，我想要做什么，如果可能，是如何做的？我是第一次使用MPI。
#include <mpi.h>
#include <iostream>
#include <cstdlib>
#include <cmath>
using namespace std;
int main(int argc, char* argv[]) {
MPI::Init(argc, argv);
浏览 0提问于2012-12-04得票数 1
回答已采纳
这是代码的一部分。
if(rank==0) {
temp=10000;
var=new char[temp] ;
MPI_Send(&temp,1,MPI_INT,1,tag,MPI_COMM_WORLD);
MPI_Send(var,temp,MPI_BYTE,1,tag,MPI_COMM_WORLD);
//MPI_Wait(&req[0],&sta[1]);
}
if(rank==1) {
MPI_Irecv(&temp
浏览 2提问于2013-06-28得票数 1
回答已采纳
2回答
我阅读了MPI标准，找到了一个关于MPI_Put和MPI_Get操作的章节。然而，对于我来说，RMA在这些功能的基础上有什么好处还不清楚。当使用这样的函数比使用异步MPI_Isend更好时，MPI_Irecv？使用RMA的一般目的是什么(不在MPI环境中)？
浏览 1提问于2018-03-03得票数 3
1回答
在套接字编程中，我们有函数，它允许我们同时检查多个套接字。我想知道MPI库中也有这样的功能吗？
在下面代码的第一个for循环中，我发送多个非阻塞发送和接收来自一个节点的请求。在第二个for循环中，我希望开始处理首先发送数据的节点的数据，而不是按顺序等待每个节点。我想知道有什么办法吗？
for(id=0; id<numtasks; id++){
if(id == taskid) continue;
if(sendCount[id] != 0) MPI_Isend(sendBuffer[id], N*sendCount[id], MPI_DOUBLE, id,
浏览 3提问于2016-05-25得票数 4
回答已采纳
1回答
我有关于MPI发送和接收操作的问题。
假设我们有两个MPI线程，它们试图相互发送消息。下面是三个代码片段：
第一(阻塞‘发送’和‘接收’)：
...
int data = ...;
...
MPI_Send( &data, sizeof( int ), MPI_INT,
(my_id == 0)?1:0, 0, MPI_COMM_WORLD );
MPI_Status status;
MPI_Recv( &data, sizeof( int ), MPI_INT,
(my_id == 0)?1:0, 0, MPI_COMM_WORLD, &
浏览 1提问于2012-02-23得票数 4
我一直在使用MPI_Scatter / MPI_Gather进行各种并行计算。我注意到的一件事是，MPI_Barrier()经常被调用来同步处理器，类似于OpenMP屏障指令。我正在调整项目的代码，并注释掉了下面的MPI_Barrier()行，发现计算仍然是正确的。为什么是这种情况？我可以理解为什么需要第一个MPI_Barrier() --其他处理器不需要等待；一旦从处理器主处理器获得数据，就可以开始计算。但是，MPI_Barrier在MPI_Gather之后是否需要使用，还是MPI_Gather已经有了隐含的障碍？
编辑:在这种情况下，正在处理的数据的大小重要吗？
MPI_Scatter(&
浏览 10提问于2017-05-15得票数 5
回答已采纳
2回答
我需要约简节点从其他节点获取元素列表(存储在向量中)的副本。我定义了我自己的还原函数，但它不起作用。程序终止/崩溃。
这是代码：
#include <iostream>
#include "mpi.h"
#include <vector>
using namespace std;
void pushTheElem(vector<int>* in, vector<int>* inout, int *len, MPI_Datatype *datatype)
{
vector<int>::iterator it;
浏览 8提问于2017-07-14得票数 1
回答已采纳
好的，我正在尝试做一个程序，其中进程0应该开始初始化发送消息到一个随机进程而不是它自己，然后选择的随机进程应该接收消息并发送到另一个随机进程。这应该发生，直到请求的要发送的消息数完成，这是由用户作为输入给出的。我看到我的程序要么以最大值2的速度发送消息，要么甚至不发送消息，并给出以下错误
**其中一个进程严重终止:清理应用程序使用退出字符串终止: TERMINATED (信号15)
**
这是我的代码，让我知道它的循环漏洞是什么。不包括随机生成部分，该部分工作正常
if(rank==0)
{
rnum=rgenerator(rank,size);
string++;
MPI_Send(&
浏览 3提问于2011-10-31得票数 1
回答已采纳
1回答
我需要编写代码，将矩阵的列从每个进程发送到根进程。
我有以下代码：
int task8(int argc, char* argv[])
{
int rank, size;
double matrix[100][150];
double result_matrix[100][150];
MPI_Init(&argc, &argv);
MPI_Comm_rank(MPI_COMM_WORLD, &rank);
MPI_Comm_size(MPI_COMM_WORLD, &size);
// generate
浏览 4提问于2020-06-18得票数 0
回答已采纳
我正在用C++为MPI编写一个轻型包装器。为了使事情变得更简单，我有一些函数返回一个MPI_Request对象，而不是将一个对象作为指针。该代码在我的计算机上运行良好，尽管我担心它可能会导致MPI的不同实现出现问题。
下面是一些示例代码：
template<class T> MPI_Request ireceive(T* data, int count, int source, int tag)
{
MPI_Request request;
MPI_Irecv(data, get_mpi_type<T>::mul * count, get_mpi_typ
浏览 4提问于2017-06-26得票数 3
回答已采纳
2回答
我有一个任务，使简单的程序使用MPI。在使用mpi.h头文件在Dev C++中尝试一个Hello World程序并对其进行编译后，出现了makefile.win，并且出现了以下错误
D:\Assignment\Project\MPI\tesmpi.o tesmpi.cpp:(.text+0x21): undefined reference to `MPI_Init'
D:\Assignment\Project\MPI\tesmpi.o tesmpi.cpp (.text$_ZN3MPI9IntracommC2Ev[__ZN3MPI9IntracommC2Ev]+0xf): undef
浏览 44提问于2017-03-16得票数 0
1回答
假设我有一些int x。我想检查所有的MPI级别是否都得到了x的相同值。使用MPI集合实现这一目标的好方法是什么？
我能想到的最简单的是，广播曲柄0的x，做比较，所有的减少-逻辑-和比较结果。这需要两项集体行动。
...
x = ...
x_bcast = comm.bcast(x, root=0)
all_equal = comm.allreduce(x==x_bcast, op=MPI.LAND)
if not all_equal:
raise Exception()
...
有更好的方法吗？
更新：
从OpenMPI用户列表中，我收到了以下响应。我觉得这是个很棒的把戏！
--我在
浏览 3提问于2022-02-17得票数 0
1回答
假设我有很好的理由去做下面的事情(我想我已经做到了)，如何让它工作？
#include "mpi.h"
int main( int argc, char *argv[] )
{
int myid, numprocs;
MPI_Init(&argc,&argv);
MPI_Comm_size(MPI_COMM_WORLD,&numprocs);
MPI_Comm_rank(MPI_COMM_WORLD,&myid);
// ...
MPI_Finalize();
MPI_Init(&a
浏览 3提问于2012-11-15得票数 5
回答已采纳
我的集群在Infiniband FDR上使用MVAPICH2，我正在考虑使用RDMA进行模拟。我知道MPI_Put和MPI_Get调用显式调用RDMA操作，但是我想知道这是否是在MPI中使用RDMA的唯一方法。
我目前的实现包括用于通信的通道语义(发送/接收)，以及MPI_Reduce和MPI_Gatherv。我知道MVAPICH2有可以用来启用RDMA的配置参数。如果使用MPI的程序启用了发送/接收呼叫和RDMA，那么MPI是否会自动从信道语义转换为内存语义(put/get)，还是MPI_Put和MPI_Get的显式使用是在MVAPICH2中实现RDMA的唯一方法？
MPI_Send需要相应
浏览 6提问于2018-03-10得票数 2
回答已采纳
1回答
我的问题可能很愚蠢，但我还是要问清楚！
问题:，您是否希望下面的两个代码使用MPI_Comm_Split来构建一个子通信程序？(例如，假设我运行的代码的级别在0到5之间，其中有6个procs )。
NB :，代码在fortran 90中，带有英特尔编译器2019年，我使用Mpich作为Mpi。
代码1
call Mpi_Init(ierror)
call Mpi_Comm_Rank(mpi_comm_world,rank,ierror)
if (rank > 2) then
call Mpi_Comm_Split(mpi_comm_world,0,rank,new_comm,i
浏览 6提问于2020-02-18得票数 2
回答已采纳
1回答
我正在写一个C/MPI程序，让许多进程从一个数据文件中读取数据。当使用stdio的标准函数(fopen、fread、fseek)时，一切都很顺利。问题是我不能超过4 go偏移量。所以我使用MPI-IO函数来读取一个大文件，而此时内存不能很好地释放。
事实上，我读取了一个缓冲区，我处理它，然后释放分配的内存。每个进程的内存使用量是完美的，但全局内存使用量并没有停止增长。只需将mpi_file_read替换为fread，就不会出现这个问题。
下面是我的代码：
double CPUtime(){ return ((double) clock())/CLOCKS_PER_SEC;}int main(i
浏览 0提问于2012-07-11得票数 0
1回答
下面的MPI程序简单地为消息定义了一个MPI类型，然后从进程0向进程1发送一条消息。但是，它崩溃了，并显示了一条没有多少信息的错误消息。它有什么问题？
#include <stdio.h>
#include <mpi.h>
struct P {
char choices[64];
int next_choice;
};
typedef struct P Packing;
int main(int argc,char** argv) {
int rank;
MPI_Datatype PACKING_TYPE;
MPI_Init
浏览 0提问于2012-02-09得票数 1
回答已采纳
我有两个程序。" master“产生执行一些计算的”worker“，我希望master从worker获取结果并存储和。我尝试使用MPI_Reduce从工人那里收集结果，工人使用MPI_Reduce将结果发送到主MPI_Comm。我不确定这是不是正确的。以下是我的程序：
师父：
#include <mpi.h>
#include <iostream>
using namespace std;
int main(int argc, char *argv[]) {
int world_size, universe_size, *universe_sizep
浏览 0提问于2013-02-06得票数 4
回答已采纳
MPI_Irecv和MPI_Isend操作返回一个MPI_Request，该MPI_Request稍后可以被标记为用MPI_Cancel取消。是否有类似的机制来阻止MPI_Probe和MPI_Mprobe？
问题的上下文是使用探测的的最新实现。
编辑-下面是如何使用假想的MPI_Probecancel的示例：
#include <mpi.h>
#include <chrono>
#include <future>
using namespace std::literals::chrono_literals;
// Executed in a thre
浏览 4提问于2019-11-19得票数 0
我知道对MPI_Irecv的调用需要与MPI_Wait (或MPI_Test等)配对。完成。然而，在MPI_Ssend下面的代码似乎正在迫使Irecv完成。
#include <iostream>
#include "mpi.h"
int main(int argc, char **argv) {
MPI_Init(&argc, &argv);
int rank = 0;
int size = 0;
MPI_Comm_rank(MPI_COMM_WORLD, &rank);
MPI_Comm_size(MPI_CO
浏览 3提问于2022-08-16得票数 0
2回答
C性能慢
、、、
我正在努力学习MPI，并在我的笔记本电脑(i5-4260 U和4GB RAM)上使用Windows上的MPI来实现缓慢的性能。我已经为MPI安装了Cygwin和适当的库。我还使用CLion，并使用设置MPI。
我已经成功地在CLion上构建了代码，并在MPICC上编译了它。但是，当我使用MPI运行时，程序需要很长时间才能运行。当我正常运行程序而不使用mpirun时，它运行得很好。即使我只指定了一个进程，程序仍然需要超过一分钟的时间打印出"Hello“。
我的笔记本电脑是性能缓慢的原因，还是我没有正确设置MPI以获得最佳性能？谢谢!
代码：
/*Simple MPI Hello Worl
浏览 3提问于2017-11-14得票数 2
回答已采纳
1回答
MPI通信器的范围
、、、、
我是MPI的新手，我想玩一下它，也就是围绕它的boost包装器实现。所以现在我想知道“什么时候”MPI才开始在多个节点上工作。我在文件中读到：
mpi::environment对象是使用主程序中的程序参数(它可能修改)初始化的。创建此对象将初始化MPI，其销毁将最终完成MPI。在绝大多数Boost.MPI程序中，mpi：：环境的一个实例将在程序开始时主要声明。
但是，如果我希望代码在初始化MPI (仅在主节点上)之前做几件事，但不希望在它们周围有一个if -子句，该怎么办？MPI是否只是在几个节点上启动相同的代码，而通信器只是告诉不同的节点它们有哪些进程号？然后开发人员通过子句决定哪个节点
浏览 2提问于2021-07-01得票数 0
1回答
如果我想列出每个通信器的变量id，我如何做到这一点？下面是一个试图证明这一想法的尝试：
from mpi4py import MPI
comm = MPI.COMM_WORLD
obj = "I am an example. My ID is unique to each communicator."
mpi_id = 'rank %i has id %s'%(comm.rank, str(id(obj)))
comm.send(mpi_id, tag=11, dtest=comm.rank)
mpi_id_list = []
for i in range(
浏览 3提问于2016-04-07得票数 0
回答已采纳
我正试图让MPI断开一个通信器，这是一个棘手的业务-我已经把下面的演示。我有两个相同想法的版本，侦听一个int，一个使用MPI_IRecv，另一个使用boost::mpi::request。
您将注意到在此程序上使用mpiexec -n 2时，版本A将很高兴地断开和退出，但是版本B不会。mpi_ trick _free有什么窍门吗？这似乎是不同之处。如果有关系，我使用的是MSVC和MSMPI，并提高了1.62。
#include "boost/mpi.hpp"
#include "mpi.h"
int main()
{
MPI_Init(NULL, N
浏览 3提问于2017-05-19得票数 2
回答已采纳
1回答
我有下面的MPI/fortran代码来创建两个组，一个包含处理器总数的前2/3，第二个包含剩下的1/3。它编译时没有问题，但当我打印出新的排名(在最近创建的组中)时，只有第二组显示正确的排名，第一组中的进程显示负数。
你对此有何评论？谢谢。
program test
implicit none
include "mpif.h"
integer, allocatable :: rs_use(:),ks_use(:)
integer numnodes,myid,mpi_err
integer ijk,new_group,old_group,
浏览 1提问于2015-07-29得票数 3
1回答
我在这段代码中使用了MPI，这是一个在进程之间传递的消息环，进程n从n-1接收消息，然后发送到n+1。
#include "mpi.h"
#include <stdio.h>
int main(argc,argv)
int argc;
char **argv;
{
int MyProc, size,tag=1;
char msg='A', msg_recpt;
MPI_Status status;
MPI_Init(&argc, &argv);
MPI_Comm_rank(MPI_COMM_WORLD, &a
浏览 2提问于2018-11-17得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
对象存储
即时通信 IM活动推荐
腾讯云开发者
