kirylkaveryn/organicmaps
1
Fork 0
forked from organicmaps/organicmaps-tmp
Code Pull requests Activity

Review fixes

Browse source
This commit is contained in:
Maksim Andrianov 2019-07-17 17:59:05 +03:00 • committed by cc-engineering
parent c5d2288e14
commit 43f6e137b3
1 changed files with 6 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

13
base/thread_pool_computational.hpp
View file

@ -67,18 +67,16 @@ public:
template <typename F, typename... Args>
auto Submit(F && func, Args &&... args) -> std::future<decltype(func(args...))>
{
{
std::unique_lock<std::mutex> lock(m_mutex);
if (m_done)
return {};
}
using ResultType = decltype(func(args...));
std::packaged_task<ResultType()> task(std::bind(std::forward<F>(func),
std::forward<Args>(args)...));
std::future<ResultType> result(task.get_future());
{
std::unique_lock<std::mutex> lock(m_mutex);
m_queue.emplace(std::move(task));
if (m_done)
return {};
m_queue.emplace(std::move(task));
}
m_condition.notify_one();
return result;
@ -91,12 +89,13 @@ public:
template <typename F, typename... Args>
void SubmitWork(F && func, Args &&... args)
{
auto f = std::bind(std::forward<F>(func), std::forward<Args>(args)...);
{
std::unique_lock<std::mutex> lock(m_mutex);
if (m_done)
return;
m_queue.emplace(std::bind(std::forward<F>(func), std::forward<Args>(args)...));
m_queue.emplace(std::move(f));
}
m_condition.notify_one();
}