diff --git a/generator/feature_builder.hpp b/generator/feature_builder.hpp index 3b40e08368..ffba8ac000 100644 --- a/generator/feature_builder.hpp +++ b/generator/feature_builder.hpp @@ -14,6 +14,7 @@ #include #include #include +#include #include namespace serial @@ -368,9 +369,11 @@ void ForEachParallelFromDatRawFormat(size_t threadsCount, std::string const & fi } }; - base::thread_pool::delayed::ThreadPool threadPool{threadsCount}; + std::vector workers; for (size_t i = 0; i < threadsCount; ++i) - threadPool.Push(concurrentProcessor); + workers.emplace_back(concurrentProcessor); + for (auto & thread : workers) + thread.join(); } template std::vector ReadAllDatRawFormat(std::string const & fileName)