MPI에서 문자열 배열을 분산시키는 방법 C++

Question

일부 문자열에 대해 기본 MapReduce 작업을 실행하고 싶습니다.

1. 과정에서 (동등) 내 모든 프로세스에 문자열 목록,
2. 배포 : 나는하려면 원하는
3. 수집, 사용자 정의 클래스의 객체 (예 : WordWithFrequency)에 수신 된 문자열을지도 객체를 생성하고 추가 작업을 위해 프로세스로 다시 보냅니다.

간단한 작업이어야하지만 올바르게 수행 할 수있는 방법을 찾지 못했습니다.

#include <boost/mpi.hpp> 
... 

int main(int argc, char *argv[]) { 
    // Initialize the MPI environment. 
    mpi::environment env(argc, argv); 
    mpi::communicator world; 

    vector<string> words = { "foo", "bar", "baz", "..." }; 
    const int wordCount = words.size(); 
    const int wordsPerProcess = wordCount/world.size(); 
    vector<vector<string> > wordsByProcess(world.size(), vector<string>()); 
    for (int j = 0; j < world.size(); ++j) { 
     for (int k = 0, wordIndex = j * wordsPerProcess + k; 
      k < wordsPerProcess && wordIndex < wordCount; ++k, ++wordIndex) { 
      wordsByProcess[j].push_back(words[wordIndex]); 
     } 
    } 

    vector<string> subWords; 
    mpi::scatter(world, wordsByProcess, subWords, 0); 
    // subWords is equal to wordsByProcess[world.rank()] here in every process. 

분산 :

Process 0 got words: 
�R 


Process 1 got words: 

Answer 1

그것은 Boost.MPI와 정말 쉬운 일이있다 :

#include <iostream> 
#include <fstream> 
#include <mpi.h> 
#include <vector> 

... 

int main(int argc, char *argv[]) { 
    // Initialize the MPI environment 
    MPI_Init(&argc, &argv); 

    // Find out the process rank and the world size 
    int world_rank; 
    MPI_Comm_rank(MPI_COMM_WORLD, &world_rank); 
    int world_size; 
    MPI_Comm_size(MPI_COMM_WORLD, &world_size); 

    vector<string> words = { "a", "bc", "d" }; 
    const int wordsLength = words.size(); 
    const int wordsPerProcess = wordsLength/world_size; 

    string *subWords = new string[wordsPerProcess]; 
    MPI_Scatter(&words, wordsPerProcess, MPI_CHAR, subWords, wordsPerProcess, ???customDataType???, 0, MPI_COMM_WORLD); 

    printf("Process %d got words:\n", world_rank); 
    for (int i = 0; i < wordsPerProcess; ++i) { 
     cout << subWords[i] << endl; 
    } 

    ... 

출력이 실행을 실행으로 변경하는 일부 재미 문자입니다 : 여기 내 고장 코드 해당 값이 전송 될 프로세스 번호로 색인화 된 요소의 벡터를 취합니다. 자세한 내용은 다음을 참조하십시오. http://www.boost.org/doc/libs/1_41_0/doc/html/boost/mpi/scatter.html