lisyarus/psemek
1
0
Fork 1
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Fix future::then

Browse source
This commit is contained in:
Nikita Lisitsa 2021-03-04 20:30:02 +03:00
parent 08d71a8496
commit 8091183375
1 changed files with 4 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
libs/async/include/psemek/async/future.hpp
View file

@ -428,19 +428,21 @@ namespace psemek::async
{ {
using R = decltype(f()); using R = decltype(f());
packaged_task<R()> t(std::forward<F>(f)); packaged_task<R()> t(std::forward<F>(f));
auto fut = t.get_future();
std::lock_guard lock{state_->then_mutex}; std::lock_guard lock{state_->then_mutex};
state_->then_func = std::move(t); state_->then_func = std::move(t);
return t.get_future(); return fut;
} }
else else
{ {
using R = decltype(f(*(state_->value))); using R = decltype(f(*(state_->value)));
packaged_task<R(T &)> t(std::forward<F>(f)); packaged_task<R(T &)> t(std::forward<F>(f));
auto fut = t.get_future();
std::lock_guard lock{state_->then_mutex}; std::lock_guard lock{state_->then_mutex};
state_->then_func = std::move(t); state_->then_func = std::move(t);
return t.get_future(); return fut;
} }
} }