Как минимум, вы один и тот же стрим ввода передаёте всем тредам. Тут имеет место быть не только гонка, но и вообще каша с доступом. Затем тред на продолжении ВСЕЙ своей работы блокирует мутекс. Ваш вариант с тем же успехом мог бы работать в один поток, т.к. пока поток не окончит чтение, другие будут ждать на мутексе. Блокируйте только на доступе к вектору.
Как вариант такой код:
#include <iostream>
#include <string>
#include <fstream>
#include <sstream>
#include <vector>
#include <deque>
#include <map>
#include <thread>
#include <mutex>
std::mutex lock;
void pipeline(const std::string&, std::vector<std::string>&);
std::string files[4] =
{
"file1.txt",
"file2.txt",
"file3.txt",
"file4.txt"
};
int main()
{
std::string string;
std::vector<std::string> str;
std::map<std::string, std::size_t> freq;
std::deque<std::thread> pool;
std::ofstream out("out.txt");
for (std::size_t i = 0; i < 3; i++)
{
pool.push_back(std::thread(pipeline, std::ref(files[i]), std::ref(str)));
}
while (pool.size())
{
pool.front().join();
pool.pop_front();
}
std::cout << str.size();
return 0;
}
void pipeline(const std::string &infile, std::vector<std::string> &str)
{
std::ifstream in(infile.c_str());
while (!in.eof())
{
std::string temp;
std::getline(in, temp);
{
std::unique_lock<std::mutex> guard(lock);
str.push_back(temp);
}
}
}
Изменения:
- стрим создаётся в потоке, потоку передаётся имя файла
- блокировка доступа только на модификации вектора
- использование охранного класса для блокирования и освобождения верктора.
- close на стриме можно в данном случае не делать - он закроется по выходу из области видимости
