同步MPI共享文件指针
是一种在并行计算中使用的技术，用于在多个进程之间同步共享文件的读写位置。
MPI（Message Passing Interface）是一种用于并行计算的通信协议和编程模型，它允许多个进程在分布式内存系统中进行通信和协作。在MPI编程中，多个进程可以同时访问共享文件，但由于文件指针的位置是每个进程独立维护的，因此需要一种机制来确保多个进程之间的文件指针同步。
共享文件指针是指多个进程对同一个文件进行读写时，文件指针的位置是相同的。同步共享文件指针的目的是确保多个进程在读写文件时，能够正确地定位到文件的指定位置，避免数据错乱或重复读写的问题。
在MPI中，可以使用MPI_File_seek函数来同步共享文件指针。该函数可以将文件指针移动到指定的位置，并且可以指定移动的方式，如相对于文件开头、文件末尾或当前位置进行移动。通过在多个进程中调用MPI_File_seek函数，可以确保它们在读写文件时都从相同的位置开始。
同步共享文件指针在并行计算中非常重要，特别是在需要对大型数据集进行并行处理时。它可以确保多个进程之间的文件访问是有序的，避免了数据冲突和不一致的问题。
腾讯云提供了一系列适用于并行计算和云计算的产品和服务，包括云服务器、云存储、云数据库等。您可以通过访问腾讯云官方网站（https://cloud.tencent.com/）了解更多相关产品和服务的详细信息。
相关·内容
1回答
有没有一种标准的方法来同步MPI共享文件指针，以便MPI_File_get_position_shared在所有进程上返回相同的值？ 例如下面的程序： #include <mpi.h>
#include <stdio.h>
#include <string.h>
#include <unistd.h>
int main(int argc, char** argv) {
// Initialize the MPI environment
MPI_Init(NULL, NULL);
int rank;
MPI_C
浏览 35提问于2020-06-12得票数 0
在阅读MPI文档之后，听起来根本没有为您提供任何额外的功能。我假设它协调了网络流量，使得所有文件操作都与执行系统(发出mpirun命令的系统)上的给定文件一起工作，而不是使用每个单独主机上的本地文件系统。这将是有用的。相反，“用户”需要确保它们都在同一个文件中结束。很明显，他们对这个文件没有太多的交流...是吗？
MPI_File_open实际上做了什么，它有什么好处？为什么我不能只使用fopen呢？
浏览 1提问于2013-12-07得票数 3
我试图使用带有共享文件指针的MPI/O (OpenMPI实现)将几个长的分布式数组写入单个文件。我收到以下错误消息
无效论证
写入失败
我准备了一个简化的代码片段来重现这个问题。
long long globalUpperBnd = 2200000000;// more than size of int
long long average = globalUpperBnd/commSize;
long long length = (commRank == commSize-1) ? globalUpperBnd-(average*comm
浏览 2提问于2018-10-23得票数 0
1回答
我正在编写一个MPI程序，它需要将文件的一部分读取到内存中，一次一块，每一块都要进入一个可用的进程。因此，我使用了共享文件指针。文件的第一部分是一个头文件，我想要读取它并将其分发给所有进程，我已经设法通过在主进程上读取它并将其广播给所有其他进程来做到这一点。
文件的下一部分是一个很长(理论上最多几to )的三元组浮点数组。我想为所有进程设置文件视图，以便它从这个数组的开头开始，并且每个进程都应该能够看到整个数组。此外，这也是我真正的问题所在，我不想让进程看到这个数组之外的东西，这样在它们遇到最后一组3个浮点数后，它们就会报告EOF。因此，在实践中，每个进程只看到一个很长的3-float数组，而
浏览 0提问于2011-06-15得票数 2
回答已采纳
2回答
MPI-3标准引入了共享内存，共享该内存的所有进程都可以读取和写入共享内存，而无需调用MPI库。虽然有使用共享或非共享内存的单边通信的例子，但我没有找到太多关于如何通过直接访问正确使用共享内存的信息。
我最终做了这样的事情，它工作得很好，但我想知道MPI标准是否保证它总是有效的？
// initialization:
MPI_Comm comm_shared;
MPI_Comm_split_type(MPI_COMM_WORLD, MPI_COMM_TYPE_SHARED, i_mpi, MPI_INFO_NULL, &comm_shared);
// allocation
cons
浏览 2提问于2020-02-19得票数 3
1回答
例如，在并行MPI程序中，100个处理器：
如果有一个全局计数号码，所有MPI进程都应该知道，并且每个进程都可以添加到这个数字中，而其他进程应该立即看到变化并增加更改的值。
同步是不可能的，并且会有很多延迟问题。
是否可以在所有进程之间打开共享内存，并使用此内存访问这个数字，也可以更改这个数字？
使用MPI_WIN_ALLOCATE_SHARED或诸如此类的东西可以吗?还是这不是一个好的解决方案？
浏览 9提问于2013-10-28得票数 1
我有以下代码
program mpi_io
use mpi
implicit none
integer :: mpierr, whoami, nproc, iout, STATUS(MPI_STATUS_SIZE),charsize
integer(kind=mpi_offset_kind):: OFFSET, fs
character(len=60) :: dd,de
character:: newline = NEW_LINE('FORTRAN')
call MPI_INIT ( mpierr )
call MPI_COMM_RANK ( MPI
浏览 1提问于2019-08-07得票数 0
回答已采纳
2回答
MPI +函数指针？
、、、、
如果我在MPI配置中的Beowulf集群的多个节点上运行相同的二进制文件(这意味着相同的体系结构)，那么通过MPI传递函数指针作为告诉另一个节点调用函数的一种方式是否安全？在什么情况下，相同二进制文件中的相同函数可以在不同机器或不同实例上具有不同的虚拟地址？
浏览 7提问于2011-09-07得票数 1
考虑以下结构
typedef struct{
void *data;
int len;
}item_t;
它允许我将 item_t 传递给一个名为map_functions(item_t dt，item_t (*f_ptr)(item_t ) )的函数，该函数接受item_t和函数指针。
然后，map_functions()将通过将item_t传递给它来调用作为参数传递的函数。请记住，有不同的函数将调用map_functions()，每个函数具有、item_t、的不同内容，并传递它们想要调用的相应函数。
这一切对我来说都很好。
现在，我想用MPI做
浏览 1提问于2012-09-18得票数 2
1回答
我有两个关于使用mpi共享内存通信的问题。
1)如果我的MPI级别是唯一写入窗口的级别，那么是否有必要使用mpi_win_lock和mpi_win_unlock？我知道我的应用程序永远不会让其他人试图写到那个窗口。它们只读取窗口的内容，而我确保它们是在MPI_BARRIER之后读取的，因此窗口的内容已经更新。
2)在我的应用程序中，我有一个MPI级别，它分配一个共享窗口，需要由1:N其他MPI级别读取。
MPI级别1只应改为: rma(1:10)
MPI等级2只应改为rma(11:20)。
MPI等级N只应改为rma(10*(N1)+1:10*N)
目前，所有1到N级别都在查询整个共享窗口，即
浏览 0提问于2019-08-07得票数 0
回答已采纳
1回答
至于mpi编程，我应该在什么时候对io使用集体操作？什么时候应该对单个文件指针IO操作使用共享文件指针IO操作？
浏览 1提问于2016-10-21得票数 1
回答已采纳
1回答
据我所知，这是用来使所有进程处于同一级别。我需要找出openMPI程序的总体处理时间(所有进程完成的时间)，所以我认为将MPI_Barrier()放在最后，然后在最后打印MPI_Wtime()-t将打印所有进程完成的时间。
MPI_stuff;//whatever i want my program to do
MPI_Barrier(MPI_COMM_WORLD);
cout << "final time ::: :: " << MPI_Wtime()-t << rank <<
浏览 0提问于2013-07-11得票数 1
回答已采纳
1回答
我看到一些开源代码在广播根值之前使用了MPI_Barrier：
MPI_Barrier(MPI_COMM_WORLD);
MPI_Bcast(buffer, N, MPI_FLOAT, 0, MPI_COMM_WORLD);
MPI_Barrier(MPI_COMM_WORLD);
我不确定MPI_Bcast()是否已经有了自然阻止功能。如果这是真的，我可能不需要MPI_Barrier()来同步所有内核的进度。那么我只能使用：
MPI_Bcast(buffer, N, MPI_FLOAT, 0, MPI_COMM_WORLD);
那么哪一个是正确的呢？
浏览 8提问于2021-01-13得票数 0
2回答
我正在用MPI编写Mergesort来对整数数组进行排序。这样做的目的是将数组的左半部分合并到相同的级别上，同时将数组的右半部分发送到子级别。因此，如果有四个procs，看起来是这样的：
rank 0, a[0..N]
/ \
rank 0, a[0..N/2] rank1, a[N/2..N]
/ \ / \
浏览 1提问于2014-04-05得票数 2
回答已采纳
void iso_diffusion_denoising(image *u, image *u_bar, float kappa, int iters) {
int my_rank,num_procs;
float *temp;
int i,j,k=0;
MPI_Comm_rank(MPI_COMM_WORLD, &my_rank);
MPI_Comm_size(MPI_COMM_WORLD, &num_procs);
int m=u->m;
int n=u->n;
//temp= malloc(n*sizeof(float));
浏览 0提问于2012-04-29得票数 0
回答已采纳
1回答
我有一个大规模的代码，运行在许多CPU核上，可能跨越多个计算节点。代码在C++中，并与OpenMPI并行化。
我的代码有一个非常大的对象(~10 by内存使用量)，每个MPI进程都从它读取。这个对象偶尔会被更新(并且可以通过一个进程来完成，只需读取一个数据文件)。
到目前为止，我所做的是给每个MPI进程一个这个对象的副本；但这意味着我的RAM非常有限，不能使用我的节点的全部CPU功能。因此，我一直在阅读MPI 3规范中的共享内存。
我的问题是:在MPI进程之间共享复杂对象的最佳方法是什么？在我发现的所有示例中，MPI共享内存窗口被创建并用于交换简单的数据结构(浮点数、ints数组等)。我的全局
浏览 7提问于2016-06-09得票数 2
回答已采纳
1回答
MPI大数据处理
、、、
我的MPI应用程序会读取一系列的图像来构建三维数据。这是非常大的数据(大约4 GB)。我不想把数据分发给每个工人。我不知道怎么处理这个。共享内存可能是一种解决方案。而是如何通过MPI来使用共享内存。关于这一点我已经搜索了很多，没有找到任何好的东西。有人能给我一些使用MPI (BTW )处理大数据的建议或例子吗？我正在使用Open MPI实现)。非常感谢你的大力帮助。
浏览 0提问于2012-03-07得票数 0
回答已采纳
假设我有一些代码，如下所示：
#include "mpi.h"
int main( int argc, char** argv )
{
int my_array[10];
//fill the array with some data
MPI_Init(&argc, &argv);
// Some code here
MPI_Finalize();
return 0;
}
每个MPI实例都会有自己的my_array副本吗？只有排名0吗？都不是吗？在MPI_Init之前编写代码是不是很糟糕？
浏览 0提问于2012-07-28得票数 3
1回答
我正在重写一个数值模拟代码，它是使用MPI向一个方向并行化的。到目前为止，包含数据的数组由主MPI进程保存，这意味着将数据从所有MPI进程转移到一个进程中，并分配巨大的数组来存储整个事件。它既不是很有效，也不是很优雅，对于大分辨率来说也是个问题。
因此，我试图使用MPI直接从分布式数组写入文件。我所拥有的约束之一是，编写的文件需要遵守fortran“未格式化”格式(即在每个字段之前和之后显示其大小的4个字节整数)。
我编写了一个简单的测试程序，当我只向文件写入一个分布式数组时，这个程序就能工作。但是，当我编写几个数组时，文件的总大小是错误的，并且当与等效的fortran‘未格式化’文件相比，文
浏览 1提问于2015-08-28得票数 5
回答已采纳
我目前正在使用MPI开发一个C程序，我遇到了一个关于MPI_Send()和MPI_Recv()函数的障碍，我希望你们都能帮我解决这个问题。我的目标是发送(使用MPI_Send())和接收(使用MPI_Recv())，地址"a“(定义如下)，然后在从MPI_Recv()收到地址后显示该地址的内容，以确认我的发送和接收是否正常。我在下面概述了我的问题：
我有一个二维数组"a"，它的工作方式如下:a包含我的目标地址*a包含我的目标值。
即printf("a[0][0] Value = %3.2f, a[0][0] Address = %p\n", *a[0][
浏览 4提问于2014-12-02得票数 1
回答已采纳
3回答
我正在运行一个具有数千个MPI进程的模拟，并且需要将输出数据写入一小组文件。例如，尽管我可能有10000个进程，但我只想写出10个文件，每个文件都有1000个写入文件(在适当的偏移量下)。正确的方法是为将要写入相同文件的进程组创建一个新的通信器，使用MPI_File_open()为该通信器打开一个共享文件，然后使用MPI_File_write_at_all()写入该文件。对吗？下面的代码是我编写的一个玩具示例：
#include <mpi.h>
#include <math.h>
#include <stdio.h>
const int MAX_NUM_F
浏览 4提问于2017-02-24得票数 0
回答已采纳
我想在进程之间使用共享内存。我尝试了MPI_Win_allocate_shared，但当我执行程序时，它给了我一个奇怪的错误：
在文件./src/mpid/ch3/include/mpid_rma_shm.h的第592行：local_target_rank >= 0 internal ABORT中断言失败
这是我的资料来源：
# include <stdlib.h>
# include <stdio.h>
# include <time.h>
# include "mpi.h"
浏览 3提问于2016-05-14得票数 3
我正在尝试采用我的代码来利用MPI共享内存。
为了使事情尽可能简单，想象一下我只有两个核心。核心A需要来自核心b的size_b数组，而核心b需要来自核心a的size_a数组
在核心A上执行时，可以执行以下操作？
call MPI_WIN_ALLOCATE_SHARED(size_a_in_BYTES, disp_unit, MPI_INFO_NULL, comm_shm, ptr, win_a, mpierr)
call C_F_pointer(ptr, fptr, (/size_a/))
以及核心B
call MPI_WIN_ALLOCATE_SHARED(size_b_in_BYTE
浏览 0提问于2019-04-02得票数 3
回答已采纳
3回答
通过MPI发送函数指针
、、、、
通过MPI传递函数指针作为通知另一个节点调用函数的方式安全吗？有人可能会说，通过MPI传递任何类型的指针都是毫无意义的，但我编写了一些代码来验证它。
//test.cpp
#include <cstdio>
#include <iostream>
#include <mpi.h>
#include <cstring>
using namespace std;
int f1(int a){return a + 1;}
int f2(int a){return a + 2;}
int f3(int a){return a + 3;}
using
浏览 0提问于2016-10-11得票数 2
回答已采纳
1回答
假设我在5个节点上运行一个MPI程序，它将运行50次模拟。然而，模拟可能需要明显不同的时间。如果我有一组初始条件，比如ic1、ic2、...ic50，当一个节点/进程完成一个模拟时，我希望它使用下一个(尚未使用)初始条件集来运行一个新的模拟。我最初的想法是使用MPI_Bcast或MPI_Gather s.t。所有节点都有一个int来保存要运行的下一个索引，并在开始新的模拟之前更新它。这是否是一个合理的想法/是否有其他和/或更好的解决办法？
浏览 1提问于2014-10-07得票数 0
回答已采纳
我一直在使用MPI_Scatter / MPI_Gather进行各种并行计算。我注意到的一件事是，MPI_Barrier()经常被调用来同步处理器，类似于OpenMP屏障指令。我正在调整项目的代码，并注释掉了下面的MPI_Barrier()行，发现计算仍然是正确的。为什么是这种情况？我可以理解为什么需要第一个MPI_Barrier() --其他处理器不需要等待；一旦从处理器主处理器获得数据，就可以开始计算。但是，MPI_Barrier在MPI_Gather之后是否需要使用，还是MPI_Gather已经有了隐含的障碍？
编辑:在这种情况下，正在处理的数据的大小重要吗？
MPI_Scatter(&
浏览 10提问于2017-05-15得票数 5
回答已采纳
我知道对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
我很难理解我的指针过道是怎么回事：
我有以下的最小程序
#include <mpi.h>
void ALLOC_SHM(double * arr, int sz);
void MPI_WRAP( MPI_Aint size, int disp, MPI_Comm comm, double * bufptr, MPI_Win* win ) ;
int main(int argc, char const *argv[])
{
int size, whoami;
double* arr;
MPI_Init(NULL, NULL) ;
MPI_Comm_size(
浏览 3提问于2020-11-01得票数 0
回答已采纳
3回答
#include<stdio.h>
#include<mpi.h>
int a=1;
int *p=&a;
int main(int argc, char **argv)
{
MPI_Init(&argc,&argv);
int rank,size;
MPI_Comm_rank(MPI_COMM_WORLD,&rank);
MPI_Comm_size(MPI_COMM_WORLD,&size);
//printf("Address val: %u \n",p);
*p=*p+1;
MPI_Barrier(
浏览 1提问于2014-01-26得票数 3
1回答
我有一个程序，用MPI (MPICH)做一些矩阵计算。每个秩都有一个矩阵的切片，并在它们的切片上进行计算以得到矩阵的一个新的部分。有时，我需要同步管理器上的矩阵以进行快照、输出等，因此我需要所有级别将当前的矩阵切片发送给经理。
我想出了一个解决方案来解决这个问题，而且它似乎还不错；但是我想知道这是一个好方法，还是我做了一些愚蠢的事情，因为我以前从未使用过MPI。我特别好奇的是，我是否正确地删除了请求向量。提前感谢！
下面是代码：
#define __WORLD MPI_COMM_WORLD
// reconstructs the matrix on the manager node
void
浏览 0提问于2018-10-26得票数 2
回答已采纳
2回答
散布后的分段故障
、、、、
/**
* BLOCK_LOW
* Returns the offset of a local array
* with regards to block decomposition
* of a global array.
*
* @param (int) process rank
* @param (int) total number of processes
* @param (int) size of global array
* @return (int) offset of l
浏览 0提问于2012-05-20得票数 2
我有一个Python应用程序，它需要加载相同的大数组(~4GB)，并对这个数组的块执行一个完全并行的函数。数组开始保存到磁盘。
我通常在集群计算机上运行这个应用程序，比如10个节点，每个节点都有8个计算核，内存总数约为32 of。
最简单的方法(不起作用)是执行n=80 mpi4py。它不能工作的原因是每个MPI核心将加载4GB的映射，这将耗尽32 4GB的内存，从而导致一个MemoryError。
另一种选择是，rank=0是加载4GB数组的唯一进程，它将数组的大块分块分配到MPI核心的其余部分--但由于网络带宽问题，这种方法很慢。
最好的方法是，如果每个节点中只有一个核心加载4GB数组，并
浏览 2提问于2017-09-12得票数 2
1回答
我想使用带有MPI3共享内存的派生数据类型。给定以下派生数据类型：
type ::pve_data
type(pve_data), pointer :: next => NULL()
real*8 , pointer :: array(:) => NULL()
end type pve_data
初始化为：
type(pve_data) :: pve_grid
allocate(pve_grid%array(10))
pve_grid%array = 0.0d0
在使用pve_grid进行了一些计算之后，我想使用MPI_WIN_ALLOCATE_SHARED创
浏览 1提问于2016-09-02得票数 0
回答已采纳
2回答
根据Fortran Standard，我不确定这是否合法。我有一个通过重载调用的子例程。这里的要点是，有时我可能会调用子例程，在那里我有指向real的指针别名。请看一下这段完整的代码。
module mpi_intf_exam
use mpi
interface GLB_SUM
module procedure GLB_SUM_INT
module procedure GLB_SUM_FLT
module procedure GLB_SUM_FLT_INPLACE
end interface
integer :: mpierr
contains
subroutine GLB_SUM
浏览 9提问于2019-11-06得票数 4
回答已采纳
我正在开发一些程序，而不是运行在4个节点集群上，每个节点上有4个核心。我有一个非常快的OpenMP版本的程序，它只运行在一个集群上，我正在尝试使用MPI来扩展它。由于我的经验有限，我想知道哪一个能给我更快的性能，OpenMP混合架构还是MPI唯一的体系结构？我见过声称混合模式通常不能超过纯MPI，但是它没有给出支持性的证据，而且对我来说有点违背直觉。
顺便说一下，我的平台使用infiniband连接节点。
非常感谢，鲍勃
浏览 1提问于2013-11-04得票数 4
2回答
我正在致力于将一个项目从PVM迁移到MPI。我想问在座的任何人以前是否这样做过，是否有任何关于PVM和MPI中函数之间的通信的教程或手册。
浏览 7提问于2012-05-24得票数 2
回答已采纳
1回答
我正在使用递归函数来寻找一个5x5矩阵的行列式。虽然这听起来是一个微不足道的问题，如果维度很大，可以使用OpenMP来解决。我正在尝试使用MPI来解决这个问题，但是我不能理解如何处理递归，因为递归会累积结果。
因此，我的问题是，我如何使用MPI来实现这一点？
PS:矩阵是一个希尔伯特矩阵，所以答案应该是0
我已经写了下面的代码，但我认为它只是简单地做了n次相同的部分，而不是划分问题然后累积结果。
#include <mpi.h>
#include <stdio.h>
#include <stdlib.h>
#include <stdbool.h>
浏览 18提问于2019-08-02得票数 2
我试图在EPOS操作系统中实现MPI协议。实际上，我不知道如何实现MPI_Comm。它被定义为“MPI用于确定通信涉及哪些进程的基本对象”。在我在互联网上发现的一些实现中，它被实现为typedef int MPI_Comm，但是我如何知道使用int MPI_Comm进行通信涉及哪个进程？有什么想法吗？
谢谢。
浏览 5提问于2013-07-03得票数 0
1回答
我正在尝试将OpenMPI的mpi.h的重要部分转换为D编程语言，这样我就可以从D调用它(HTOD根本不起作用)。我不能理解下面的代码：
typedef struct ompi_communicator_t *MPI_Comm;
OMPI_DECLSPEC extern struct ompi_communicator_t ompi_mpi_comm_world;
OMPI_DECLSPEC extern struct ompi_communicator_t ompi_mpi_comm_self;
OMPI_DECLSPEC extern struct ompi_communicator_t
浏览 0提问于2011-08-05得票数 4
回答已采纳
我与C++一起使用MPI。我想从一个文件中读取信息，通过某种规则修改它，然后在同一个文件中写入修改过的内容。我使用的是临时文件，该文件存储修改后的内容，并在最后用以下命令覆盖它：
temp_file.open("temporary.txt",ios::in);
ofstream output_file(output_name,ios::out);
output_file<<temp_file.rdbuf();
output_file.flush();
temp_file.close();
output_file.close();
remove("tempo
浏览 2提问于2015-03-13得票数 0
回答已采纳
我希望在MPI程序中使用共享数组，这样在一个进程完成其工作后，它将把它的级别放到该数组中，并通过不等待发送给其他进程来“更新”它。我尝试将MPI_Bcast作为“根”参数给出正在运行的进程的级别(而不是0)，但是当我显示来自每个进程的数组时，它只显示本地发生了更改(发送的其他级别不在数组中)。
int array[10];
array[rank] = rank;
MPI_Bcast(array,10,MPI_INT,rank,MPI_COMM_WORLD);
printf("%d, %d - ",array[0],array[1]); //displays: 0, 26872
浏览 0提问于2016-05-12得票数 2
2回答
我试图计算使用MPI_Bcast和通常的MPI_send和MPI_Recv向所有进程广播100万个整数的速度和效率之间的差异。但我不明白为什么我会得到这个分割错误，任何帮助都会非常感谢。这是我的代码：
#define num_of_ints 1000000
int *create_random_array(int);
int main(int argc, char *argv[]){
int size=0, my_rank =0, i=0;
int tag =99;
double start, end;
int *array = NULL;
srand(time(NULL));
MPI_St
浏览 0提问于2014-04-16得票数 1
回答已采纳
1回答
MPI发送和重构
、、
我的第一个进程创建了一个链接的结构列表，我希望将列表中的一个元素发送到每个进程。在其他进程中接收到元素后，我需要将一个网格传递给callMethod()。在发送MPI之前，我需要先转换这些文件吗？
struct grid {
int g[N][N];
};
typedef struct s_grids {
struct grid grid;
int start;
struct grids* next;
} grids;
(...MPI_Initialization...)
grids* gridList;
if (rank == 0
浏览 1提问于2022-06-07得票数 0
1回答
远程线程执行
、、
我有一个用C++和MFC编写的大型多线程数学应用程序。我正在寻找一种方法来跟踪线程的执行(线程启动)，并从本地机器上获取它(在执行和移动之前停止它)，并在远程机器上运行，因为所有的bin文件和内存堆都已经传输了。也不可能在应用程序的源代码中进行严重的修改。
我知道MPI正在做类似的工作，对程序进行了一些修改。
你能给点建议吗？所有的想法和链接是赞赏的。我还应该读些什么？
浏览 0提问于2012-06-09得票数 0
回答已采纳
1回答
在MPI上具有指针的结构
、、、
我试图在MPI上发送以下结构：
union atributo{
int valor1;
char *valor2;
float valor3;
};
struct estructura{
int *tipo;
union atributo *list;
};
我知道它们是非常重要的指针，但我需要使用它们。我有类似的结构与静力学指针工作，但有了这些，我不能让他们工作。
MPI结构如下：
MPI_Datatype atributo_MPI;
MPI_Datatype type[1] = { MPI_BYTE };
int blocklen[1] =
浏览 0提问于2013-11-06得票数 1
回答已采纳
1回答
基本上，我需要一个函数在所有节点上以相同的物理时间返回相同的值。我最初使用的是gettimeofday，但不确定它是否能完成不同节点之间的同步计时。
现在我正在考虑使用MPI_Wtime。首先，我在运行MPI任务时检查了MPI_WTIME_IS_GLOBAL值，因为手册上说
The value returned for MPI_WTIME_IS_GLOBAL is 1 if clocks MPI_WTIME_IS_GLOBAL at all processes in MPI_COMM_WORLD are synchronized, 0 otherwise.
我的MPI运行返回3，而不是1或0
浏览 4提问于2013-09-26得票数 0
回答已采纳
1回答
我想要创建一个程序，它既可以在运行时与MPI一起工作，也可以在运行时不工作，我认为这是不可能的。
例如，MPI程序可能如下所示：
#include <mpi.h>
int main(int argc, char* argv[])
{
MPI_Init(&argc, &argv);
...
MPI_Finalize ();
return 0;
}
但是，为了允许没有安装MPI的用户编译它，我必须将它封装在#if的周围：
// Somewhere here, pull in a .h file which would set HAVE_MPI to 0
浏览 14提问于2022-08-19得票数 0
回答已采纳
我是MPI初学者。我有一个大数组的数字gmat (类型为double，维度1x14000000)，它被预先计算并存储在一个二进制文件中。它将使用大约100 MB的内存(14000000 x8字节/1024 /1024)。我想编写一个MPI代码，它将对这个数组进行一些计算(例如，将gmat的所有元素乘以进程的秩号)。这个数组gmat本身在运行时保持不变.代码应该是这样的
#include <iostream>
#include "mpi.h"
double* gmat;
long int imax;
int main(int argc, char* argv[])
浏览 0提问于2013-09-21得票数 0
回答已采纳
1回答
我有以下C结构：
typedef struct chromosome{
int *genes;
float cout;
}chromosome;
我想给发送一组染色体，使用MPI_Send。我定义了这样一个MPI_CHROMOSOME数据类型：
MPI_Datatype MPI_CHROMOSOME;
MPI_Datatype TYPES_ELEMENTAIRES[2] = {MPI_INT, MPI_FLOAT};
int blocklengths[2] = {NB_SOMMETS,1}; //NB_SOMMET is a known integer value at this point
浏览 5提问于2016-05-21得票数 1
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
实时音视频活动推荐
腾讯云开发者
