| 15 | } |
| 16 | |
| 17 | void TranslatorsPool::Emit(std::vector<OsmElement> && elements) |
| 18 | { |
| 19 | std::shared_ptr<TranslatorInterface> translator; |
| 20 | m_translators.WaitAndPop(translator); |
| 21 | m_threadPool.SubmitWork([&, translator, elements = std::move(elements)]() mutable |
| 22 | { |
| 23 | for (auto const & element : elements) |
| 24 | translator->Emit(element); |
| 25 | |
| 26 | m_translators.Push(translator); |
| 27 | }); |
| 28 | } |
| 29 | |
| 30 | bool TranslatorsPool::Finish() |
| 31 | { |
nothing calls this directly
no test coverage detected