MPI и stdin над головой?

Question

Я кодирую программу в C++ MPI, но, передавая большой файл как stdin, я столкнулся с проблемой, что потоки не видят одну и ту же информацию stdin.

Более подробно, я прохожу в качестве стандартного ввода список входных файлов, который затем хранится в vector<string>:

MPI_Init(NULL,NULL); 
int CORES, thread; 
MPI_Comm_size(MPI_COMM_WORLD,&CORES); 
MPI_Comm_rank(MPI_COMM_WORLD,&thread); 
stringstream tline; 
int count = 0; 
for (std::string line; std::getline(std::cin, line);){ 
    tline << line << " "; 
    count++; 
    } 

vector<string> args(count,""); 
for(int i = 0; i < count; i++) 
    tline >> args[i]; 

cout << thread << " " << count << endl; //each thread outputs the number of input files it received 

Моя проблема заключается в том, что это дает разные номера для разных потоков. Например, после прохождения файла из 10 000 строк я получаю:

5 9464 
6 9464 
3 9464 
4 9464 
1 9554 
2 9554 
0 10000 
7 9464 

Это из-за некоторых накладных расходов? Как я могу избежать этого?

Answer 1

Хорошо, так что в основном ваша проблема в том, что все ваши темы потребляют линии от cin и они участвуют в гонке. Несмотря на то, что cin дает некоторые гарантии безопасности потоков в целом, вы не всегда уверены в том, что получите. Проверьте эту резьбу: How do scanf(), std::cin behave on multithreaded environment?

Решение: Не использовать CIN? Используйте файл и каждый поток открывает файл самостоятельно с помощью дескриптора файла. Если вы действительно хотите использовать cin, тогда проведите один поток от MPI CIN и передайте его другим темам, а затем они смогут что угодно с ним.