Нет, все работает, каждое из 4х ядер загружено на 90%, процесс отрабатывает почти в 4 раза быстрее чем однопоточный.
Но в выходном файле строки оказываются в точно том порядке, в котором они находятся в исходном. На .NET что с помощью
что через
у меня это никогда не получалось и выходной файл содержал входные строки в случайном порядке примерно сгруппированными по количеству ядер. Допустил ли я какие-то ошибки синхронизируя чтение из входного потока?
1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
12.
13.
14.
15.
16.
17.
18.
19.
20.
21.
22.
23.
24.
25.
26.
27.
28.
29.
30.
31.
32.
33.
34.
ifstream sourceStream(sourceFile.c_str());
ofstream destStream(destFile.c_str());
vector<thread> threadPool;
for (unsigned int i = 0; i < thread::hardware_concurrency(); i++)
{
threadPool.emplace_back([&]
{
static mutex sourceMutex, destMutex;
bool moreToRead = true;
while (moreToRead)
{
string plain, encrypted;
{
lock_guard<mutex> io_guard(sourceMutex);
moreToRead = (bool)getline(sourceStream, plain);
}
if (moreToRead)
{
Encryptor ss(plain, encrypted);
{
lock_guard<mutex> io_guard(destMutex);
destStream << encrypted << endl;
}
}
}
});
}
for (auto &thread : threadPool) thread.join();
Макет входного файла:
1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
0 1234567890qwertyuiopasdfghjklzxcvbnm 1522771668
1 1234567890qwertyuiopasdfghjklzxcvbnm 1522771668
2 1234567890qwertyuiopasdfghjklzxcvbnm 1522771668
3 1234567890qwertyuiopasdfghjklzxcvbnm 1522771668
4 1234567890qwertyuiopasdfghjklzxcvbnm 1522771668
5 1234567890qwertyuiopasdfghjklzxcvbnm 1522771668
6 1234567890qwertyuiopasdfghjklzxcvbnm 1522771668
7 1234567890qwertyuiopasdfghjklzxcvbnm 1522771668
8 1234567890qwertyuiopasdfghjklzxcvbnm 1522771668
9 1234567890qwertyuiopasdfghjklzxcvbnm 1522771668
10 1234567890qwertyuiopasdfghjklzxcvbnm 1522771668
Когда я в однопотоке расшифровываю то, что зашифровал код выше, в консоль валится точно такой же порядок строк. Пробовал на 100,000 строках и все равно ни одного нарушения порядке. Пример блокировки мутексом брал с
отсюда . Где я напорол?
