AuroraMiddleware/asio
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Add missing sender traits and connect() member to thread_pool executor.

Browse Source
This commit is contained in:
Christopher Kohlhoff 2020-07-23 17:13:00 +10:00
parent 2e2d26c987
commit 284a11bb0d
1 changed files with 41 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

42
asio/include/asio/thread_pool.hpp
View File

@ -168,6 +168,20 @@ public:
/// The sender type, when this type is used as a scheduler.
typedef basic_executor_type sender_type;
#if defined(ASIO_HAS_DEDUCED_EXECUTION_IS_TYPED_SENDER_TRAIT) \
&& defined(ASIO_HAS_STD_EXCEPTION_PTR)
template <
template <typename...> class Tuple,
template <typename...> class Variant>
using value_types = Variant<Tuple<>>;
template <template <typename...> class Variant>
using error_types = Variant<std::exception_ptr>;
ASIO_STATIC_CONSTEXPR(bool, sends_done = true);
#endif // defined(ASIO_HAS_DEDUCED_EXECUTION_IS_TYPED_SENDER_TRAIT)
// && defined(ASIO_HAS_STD_EXCEPTION_PTR)
/// Copy construtor.
basic_executor_type(
const basic_executor_type& other) ASIO_NOEXCEPT
@ -406,12 +420,21 @@ public:
integral_constant<bool, (Bits & blocking_always) != 0>());
}
/// Schedule function.
/// Schedule function. Returns a sender.
sender_type schedule() const ASIO_NOEXCEPT
{
return *this;
}
/// Connect function. Returns operation state.
template <ASIO_EXECUTION_RECEIVER_OF_0 Receiver>
execution::detail::as_operation<basic_executor_type, Receiver>
connect(ASIO_MOVE_ARG(Receiver) r) const
{
return execution::detail::as_operation<basic_executor_type, Receiver>(
*this, ASIO_MOVE_CAST(Receiver)(r));
}
#if !defined(ASIO_NO_TS_EXECUTORS)
/// Obtain the underlying execution context.
thread_pool& context() const ASIO_NOEXCEPT;
@ -590,6 +613,23 @@ struct schedule_member<
#endif // !defined(ASIO_HAS_DEDUCED_SCHEDULE_MEMBER_TRAIT)
#if !defined(ASIO_HAS_DEDUCED_CONNECT_MEMBER_TRAIT)
template <typename Allocator, unsigned int Bits, typename Receiver>
struct connect_member<
const asio::thread_pool::basic_executor_type<Allocator, Bits>,
Receiver
>
{
ASIO_STATIC_CONSTEXPR(bool, is_valid = true);
ASIO_STATIC_CONSTEXPR(bool, is_noexcept = false);
typedef asio::execution::detail::as_operation<
asio::thread_pool::basic_executor_type<Allocator, Bits>,
Receiver> result_type;
};
#endif // !defined(ASIO_HAS_DEDUCED_CONNECT_MEMBER_TRAIT)
#if !defined(ASIO_HAS_DEDUCED_REQUIRE_MEMBER_TRAIT)
template <typename Allocator, unsigned int Bits>