MPI忙碌等待响应
MPI（Message Passing Interface）是一种用于并行计算的通信协议和编程模型。它允许在多个计算节点之间进行消息传递和同步操作，以实现并行计算任务的协同工作。
MPI的分类：
MPI可以分为标准MPI和厂商特定的MPI实现。标准MPI是一种通用的并行编程接口，由MPI论坛制定并发布，包括了一系列的函数和语义规范。而厂商特定的MPI实现则是由不同的厂商根据标准MPI进行实现和优化，以适应不同的硬件和软件环境。
MPI的优势：
- 高性能：MPI通过消息传递的方式实现节点间的通信，可以充分利用计算资源，实现高效的并行计算。
- 可扩展性：MPI可以在大规模的并行计算集群中进行扩展，支持数千甚至数百万个计算节点的并行计算。
- 灵活性：MPI提供了丰富的通信和同步操作，可以灵活地实现各种并行算法和应用。
- 跨平台：MPI是一个跨平台的并行编程接口，可以在不同的操作系统和硬件平台上使用。
MPI的应用场景：
- 科学计算：MPI广泛应用于科学计算领域，如天气预报、气候模拟、物理模拟等需要大规模并行计算的领域。
- 数据分析：MPI可以用于大规模数据的并行处理和分析，如大规模数据挖掘、机器学习等。
- 并行算法：MPI提供了丰富的通信和同步操作，可以用于实现各种并行算法，如并行排序、并行图算法等。
腾讯云相关产品和产品介绍链接地址：
腾讯云提供了一系列与MPI相关的产品和服务，包括：
- 弹性容器实例（Elastic Container Instance）：提供了一种轻量级的容器实例服务，可以方便地部署和管理MPI应用。 产品介绍链接：https://cloud.tencent.com/product/eci
- 弹性MapReduce（EMR）：提供了一种大数据处理和分析的解决方案，支持MPI等并行计算框架。 产品介绍链接：https://cloud.tencent.com/product/emr
- 弹性高性能计算（Elastic HPC）：提供了一种高性能计算的解决方案，支持MPI等并行计算框架。 产品介绍链接：https://cloud.tencent.com/product/ehpc
以上是腾讯云提供的与MPI相关的产品和服务，可以根据具体需求选择适合的产品进行使用。
相关·内容
2回答
我有一个MPI程序，由一个主进程组成，它将命令传递给一组从进程。在接收到命令时，从节点只需调用system()来执行此操作。当奴隶在等待命令时，他们消耗了各自CPU的100%。探测()似乎处于一个紧密的循环中，但这只是猜测。你认为是什么导致了这一切，我能做些什么来解决这个问题呢？
下面是等待命令的从进程中的代码。同时观察日志和top命令表明，当奴隶使用他们的CPU时，他们就在这个函数中。
MpiMessage
Mpi::BlockingRecv() {
LOG(8, "BlockingRecv");
MpiMessage result;
MPI::Status s
浏览 3提问于2013-01-28得票数 10
回答已采纳
我有一个在main()中使用C与openMPI并行的算法；它工作得很好，但现在我想将代码移到外部函数中。
void my_parallel_function(int v[], int size, int rank)
{
if(rank==0)
{
MPI_Send(&v[0], 5, MPI_INT, 1, 1, MPI_COMM_WORLD);
}
else
{
MPI_Recv(&v[0], 5, MPI_INT, MPI_ANY_SOURCE, 1, MPI_COMM_WORLD,&status);
pr
浏览 1提问于2013-11-12得票数 0
回答已采纳
2回答
我正在使用MPI解决负载平衡问题:主进程将任务发送到从进程，并在从进程计算并发回其作业时收集结果。因为我想尽可能提高性能，所以我使用非阻塞通信: Master发送多个任务，然后等待，直到一个进程发回它的响应，这样master就可以向它发送额外的工作，等等。
我使用MPI_Waitany()，因为我事先不知道哪个从进程首先响应，然后我从状态中获取发送者，然后将新作业发送给它。
我的问题是，有时我得到的发送者是错误的(一个等级不在MPI_COMM_WORLD中)，程序崩溃；其他时候它工作得很好。
这是代码。谢谢!
//master
if (rank == 0) {
int N_chunk
浏览 0提问于2018-01-10得票数 0
2回答
高效收集/分散任务
、、、、
我正在使用的MPI实现本身并不支持完整的多线程操作(由于复杂的原因，最高级别是MPI_THREAD_SERIALIZED )，所以我尝试将来自多个线程的请求集中到一个工作线程中，然后将结果分散到多个线程中。
通过使用并发队列，我可以很容易地处理收集本地请求任务，并且MPI本机支持将异步任务入队。然而，问题是让双方相互对话：
为了将响应分散到各个线程，我需要对当前正在进行的请求调用类似MPI_Waitany的函数，但在此期间MPI worker实际上被阻塞了，因此它无法从本地worker收集和提交任何新任务。
// mpi worker thread
std::vector<MPI_Req
浏览 2提问于2016-06-20得票数 4
我注意到并不是所有的MPI_Isend/MPI_IRecv都在执行。我认为这可能是因为我执行发送和接收的顺序，或者是代码不等待所有命令执行的事实。我已经从下面的代码中复制了摘录。你能建议一下我可能做错了什么吗？
谢谢!
MPI_Status status[8];
MPI_Request request[8];
....
....
if ((my_rank) == 0)
{
MPI_Isend(eastedge0, Rows, MPI_DOUBLE, my_rank+1, 0, MPI_COMM_WORLD, &request[0]);
MPI_Irecv(wes
浏览 0提问于2011-05-19得票数 0
回答已采纳
当我试图在四个处理器上运行一个问题时，会收到以下的错误序列。我使用的MPI命令是mpirun -np 4。
我为发布错误信息而道歉(主要是因为缺乏解密信息的知识)。如能就下列事项提供意见，将不胜感激：
错误消息是什么意思？一个人在什么时候收到它？是由于系统内存(硬件)，还是由于通信错误(与MPI_Isend/Irecv有关)？即软件issue).Finally，如何修复？
谢谢!
收到的错误消息如下：- - *请注意:此错误仅在时间很长时才会收到。当计算数据所需的时间较短时，代码计算得很好(即300个时间步骤，而不是1000个时间步骤)
中止作业：
MPI_Irecv中的致命错误:其他MPI错
浏览 2提问于2011-06-02得票数 1
回答已采纳
假设我在一系列对MPI_ISEND (或MPI_IRECV)的调用中启动了一个非阻塞的MPI_IRECV请求数组。我将请求信息存储在数组xfer_rqst中。我的理解是，当请求完成时，它在xfer_rqst中的相应值将被设置为MPI_REQUEST_NULL。此外，我的理解是，如果对MPI_WAITALL进行调用，只有在xfer_rqst中的某些请求除了MPI_REQUEST_NULL之外还有其他值时，它才会有工作要做。如果我做对了，那么，如果在我们到达MPI_WAITALL调用之前，所有请求都完成了，那么对于所有意图和目的，MPI_WAITALL都将是不操作的。如果我对这一切都是正确的(吼小
浏览 5提问于2022-07-27得票数 0
回答已采纳
#include "mpi.h"
#include <stdio.h>
int main(int argc,char *argv[]){
int numtasks, rank, rc, count, tag=1, i =0;
MPI_Status Stat;
MPI_Init(&argc,&argv);
MPI_Comm_size(MPI_COMM_WORLD, &numtasks);
MPI_Comm_rank(MPI_COMM_WORLD, &rank);
if (rank ==
浏览 1提问于2018-10-05得票数 0
我正在尝试做一个简单的服务器应用程序，所以我需要循环，直到有一个连接，然后再次循环，等等…但是当我这样做的时候，我得到了50-100%的cpu使用率，而我使用的是互斥锁和条件，有没有办法避免在c中使用posix线程(Pthread)呢？如果是的话，你能举个例子吗？
浏览 2提问于2011-03-22得票数 0
回答已采纳
1回答
我试图在mpi中使用动态进程创建，但是我在接收子进程的响应时遇到了问题。我创建了一个名为sum_partial的向量来存储每个子级的结果。当我使用4个进程(1个父进程+3个子进程)运行时，工作正常。但是，当我使用更多的进程运行时，sum_partial不会得到一些子进程的结果。
我不确定问题是MPI_Irecv还是MPI_Waitany。我尝试过使用MPI_Wait、MPI_Waitall、MPI_Test的其他方法。然而，这个问题一再出现。
下面是我在父进程中使用的MPI代码块。
//Some code here...
for(j=0;j<num_Proc;j++){
spr
浏览 5提问于2017-10-04得票数 0
回答已采纳
我是MPI编程的新手，我正在尝试创建一个程序，在一个环中的进程之间执行双向通信。
我在MPI_Finalize()语句中得到了MPI_Finalize错误。后来，我发现我可以使用-fsanitize=address -fno-omit-frame-pointer标志来帮助我调试泄漏可能出现的位置。
现在我犯了一个很奇怪的错误(至少对我来说是这样)。
这是我的密码：
MPI_Request request_s1, request_s2, request_r1, request_r2;
// receiving 2 elems from the left neig
浏览 4提问于2022-04-22得票数 0
1回答
为了重叠MPI通信和计算，我正在对来自I/O的数据发出异步I/O (MPI调用)和用户定义的计算功能。
MS-窗口的“重叠”不是MPI的朋友(它只支持文件I/O和套接字通信的重叠I/O，但不支持MPI操作.)
我找不到适合它的MPI API，有没有人对它有一瞥？
浏览 8提问于2015-11-17得票数 1
回答已采纳
此MPI程序是用C编写的。当我输入2作为处理器数时，输出如下：
P:0 Got data from processor 1
P:0 Got 100 elements
P:0 value[5]=5.000000
但是当我输入3个或更多处理器时，程序就会输出。
P:0 Got data from processor 1
P:0 Got 100 elements
P:0 value[5]=5.000000
然后它停了下来，其他的东西都没有印出来。我必须用ctrl+c退出程序，我不知道为什么程序会停止。我希望得到一些提示或好的指导。
以下是代码：
#include <stdio.h&
浏览 4提问于2014-09-30得票数 0
回答已采纳
2回答
当我执行这段代码时，我没有响应，它会永远等待，进程1正在向根进程发送数据，但是根进程没有接收到它(或者说，这几乎就是我所认为的)。
#include <stdio.h>
#include <stdlib.h>
#include "mpi.h"
void my_parallel_function(int v[], int size, int rank)
{
MPI_Status status;
int i;
if(rank==0)
{
MPI_Send(&v[0], 10, MPI_INT, 1, 1, MP
浏览 1提问于2013-11-12得票数 1
回答已采纳
1回答
我按照示例添加了一些测试代码，但是当我添加新代码时，出现了一些奇怪的结果。结果如下所示。它挂在这里，不能继续下去了。
[0]: Before Bcast, buf is 777
[1]: Before Bcast, buf is 32767
[0]: After Bcast, buf is 777
从两个角度来看，这是很奇怪的：
当代码是if(rank==i) if(i==0)时它不会挂断
乳清buffer[1]在bcast之前不是0。
以下是代码：
#include <mpi.h>
#include <stdio.h>
#include <std
浏览 2提问于2014-11-04得票数 0
回答已采纳
我想知道为什么我要使用MPI_Wait来等待MPI请求完成？
所以，在MPI_Send作用域的末尾，我会使用MPI_Wait方法，但是为什么呢？在我的理解中，MPI_Send只发送一条消息，并不等待请求完成，但是MPI_ISend会！
谢谢。
浏览 3提问于2013-07-11得票数 3
回答已采纳
1回答
我在做一堆MPI_Iallreduce非阻塞通信。我在代码中将这些Iallreduce调用添加到了几个不同的位置。经常，我想暂停并等待所有的Iallreduce调用完成。
使用MPI_Request 簿记的版本1 --这是工作的：
MPI_Request requests[];
MPI_Iallreduce(..., requests[0]);
...
MPI_Iallreduce(..., requests[n-1]);
for(int i=0; i<n; i++){
MPI_Wait(requests[i], ...);
}
但是，我正在编写一个相当大的代码库，我不想编写
浏览 9提问于2015-06-03得票数 4
回答已采纳
请看下面的MWE，它显示了在我看来，使用MPI_Irecv和MPI_ANY_SOURCE报告作为源的整数值"-1“是如何成功地进行通信的。
该示例包括命令行输出，如下所示。在这一行中，它SigFaults作为"-1“索引，稍后用作发送源。
嗨！(fun2)嗨！(fun1)嗨！(fun1)嗨！(fun2)发送！0标志为1，源为-1，错误为0，状态标志为0。
发送！0标志为1，源为-1，错误为0，状态标志为0。
#include <iostream>
#include "mpi.h"
#include <omp.h>
#include &l
浏览 2提问于2021-11-17得票数 1
回答已采纳
我正在尝试将经典的MPI_Issend MPI_Irecv并行化，用于与OpenMP线程和MPI_THREAD_MULTIPLE交换光环。也就是说，每个线程将向右和向左发送主缓冲区的一部分，每个线程负责从右和左获取缓冲区的一部分。
#pragma omp parallel private(i,tid)
{
tid = omp_get_thread_num();
nthreads = omp_get_num_threads();
// starting position for each thread
int sizeid = SIZE/nthreads;
浏览 1提问于2016-12-17得票数 0
回答已采纳
1回答
我需要编写一个MPI程序，它只需要在不同的集群节点上启动几个进程。这是我的代码样本。
#include <stdio.h>
#include <mpi.h>
int main(int argc, char *argv[]) {
int rank, size, nodenamesize;
char nodename[100];
MPI_Init(&argc, &argv);
MPI_Comm_rank(MPI_COMM_WORLD, &rank);
MPI_Comm_size(MPI_COMM_WORL
浏览 1提问于2012-06-11得票数 1
我正在使用valgrind运行一个多线程套接字程序。客户端将通过TCP向服务器发送一个请求，然后忙于等待一个布尔值。布尔值将在调用为来自服务器的响应提供服务的回调函数时设置。一旦接收到响应(并且设置了boolean标志)，服务器将再次发出请求，并在循环中重复执行此操作。
我意识到对共享变量(布尔值)的非同步访问可能会导致线程问题，但我尝试过使用pthread互斥锁，程序的速度慢了大约20% (这里的速度很重要)。我确信写入共享布尔变量是很好的，因为它可以在单个周期内完成。
该程序在valgrind之外运行得很好，但在使用valgrind运行时经常会停滞。我让程序运行了一夜..通常它需要几秒钟才
浏览 0提问于2011-12-29得票数 8
回答已采纳
1回答
我正在尝试从左到右发送缓冲区(0->1，1->2 2->3等)。我非常确定进程发送和接收的是正确的合作伙伴，但代码挂起或输出了seg错误。
#include "mpi.h"
#include <iostream>
int main(int argc, char *argv[])
{
int comm_rank, num_procs, recieve1, send1;
int buffer[10];
MPI_Request request, request2;
MPI_Status status;
MPI_Init(&argc,&a
浏览 1提问于2017-01-18得票数 1
回答已采纳
嗨，我对OpenMPI非常陌生，我刚刚开始玩它。我想知道MPI_Barrier和MPI_Waitall之间有什么区别，因为它们都要求在继续代码之前完成所有的操作。谢谢!
浏览 0提问于2018-01-21得票数 0
回答已采纳
我有一个第一个进程(test1)，它动态地产生第二个进程(test2)，然后等待接收来自派生组的带有标记1的消息。派生的进程执行一些计算，然后向父组(包含第一个进程)发送带有标记1的消息，说明它已经完成，最后调用MPI_Finalize。第一个进程正确地接收消息并继续，但第二个进程挂起在MPI_Finalize中。我不明白是什么阻止了第二个过程的结束。
测试1
#include <stdio.h>
#include "mpi.h"
int main() {
int flag_mpi, erc, err_mpi, ndr;
MPI_Comm comm;
MPI_I
浏览 2提问于2014-02-17得票数 0
回答已采纳
1回答
我正在使用java async servlet来执行长时间运行的任务，这些任务是使用部署在weblogic中的jersey实现的。 @GET
@Path("/asyncjob")
@Produces(MediaType.TEXT_PLAIN)
public void asyncJob(@Suspended final AsyncResponse asyncResponse) {
ExecutorService executor = Executors.newFixedThreadPool(1);
executor
浏览 25提问于2020-08-20得票数 1
我使用MPI并行化了一个Fortran代码。在共享点，我从模型中的所有进程使用MPI_Isend将所有数据发送到缓冲区。然后，每个进程使用MPI_Recv收集所需的数据。由于MPI_Recv是阻塞的，我知道每个进程在继续其计算之前都会得到它所需的数据。因此，我忽略了MPI_Isend提供给我的请求代码。我将其设置为不保留的整数。我从不给MPI_Wait打电话。当我运行我的代码时，我注意到它在每次迭代时占用了更多的内存，我想知道是不是因为我没有调用MPI_Wait，因为在文档中，MPI_Wait说：
如果与此请求关联的通信对象是由非阻塞发送或接收调用创建的，则该对象是通过调用MPI_WAIT解
浏览 2提问于2013-08-02得票数 4
回答已采纳
1回答
我正在用MPI库用C++写一个程序。只有一个节点工作时才会发生死锁！我使用的不是发送或接收集合操作，而是两个集合函数(MPI_Allreduce和MPI_Bcast)。如果有节点等待另一个节点发送或接收东西，我实际上不明白是什么导致了这个死锁。
void ParaStochSimulator::first_reacsimulator() {
SimulateSingleRun();
}
double ParaStochSimulator::deterMinTau() {
//calcualte minimum tau for this process
l_nLocal
浏览 1提问于2017-05-05得票数 0
1回答
并行相乘矩阵问题
、、、、
我在使用乘法矩阵时遇到了困难。
我有程序从两个文件中读取两个n×n矩阵，并且应该使用MPI。但是我在其中一个进程中得到了一个分段错误。这是我在运行代码时得到的输出：
read matrix A from matrixA
read matrix B from matrixB
mpirun注意到，在信号11 (分段故障)中，节点VirtualBox上的进程等级为1，PID为15599。
这是我的代码：
int main (int argc, char * argv[])
{
/* Check the number of arguments */
int n; /* Dime
浏览 7提问于2012-12-01得票数 2
1回答
我想知道是否有可能从一个发送者并发接收消息，反过来，将消息并发发送到一个接收者。如果是，它将如何表现？
为了使问题更清晰，假设我们有4个线程，每个线程都在监听来自相同来源的消息
MPI_Recv(buf, count, type, THE_SAME_SOURCE, tag, status)
所有这些线程都在相同的MPI进程中，因此它们都具有相同的MPI等级。而来自其他MPI进程或相同但来自不同线程的人，则称为MPI_Send。是每个接收者都收到相同的消息，还是只有一个接收者，或者抛出了一些异常(发生了错误)？
反过来，如果4个线程(在相同的MPI进程内或不在同一MPI进程内)将消息发送到也可能
浏览 0提问于2011-09-08得票数 2
回答已采纳
2回答
我开发的MPI程序可以在分布式环境下在不同的核上执行，并通过获取节点的主机名来演示在不同节点上的执行。但是，当我们在单个节点上运行程序时，我可以得到核心id，它演示了在多个节点上的执行示例代码如下
#include"stdio.h"
#include"stdlib.h"
#include"mpi.h"
int main(int argc , char **argv)
{
int size,rank;
int a,b,c;
MPI_Init(&argc, &argv);
MPI_Comm_size(MPI_COMM_WORLD,
浏览 5提问于2013-11-13得票数 2
回答已采纳
1回答
下面的代码使用双指针malloc方法创建一个矩阵m，并使用非阻塞的n-1函数向每个n-1处理器发送相同数量的矩阵块。处理器P=0负责生成矩阵并发送矩阵，以便每个P != 0处理器接收一组行并处理它们。
尽管我花了好几天时间来确保每一行都是正确的，但是我不知道这些but是从哪里来的:(我很感谢任何帮助。
#include <stdio.h>
#include <string.h>
#include <time.h>
#include "mpi.h"
int main (int argc, char* argv[]) {
cons
浏览 3提问于2015-09-12得票数 1
回答已采纳
1回答
当我试图运行此代码消息时，“死锁:试图在没有事先匹配的接收的情况下向本地进程发送消息”。
#include "pch.h"
#include <iostream>
#include <mpi.h>
using namespace std;
void main(int argc, char* argv[])
{ int ierr, procid, numprocs;
ierr = MPI_Init(&argc, &argv);
ierr = MPI_Comm_rank(MPI_COMM_WORLD, &proc
浏览 1提问于2022-05-12得票数 0
1回答
我正在构建一个简单的应用程序，它在三次迭代中构建一个逻辑圈，然后打印结果。首先，我使用阻塞Send和Recv，从进程0，我使用Send和Recv，直到最后的n-1个进程，它发送到进程0。在进程0中，我在main中有以下代码：
int i;
MPI_Status status;
MPI_Init(&argc, &argv);
MPI_Comm_size(MPI_COMM_WORLD,&numtasks);
MPI_Comm_rank(MPI_COMM_WORLD;&myrank);
if(myrank==0){
for(i=0;i
浏览 2提问于2011-02-27得票数 1
我有一些设置，在这些设置中，所有进程都有一个连续的工作块，我希望在最后将所有输出保存为一个文件，如下所示：
int start_ind = split_work(mpi_rank, mpi_size), end_ind = split_work(mpi_rank+1, mpi_size);
vector<double> results;
for(int i=start_ind; i<end_ind; i++){
results[i] = do_work(i);
}
MPI_File handler;
MPI_File_open(MPI_COMM_WORLD, fil
浏览 10提问于2019-11-21得票数 0
回答已采纳
我使用MPI在4个节点上总共传递了8条消息。我注意到有两条消息的数组没有提供有意义的结果。我抄写了下面代码的摘录吗？以下是我根据下面的代码/结果提出的一些相关问题：
MPI_Isend也需要等待吗？我不确定是否有僵局。我还尝试将这两个变量从一个节点传递到另一个节点，数组值仍然为NULL。 MPI_SendRecv会像这里建议的那样提高代码的效率吗？如果是，如何/为什么？也会感谢一些关于设置这方面的建议。
谢谢!
Source Code:
if ((my_rank) == 0)
{
MPI_Irecv(A, Rows, MPI_DOUBLE, my_rank+1, MPI_ANY_TAG,
浏览 2提问于2011-05-19得票数 1
回答已采纳
我使用MPI已经有一段时间了，但我没有经验。因此，我在这里询问关于以下实现的一般结构的建议。比如说，我有一个主C++文件
MPI_Init(&narg,&arg);
int me,nprocs;
MPI_Comm_rank(MPI_COMM_WORLD,&me);
MPI_Comm_size(MPI_COMM_WORLD,&nprocs);
int N = 10;
for (int i=0;i<N;i++) {
//(1)do some stuff in parallel...
//(2)gather results and write a
浏览 2提问于2013-03-28得票数 0
回答已采纳
以下代码是Master/Worker模式的实现。 Ibcast用于终止所有工作进程，因为我们在程序开始时不知道问题的大小。 MPI_Waitany()用于等待Irecv获取新数据，Ibcast用于终止程序。 问题是在接收到来自主服务器的所有MPI_Send()之后，MPI_Waitany被阻塞。因此MPI_Ibcast()不会返回阻塞 if (myid == 0) { //Master
bool test = false;
MPI_Request mpi_request;
for (int i = 0; i < 10; ++i) {
//Sendi
浏览 21提问于2019-01-10得票数 0
回答已采纳
2回答
如果我在一台有2个-np的机器上运行一个需要3个节点的MPI程序(即mpiexecccc3 ./ program )，会发生什么？
浏览 0提问于2010-11-25得票数 5
2回答
我有两个WCF应用程序通过命名管道进行单向通信。一切都很好，除了一件事:正常情况下，请求/响应周期需要零(边缘)时间。但是，如果有半分钟没有任何通信的时间跨度，请求/响应将增加到大约300-500ms。
我环顾了一下网络，我有了使用心跳/ping机制来保持通信通道忙碌的想法。使用试错法，我发现当每10秒处理一次请求时，响应时间仍然很低。从大约15秒的间隔开始，开始出现“呃逆”响应时间。
现在我想知道这种现象是从哪里来的。我尝试将两端所有可能的超时设置为>1分钟，但无济于事。
有人能解释一下那里发生了什么吗？
浏览 0提问于2009-04-19得票数 2
回答已采纳
1回答
我正在尝试用mpi4py自学MPI消息传递接口。我注意到MPI有一个叫做"sendrecv“的函数。但是，它没有在mpi4py文档中列出：
我可以简单地使用下面的命令来模拟sendrecv函数吗
communicator.send(0xdeadbeef, dest=1, tag=0)
data = communicator.recv(source=1, tag=0)
除了模拟recv和send之外，"sendrecv“还能做什么？我在哪里可以找到关于它的mpi4py文档？
浏览 2提问于2012-10-22得票数 2
回答已采纳
1回答
我正在尝试写一个并行程序，用MPI和C语言实现一个管道版本的高斯消去法...
然而，我在代码实现的早期遇到了一些困难……
我使用根进程从文本文件中读取数据矩阵...这个进程给我这个矩阵的大小，我将它的大小广播给所有其他进程，以便它们在内存中分配它……然而，从进程试图在从根广播之前分配它...我怎么才能让他们等呢？
#include <stdio.h>
#include <stdlib.h>
#include <math.h>
#include <mpi.h>
int CalcInd(int i, int j, int dimL)
{
ret
浏览 1提问于2013-01-22得票数 2
1回答
我有一个应用程序，其中每个处理器需要发送数据到特定数量的处理器，并从未知数量的处理器接收数据，这些处理器的数据大小未知，同时执行本地操作。这就是我的想法：
MPI_Isend(...)
// Do local computation
MPI_Wait(...)
int flag;
MPI_Status st;
MPI_Iprobe(MPI_ANY_SOURCES, tag, &flag, comm, &st);
While(flag) {
MPI_Irecv(st.MPI_SOURCE,...);
MPI_Iprobe(MPI_ANY_SOURCES, tag
浏览 1提问于2014-01-26得票数 0
1回答
我是MPI的新手，我正在尝试用c语言编写一些代码。
void update(float ** cur, float ** next, int dimension, int numOfProcesses, int rank)
{
int i,j,numNeighbor, processReceived, receivedTop=0, receivedBot=0,
receivedLeft=0, receivedRight=0;
float *recvTop, *recvBot, *recvLeft, *recvRight, ** recvArray
浏览 2提问于2015-12-21得票数 0
回答已采纳
如果我先调用MPI_isend，然后调用MPI_irecv，或者先执行irecv，然后执行isend，最后等待？哪个顺序很重要吗？
浏览 6提问于2021-04-13得票数 0
情况: 1.使用MPI_Wait()获得的状态是什么？
if(rank==0)
MPI_Isend(&buffer0, count, MPI_INT, 1, 0, MPI_COMM_WORLD, &request0);
if(rank==1)
MPI_Recv(&buffer1, count, MPI_INT, 0, 0, MPI_COMM_WORLD);
if(rank==0)
MPI_Wait(&request0, &status);
// Can i use status here to do something?
MPI_Finalize();
浏览 0提问于2019-01-19得票数 0
回答已采纳
1回答
MPI消息可用性通知
、、、、
在MPI中是否有一种方法可以通知特定进程的消息的可用性？Currenlty -我使用轮询，使用异步MPI_Iprobe，然后是MPI_Recv。这意味着进程必须停止它正在做的事情，并不时调用此方法。是否有通过信号/中断通知消息可用性的方法？另一种选择是使用单独的线程进行轮询，但我不确定这是否可以接受，因为它占用了cpu时间。
int poll(int& source,int& message_id) {
int flag;
MPI_Status mpi_status;
MPI_Iprobe(MPI_ANY_SOURCE, MPI_ANY_T
浏览 1提问于2013-02-27得票数 2
回答已采纳
当我尝试用MPI_Isend从一个节点发送消息，并在另一个节点上使用MPI_Irecv接收消息时，我在c语言中学习mpi通信。以下是代码：
#include <stdlib.h>
#include <stdio.h>
#include <mpi.h>
#include <string.h>
#define TAG 3
#define ROOT 0
int main (int argc, char ** argv){
int number_of_proc = 0;
int rank = 0;
// initialize
浏览 1提问于2015-06-06得票数 3
回答已采纳
我知道对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种进程类型(根进程、子进程、ids/秩分别为10和0-9 )
init：
根将听孩子的“完成”
当所有内容都完成时，子节点将听取根通知。
虽然没有赢家(还没有全部完成)：
孩子们将有20%的机会完成他们(并通知根他们已经完成)
根目录将检查所有操作是否都已完成。
如果全部完成:向孩子们发送“赢家”的通知
我有这样的代码：
int numprocs, id, arr[10], winner = -1;
bool stop = false;
MPI_Request reqs[10]
浏览 2提问于2012-11-17得票数 3
回答已采纳
在MPI_IScatterv()函数中设置置换数组时，我遇到了问题。
我需要把图片的一部分分散到不同的过程中。我做了我自己的MPI_Datatype：
private: MPI_Datatype createMPI_PixelType(){
MPI_Datatype new_type;
int count = 3;
int blocklens[] = { 1,1,1 };
MPI_Aint indices[3];
indices[0] = (MPI_Aint)offsetof(struct Pixel, Red);
indices[1] = (MPI_Aint)offsetof(struc
浏览 2提问于2016-04-24得票数 2
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
