pastk/organicmaps
1
Fork 0
forked from organicmaps/organicmaps
Code Pull requests Activity

[generator] Fix parallel processing in ForEachParallelFromDatRawFormat()

Browse source
This commit is contained in:
Anatoly Serdtcev 2019-07-15 16:01:32 +03:00 • committed by Maksim Andrianov
parent 8bb3bbe85b
commit 0ba20f3512
1 changed files with 5 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

7
generator/feature_builder.hpp
View file

@ -14,6 +14,7 @@
#include <list>
#include <mutex>
#include <string>
#include <thread>
#include <vector>
namespace serial
@ -368,9 +369,11 @@ void ForEachParallelFromDatRawFormat(size_t threadsCount, std::string const & fi
}
};
base::thread_pool::delayed::ThreadPool threadPool{threadsCount};
std::vector<std::thread> workers;
for (size_t i = 0; i < threadsCount; ++i)
threadPool.Push(concurrentProcessor);
workers.emplace_back(concurrentProcessor);
for (auto & thread : workers)
thread.join();
}
template <class SerializationPolicy = serialization_policy::MinSize>
std::vector<FeatureBuilder> ReadAllDatRawFormat(std::string const & fileName)