dn724/dncurrency
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages 1 Wiki Activity Actions

Async factory

Browse source
This commit is contained in:
Piotr Wójcik 2024-11-19 00:24:27 +01:00
commit 31ca903999
1 changed files with 16 additions and 6 deletions
Download patch file Download diff file Expand all files Collapse all files

22
nano/lib/async.hpp
View file

@ -162,15 +162,15 @@ concept async_task = std::same_as<T, asio::awaitable<void>>;
// Concept for callables that return an awaitable // Concept for callables that return an awaitable
template <typename T> template <typename T>
concept async_callable = requires (T t) { concept async_factory = requires (T t) {
{ {
t () t ()
} -> std::same_as<asio::awaitable<void>>; } -> std::same_as<asio::awaitable<void>>;
}; };
// Concept for tasks that take a condition and return an awaitable // Concept for callables that take a condition and return an awaitable
template <typename T> template <typename T>
concept async_callable_with_condition = requires (T t, condition & c) { concept async_factory_with_condition = requires (T t, condition & c) {
{ {
t (c) t (c)
} -> std::same_as<asio::awaitable<void>>; } -> std::same_as<asio::awaitable<void>>;
@ -192,8 +192,7 @@ public:
{ {
} }
template <typename Func> template <async_task Func>
requires async_task<Func> || async_callable<Func>
task (nano::async::strand & strand, Func && func) : task (nano::async::strand & strand, Func && func) :
strand{ strand }, strand{ strand },
cancellation{ strand } cancellation{ strand }
@ -204,7 +203,18 @@ public:
asio::bind_cancellation_slot (cancellation.slot (), asio::use_future)); asio::bind_cancellation_slot (cancellation.slot (), asio::use_future));
} }
template <async_callable_with_condition Func> template <async_factory Func>
task (nano::async::strand & strand, Func && func) :
strand{ strand },
cancellation{ strand }
{
future = asio::co_spawn (
strand,
func (),
asio::bind_cancellation_slot (cancellation.slot (), asio::use_future));
}
template <async_factory_with_condition Func>
task (nano::async::strand & strand, Func && func) : task (nano::async::strand & strand, Func && func) :
strand{ strand }, strand{ strand },
cancellation{ strand }, cancellation{ strand },