MirrorHub/construct
0
0
Fork 0
mirror of https://github.com/matrix-construct/construct synced 2024-11-26 00:32:35 +01:00
Code Issues Releases Wiki Activity

ircd::ctx: Update async() with moveable promise.

Browse source
This commit is contained in:
Jason Volk 2018-01-08 12:39:05 -08:00
parent f8127957c3
commit 0cafcd7b84
1 changed files with 24 additions and 15 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

37
include/ircd/ctx/async.h
View file

@ -60,15 +60,17 @@ ircd::ctx::async(F&& f,
{
using R = typename std::result_of<F (A...)>::type;
auto func(std::bind(std::forward<F>(f), std::forward<A>(a)...));
auto p(std::make_shared<promise<R>>());
auto wrapper([p, func(std::move(func))]
() mutable -> void
promise<R> p;
future<R> ret{p};
auto wrapper
{
p->set_value(func());
});
[p(std::move(p)), func(std::bind(std::forward<F>(f), std::forward<A>(a)...))]
() mutable
{
p.set_value(func());
}
};
future<R> ret(*p);
//TODO: DEFER_POST?
context(stack_size, std::move(wrapper), context::DETACH | context::POST | flags);
return ret;
@ -84,16 +86,23 @@ ircd::ctx::async(F&& f,
{
using R = typename std::result_of<F (A...)>::type;
auto func(std::bind(std::forward<F>(f), std::forward<A>(a)...));
auto p(std::make_shared<promise<R>>());
auto wrapper([p, func(std::move(func))]
() mutable -> void
auto func
{
std::bind(std::forward<F>(f), std::forward<A>(a)...)
};
promise<R> p;
future<R> ret{p};
auto wrapper
{
[p(std::move(p)), func(std::bind(std::forward<F>(f), std::forward<A>(a)...))]
() mutable
{
func();
p->set_value();
});
p.set_value();
}
};
future<R> ret(*p);
//TODO: DEFER_POST?
context(stack_size, std::move(wrapper), context::DETACH | context::POST | flags);
return ret;