尝试启动另一个进程，并通过MPIjoin，但访问冲突

我试图启动另一个进程，调用第一个，并通过MPIjoin，但我得到一个访问冲突，我不明白。 我认为代码应该是非常自我解释，访问冲突命中MPI_COMM_ACCEPT行。 我认为一切看起来都是一致的，它应该起作用，但不会。

如果我把这一切都弄错了，还有一个更简单的方法，让我知道。 我没有使用mpiexec，因为我试图在构build整个混乱的testing框架中这样做，但如果这样做更有意义，那么告诉我，我已经做了一个烂摊子。

#include <windows.h> #include <AtlBase.h> #include <atlconv.h> #include <iostream> #include "mpi.h" #include <string> int main(int argc, char** argv) { MPI_Init(&argc, &argv); MPI_Comm intercomm; if (argc == 1) { PROCESS_INFORMATION pi; STARTUPINFO si; ZeroMemory(&si, sizeof(si)); si.cb = sizeof(si); ZeroMemory(&pi, sizeof(pi)); std::string x = std::string(argv[0]); x += " "; x += std::to_string(1); int res = CreateProcess(NULL, CA2T(x.c_str()), NULL, NULL, false, NORMAL_PRIORITY_CLASS | CREATE_NO_WINDOW, NULL, NULL, &si, &pi); std::cout << res <<std::endl; MPI_Open_port(MPI_INFO_NULL, "A"); MPI_Comm_accept("A", MPI_INFO_NULL, 0, MPI_COMM_SELF,&intercomm); std::cout << MPI_Comm_size(intercomm, &res); std::cout << res; } else { MPI_Comm_connect("A", MPI_INFO_NULL, 0, MPI_COMM_SELF, &intercomm); } MPI_Finalize(); // } } 

编辑：工作！ 这是非常诱人的，但它工作！

 #include <cstdlib> #include <ctime> #include <iomanip> #include <iostream> #include <mpi.h> #include <windows.h> #include <AtlBase.h> #include <atlconv.h> #include <iostream> #include "mpi.h" #include <string> int main(int argc, char** argv) { char myPort[MPI_MAX_PORT_NAME]; MPI_Init(&argc, &argv); MPI_Comm intercomm; if (argc == 1) { PROCESS_INFORMATION pi; STARTUPINFO si; ZeroMemory(&si, sizeof(si)); si.cb = sizeof(si); ZeroMemory(&pi, sizeof(pi)); MPI_Open_port(MPI_INFO_NULL, myPort); std::string x = std::string(argv[0])+" \""+myPort+"\""; std::cout <<"OLDPROCESS:" << x << std::endl; int res = CreateProcess(NULL, CA2T(x.c_str()), NULL, NULL, false, NORMAL_PRIORITY_CLASS , NULL, NULL, &si, &pi); MPI_Comm_accept(myPort, MPI_INFO_NULL, 0, MPI_COMM_SELF, &intercomm); std::cout << MPI_Comm_size(intercomm, &res); } else { std::cout << "NEWPROCESS:"<<argv[1] << std::endl; strcpy_s(myPort,argv[1]); MPI_Comm_connect(myPort, MPI_INFO_NULL, 0, MPI_COMM_SELF, &intercomm); } MPI_Finalize(); // } }