From 35225a659618bb294fdd8585a0a31ca3e13a7875 Mon Sep 17 00:00:00 2001 From: JorgeV92 Date: Thu, 30 Apr 2026 20:18:22 -0500 Subject: [PATCH 01/16] Add parallel_scheduler scaffold --- .../execution/detail/parallel_scheduler.hpp | 61 +++++++++++++++++++ include/beman/execution/execution.hpp | 2 + src/beman/execution/CMakeLists.txt | 2 + src/beman/execution/execution-detail.cppm | 1 + src/beman/execution/execution.cppm | 5 ++ src/beman/execution/parallel_scheduler.cppm | 12 ++++ 6 files changed, 83 insertions(+) create mode 100644 include/beman/execution/detail/parallel_scheduler.hpp create mode 100644 src/beman/execution/parallel_scheduler.cppm diff --git a/include/beman/execution/detail/parallel_scheduler.hpp b/include/beman/execution/detail/parallel_scheduler.hpp new file mode 100644 index 00000000..0394734f --- /dev/null +++ b/include/beman/execution/detail/parallel_scheduler.hpp @@ -0,0 +1,61 @@ +// include/beman/execution/detail/parallel_scheduler.hpp -*-C++-*- +// SPDX-License-Identifier: Apache-2.0 WITH LLVM-exception + +#ifndef INCLUDED_BEMAN_EXECUTION_DETAIL_PARALLEL_SCHEDULER +#define INCLUDED_BEMAN_EXECUTION_DETAIL_PARALLEL_SCHEDULER + +#include +#ifdef BEMAN_HAS_IMPORT_STD +import std; +#else +#include +#include +#include +#include +#include +#include +#include +#include +#endif +#ifdef BEMAN_HAS_MODULES +import beman.execution.detail.completion_signatures; +import beman.execution.detail.get_completion_scheduler; +import beman.execution.detail.get_forward_progress_guarantee; +import beman.execution.detail.operation_state; +import beman.execution.detail.receiver; +import beman.execution.detail.scheduler; +import beman.execution.detail.scheduler_t; +import beman.execution.detail.sender; +import beman.execution.detail.set_error; +import beman.execution.detail.set_stopped; +import beman.execution.detail.set_value; +#else +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include +#endif + +// ---------------------------------------------------------------------------- + +namespace beman::execution { + +class parallel_scheduler { + // TODO(P2079R10): add scheduler state and operations. +}; + +// TODO(P2079R10): implement using system_context_replaceability::query_parallel_scheduler_backend(). +auto get_parallel_scheduler() -> parallel_scheduler; + +} // namespace beman::execution + +// ---------------------------------------------------------------------------- + +#endif // INCLUDED_BEMAN_EXECUTION_DETAIL_PARALLEL_SCHEDULER diff --git a/include/beman/execution/execution.hpp b/include/beman/execution/execution.hpp index 5f526386..914a5115 100644 --- a/include/beman/execution/execution.hpp +++ b/include/beman/execution/execution.hpp @@ -39,6 +39,7 @@ import beman.execution.detail.let; import beman.execution.detail.matching_sig; import beman.execution.detail.on; import beman.execution.detail.operation_state; +import beman.execution.detail.parallel_scheduler; import beman.execution.detail.prop; import beman.execution.detail.read_env; import beman.execution.detail.receiver; @@ -101,6 +102,7 @@ import beman.execution.detail.write_env; #include #include #include +#include #include #include #include diff --git a/src/beman/execution/CMakeLists.txt b/src/beman/execution/CMakeLists.txt index 674d52c5..e663edb8 100644 --- a/src/beman/execution/CMakeLists.txt +++ b/src/beman/execution/CMakeLists.txt @@ -133,6 +133,7 @@ target_sources( ${PROJECT_SOURCE_DIR}/include/beman/execution/detail/on_stop_request.hpp ${PROJECT_SOURCE_DIR}/include/beman/execution/detail/operation_state.hpp ${PROJECT_SOURCE_DIR}/include/beman/execution/detail/operation_state_task.hpp + ${PROJECT_SOURCE_DIR}/include/beman/execution/detail/parallel_scheduler.hpp ${PROJECT_SOURCE_DIR}/include/beman/execution/detail/product_type.hpp ${PROJECT_SOURCE_DIR}/include/beman/execution/detail/prop.hpp ${PROJECT_SOURCE_DIR}/include/beman/execution/detail/query_with_default.hpp @@ -327,6 +328,7 @@ if(BEMAN_USE_MODULES) on.cppm operation_state_task.cppm operation_state.cppm + parallel_scheduler.cppm product_type.cppm prop.cppm query_with_default.cppm diff --git a/src/beman/execution/execution-detail.cppm b/src/beman/execution/execution-detail.cppm index 568be1bb..6d8a0ad4 100644 --- a/src/beman/execution/execution-detail.cppm +++ b/src/beman/execution/execution-detail.cppm @@ -59,6 +59,7 @@ export import beman.execution.detail.non_assignable; export import beman.execution.detail.nothrow_callable; export import beman.execution.detail.notify; export import beman.execution.detail.operation_state_task; +export import beman.execution.detail.parallel_scheduler; export import beman.execution.detail.product_type; export import beman.execution.detail.query_with_default; export import beman.execution.detail.queryable; diff --git a/src/beman/execution/execution.cppm b/src/beman/execution/execution.cppm index 3de60d3c..c6e4b9d4 100644 --- a/src/beman/execution/execution.cppm +++ b/src/beman/execution/execution.cppm @@ -43,6 +43,7 @@ import beman.execution.detail.never_stop_token; import beman.execution.detail.nostopstate; import beman.execution.detail.on; export import beman.execution.detail.operation_state; // [exec.opstate], operation states +import beman.execution.detail.parallel_scheduler; import beman.execution.detail.prop; import beman.execution.detail.read_env; import beman.execution.detail.run_loop; @@ -237,6 +238,10 @@ export using ::beman::execution::stopped_as_error; // [exec.run.loop], run_loop export using ::beman::execution::run_loop; +// [exec.parallel.scheduler], parallel scheduler +export using ::beman::execution::parallel_scheduler; +export using ::beman::execution::get_parallel_scheduler; + // [exec.consumers], consumers export using ::beman::execution::sync_wait_t; export using ::beman::execution::sync_wait_with_variant_t; diff --git a/src/beman/execution/parallel_scheduler.cppm b/src/beman/execution/parallel_scheduler.cppm new file mode 100644 index 00000000..14076f84 --- /dev/null +++ b/src/beman/execution/parallel_scheduler.cppm @@ -0,0 +1,12 @@ +module; +// src/beman/execution/parallel_scheduler.cppm -*-C++-*- +// SPDX-License-Identifier: Apache-2.0 WITH LLVM-exception + +#include + +export module beman.execution.detail.parallel_scheduler; + +namespace beman::execution { +export using beman::execution::parallel_scheduler; +export using beman::execution::get_parallel_scheduler; +} // namespace beman::execution From 799718972a3d8aa26214cd5e6d238f0a664166ee Mon Sep 17 00:00:00 2001 From: JorgeV92 Date: Sun, 3 May 2026 19:15:10 -0500 Subject: [PATCH 02/16] added receiver proxy --- .../execution/detail/parallel_scheduler.hpp | 18 ++++++++++++++++++ 1 file changed, 18 insertions(+) diff --git a/include/beman/execution/detail/parallel_scheduler.hpp b/include/beman/execution/detail/parallel_scheduler.hpp index 0394734f..d30b226f 100644 --- a/include/beman/execution/detail/parallel_scheduler.hpp +++ b/include/beman/execution/detail/parallel_scheduler.hpp @@ -45,6 +45,24 @@ import beman.execution.detail.set_value; // ---------------------------------------------------------------------------- +namespace beman::execution::system_context_replaceability { + +struct receiver_proxy { + virtual ~receiver_proxy() = default; + + virtual auto set_value() noexcept -> void = 0; + virtual auto set_error(::std::exception_ptr) noexcept -> void = 0; + virtual auto set_stopped() noexcept -> void = 0; + + template + requires(::std::same_as> && ::std::is_object_v

&& !::std::is_array_v

) + auto try_query(Query) noexcept -> ::std::optional

{ + // TODO(P2079R10): forward supported receiver environment queries + // through this proxy, especially get_stop_token_t -> inplace_stop_token + return ::std::nullopt; + } +}; + namespace beman::execution { class parallel_scheduler { From fb72e92b3dd8dfe5672e9f59f6d284d3c4c25a36 Mon Sep 17 00:00:00 2001 From: JorgeV92 Date: Sun, 3 May 2026 19:44:41 -0500 Subject: [PATCH 03/16] Add receiver_proxy module export --- src/beman/execution/parallel_scheduler.cppm | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/src/beman/execution/parallel_scheduler.cppm b/src/beman/execution/parallel_scheduler.cppm index 14076f84..234cecbf 100644 --- a/src/beman/execution/parallel_scheduler.cppm +++ b/src/beman/execution/parallel_scheduler.cppm @@ -9,4 +9,8 @@ export module beman.execution.detail.parallel_scheduler; namespace beman::execution { export using beman::execution::parallel_scheduler; export using beman::execution::get_parallel_scheduler; + +namespace system_context_replaceability { +export using beman::execution::system_context_replaceability::query_parallel_scheduler_backend; +} // namespace system_context_replaceability } // namespace beman::execution From a38059efd834d3d7cf32d44ee9f52313a618b603 Mon Sep 17 00:00:00 2001 From: JorgeV92 Date: Sun, 3 May 2026 19:46:45 -0500 Subject: [PATCH 04/16] added correct import --- src/beman/execution/parallel_scheduler.cppm | 1 + 1 file changed, 1 insertion(+) diff --git a/src/beman/execution/parallel_scheduler.cppm b/src/beman/execution/parallel_scheduler.cppm index 234cecbf..760cdc45 100644 --- a/src/beman/execution/parallel_scheduler.cppm +++ b/src/beman/execution/parallel_scheduler.cppm @@ -11,6 +11,7 @@ export using beman::execution::parallel_scheduler; export using beman::execution::get_parallel_scheduler; namespace system_context_replaceability { +export using beman::execution::system_context_replaceability::receiver_proxy; export using beman::execution::system_context_replaceability::query_parallel_scheduler_backend; } // namespace system_context_replaceability } // namespace beman::execution From 14fd292b4531f51a12b7741f22c6bf919269ae25 Mon Sep 17 00:00:00 2001 From: JorgeV92 Date: Sun, 3 May 2026 19:47:38 -0500 Subject: [PATCH 05/16] added correct import --- src/beman/execution/parallel_scheduler.cppm | 1 - 1 file changed, 1 deletion(-) diff --git a/src/beman/execution/parallel_scheduler.cppm b/src/beman/execution/parallel_scheduler.cppm index 760cdc45..ee434f01 100644 --- a/src/beman/execution/parallel_scheduler.cppm +++ b/src/beman/execution/parallel_scheduler.cppm @@ -12,6 +12,5 @@ export using beman::execution::get_parallel_scheduler; namespace system_context_replaceability { export using beman::execution::system_context_replaceability::receiver_proxy; -export using beman::execution::system_context_replaceability::query_parallel_scheduler_backend; } // namespace system_context_replaceability } // namespace beman::execution From ffda8baf9589585365f1fb79c7e4da590a31ce33 Mon Sep 17 00:00:00 2001 From: JorgeV92 Date: Sun, 3 May 2026 19:56:40 -0500 Subject: [PATCH 06/16] fixed syntax for system_context_replaceability --- include/beman/execution/detail/parallel_scheduler.hpp | 1 + 1 file changed, 1 insertion(+) diff --git a/include/beman/execution/detail/parallel_scheduler.hpp b/include/beman/execution/detail/parallel_scheduler.hpp index d30b226f..1e22109b 100644 --- a/include/beman/execution/detail/parallel_scheduler.hpp +++ b/include/beman/execution/detail/parallel_scheduler.hpp @@ -62,6 +62,7 @@ struct receiver_proxy { return ::std::nullopt; } }; +}// namespace beman::execution::system_context_replaceability namespace beman::execution { From 9c686efe61be1c60ace7123f31b057e4c5847bb7 Mon Sep 17 00:00:00 2001 From: JorgeV92 Date: Sun, 3 May 2026 20:18:11 -0500 Subject: [PATCH 07/16] added bulk_item_receiver_proxy --- include/beman/execution/detail/parallel_scheduler.hpp | 11 ++++++++--- 1 file changed, 8 insertions(+), 3 deletions(-) diff --git a/include/beman/execution/detail/parallel_scheduler.hpp b/include/beman/execution/detail/parallel_scheduler.hpp index 1e22109b..ce5ab8e9 100644 --- a/include/beman/execution/detail/parallel_scheduler.hpp +++ b/include/beman/execution/detail/parallel_scheduler.hpp @@ -50,9 +50,9 @@ namespace beman::execution::system_context_replaceability { struct receiver_proxy { virtual ~receiver_proxy() = default; - virtual auto set_value() noexcept -> void = 0; + virtual auto set_value() noexcept -> void = 0; virtual auto set_error(::std::exception_ptr) noexcept -> void = 0; - virtual auto set_stopped() noexcept -> void = 0; + virtual auto set_stopped() noexcept -> void = 0; template requires(::std::same_as> && ::std::is_object_v

&& !::std::is_array_v

) @@ -62,7 +62,12 @@ struct receiver_proxy { return ::std::nullopt; } }; -}// namespace beman::execution::system_context_replaceability + +struct bulk_item_receiver_proxy : receiver_proxy { + virtual auto execute(::std::size_t, ::std::size_t) noexcept -> void = 0; +}; + +} // namespace beman::execution::system_context_replaceability namespace beman::execution { From 089d2a7b88ca939cbd8cde4949bb7b5be809e0a9 Mon Sep 17 00:00:00 2001 From: JorgeV92 Date: Sun, 3 May 2026 21:34:02 -0500 Subject: [PATCH 08/16] added parallel_scheduler_backend --- .../beman/execution/detail/parallel_scheduler.hpp | 15 +++++++++++++++ src/beman/execution/parallel_scheduler.cppm | 1 + 2 files changed, 16 insertions(+) diff --git a/include/beman/execution/detail/parallel_scheduler.hpp b/include/beman/execution/detail/parallel_scheduler.hpp index ce5ab8e9..092f49bb 100644 --- a/include/beman/execution/detail/parallel_scheduler.hpp +++ b/include/beman/execution/detail/parallel_scheduler.hpp @@ -67,6 +67,21 @@ struct bulk_item_receiver_proxy : receiver_proxy { virtual auto execute(::std::size_t, ::std::size_t) noexcept -> void = 0; }; +struct parallel_scheduler_backend { + virtual ~parallel_scheduler_backend() = default; + + virtual auto schedule(receiver_proxy&, ::std::span<::std::byte>) noexcept -> void = 0; + virtual auto schedule_bulk_chunked(::std::size_t, + bulk_item_receiver_proxy&, + ::std::span<::std::byte>) noexcept -> void = 0; + virtual auto schedule_bulk_unchunked(::std::size_t, + bulk_item_receiver_proxy&, + ::std::span<::std::byte>) noexcept -> void = 0; +}; + +// TODO(P2079R10): provide the project-supported link-time replaceability hook. +auto query_parallel_scheduler_backend() -> ::std::shared_ptr; + } // namespace beman::execution::system_context_replaceability namespace beman::execution { diff --git a/src/beman/execution/parallel_scheduler.cppm b/src/beman/execution/parallel_scheduler.cppm index ee434f01..760cdc45 100644 --- a/src/beman/execution/parallel_scheduler.cppm +++ b/src/beman/execution/parallel_scheduler.cppm @@ -12,5 +12,6 @@ export using beman::execution::get_parallel_scheduler; namespace system_context_replaceability { export using beman::execution::system_context_replaceability::receiver_proxy; +export using beman::execution::system_context_replaceability::query_parallel_scheduler_backend; } // namespace system_context_replaceability } // namespace beman::execution From 9cf288ff2505d0f5adce777e6961429450e79ba8 Mon Sep 17 00:00:00 2001 From: JorgeV92 Date: Sun, 3 May 2026 22:13:36 -0500 Subject: [PATCH 09/16] added parallel_scheduler --- .../execution/detail/parallel_scheduler.hpp | 34 ++++++++++++++++++- src/beman/execution/parallel_scheduler.cppm | 2 ++ 2 files changed, 35 insertions(+), 1 deletion(-) diff --git a/include/beman/execution/detail/parallel_scheduler.hpp b/include/beman/execution/detail/parallel_scheduler.hpp index 092f49bb..38a7ed62 100644 --- a/include/beman/execution/detail/parallel_scheduler.hpp +++ b/include/beman/execution/detail/parallel_scheduler.hpp @@ -87,7 +87,39 @@ auto query_parallel_scheduler_backend() -> ::std::shared_ptr parallel_scheduler& = default; + auto operator=(parallel_scheduler&&) noexcept -> parallel_scheduler& = default; + + auto operator==(const parallel_scheduler& other) const noexcept -> bool { + return this->backend_ == other.backend_; + } + + static constexpr auto query(::beman::execution::get_forward_progress_guarantee_t) noexcept + -> ::beman::execution::forward_progress_guarantee { + return ::beman::execution::forward_progress_guarantee::parallel; + } + + auto schedule() const noexcept -> sender; + // TODO(P2079R10): customize bulk_chunked and bulk_unchunked for this scheduler. + + private: + explicit parallel_scheduler(::std::shared_ptr backend) noexcept : backend_(::std::move(backend)) {} + + ::std::shared_ptr backend_; + + friend auto get_parallel_scheduler() -> parallel_scheduler; }; // TODO(P2079R10): implement using system_context_replaceability::query_parallel_scheduler_backend(). diff --git a/src/beman/execution/parallel_scheduler.cppm b/src/beman/execution/parallel_scheduler.cppm index 760cdc45..16138923 100644 --- a/src/beman/execution/parallel_scheduler.cppm +++ b/src/beman/execution/parallel_scheduler.cppm @@ -12,6 +12,8 @@ export using beman::execution::get_parallel_scheduler; namespace system_context_replaceability { export using beman::execution::system_context_replaceability::receiver_proxy; +export using beman::execution::system_context_replaceability::bulk_item_receiver_proxy; +export using beman::execution::system_context_replaceability::parallel_scheduler_backend; export using beman::execution::system_context_replaceability::query_parallel_scheduler_backend; } // namespace system_context_replaceability } // namespace beman::execution From eb7709afefbcb728fc01b8e282126e6a4c43b0fd Mon Sep 17 00:00:00 2001 From: JorgeV92 Date: Sun, 3 May 2026 22:41:39 -0500 Subject: [PATCH 10/16] fixed format --- .../beman/execution/detail/parallel_scheduler.hpp | 12 +++++------- 1 file changed, 5 insertions(+), 7 deletions(-) diff --git a/include/beman/execution/detail/parallel_scheduler.hpp b/include/beman/execution/detail/parallel_scheduler.hpp index 38a7ed62..923702b2 100644 --- a/include/beman/execution/detail/parallel_scheduler.hpp +++ b/include/beman/execution/detail/parallel_scheduler.hpp @@ -71,12 +71,10 @@ struct parallel_scheduler_backend { virtual ~parallel_scheduler_backend() = default; virtual auto schedule(receiver_proxy&, ::std::span<::std::byte>) noexcept -> void = 0; - virtual auto schedule_bulk_chunked(::std::size_t, - bulk_item_receiver_proxy&, - ::std::span<::std::byte>) noexcept -> void = 0; - virtual auto schedule_bulk_unchunked(::std::size_t, - bulk_item_receiver_proxy&, - ::std::span<::std::byte>) noexcept -> void = 0; + virtual auto schedule_bulk_chunked(::std::size_t, bulk_item_receiver_proxy&, ::std::span<::std::byte>) noexcept + -> void = 0; + virtual auto schedule_bulk_unchunked(::std::size_t, bulk_item_receiver_proxy&, ::std::span<::std::byte>) noexcept + -> void = 0; }; // TODO(P2079R10): provide the project-supported link-time replaceability hook. @@ -94,7 +92,7 @@ class parallel_scheduler { class sender; - parallel_scheduler() = delete; + parallel_scheduler() = delete; ~parallel_scheduler() = default; parallel_scheduler(const parallel_scheduler&) noexcept = default; From f2a887ef2dac1ce9460bae1a5a6ed0a5b80ce2ac Mon Sep 17 00:00:00 2001 From: JorgeV92 Date: Wed, 13 May 2026 21:21:04 -0500 Subject: [PATCH 11/16] fixed modified imports with scheduler_tag --- include/beman/execution/detail/parallel_scheduler.hpp | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/include/beman/execution/detail/parallel_scheduler.hpp b/include/beman/execution/detail/parallel_scheduler.hpp index 923702b2..6b97ba74 100644 --- a/include/beman/execution/detail/parallel_scheduler.hpp +++ b/include/beman/execution/detail/parallel_scheduler.hpp @@ -24,7 +24,7 @@ import beman.execution.detail.get_forward_progress_guarantee; import beman.execution.detail.operation_state; import beman.execution.detail.receiver; import beman.execution.detail.scheduler; -import beman.execution.detail.scheduler_t; +import beman.execution.detail.scheduler_tag; import beman.execution.detail.sender; import beman.execution.detail.set_error; import beman.execution.detail.set_stopped; @@ -36,7 +36,7 @@ import beman.execution.detail.set_value; #include #include #include -#include +#include #include #include #include @@ -88,7 +88,7 @@ class parallel_scheduler { using backend_type = ::beman::execution::system_context_replaceability::parallel_scheduler_backend; public: - using scheduler_concept = ::beman::execution::scheduler_t; + using scheduler_concept = ::beman::execution::scheduler_tag; class sender; From f761d3cc801b21571d65ced28f72555aa82ca933 Mon Sep 17 00:00:00 2001 From: JorgeV92 Date: Wed, 13 May 2026 22:48:13 -0500 Subject: [PATCH 12/16] added parallel_scheduler::sender class --- .../execution/detail/parallel_scheduler.hpp | 79 +++++++++++++++++++ 1 file changed, 79 insertions(+) diff --git a/include/beman/execution/detail/parallel_scheduler.hpp b/include/beman/execution/detail/parallel_scheduler.hpp index 6b97ba74..3da33831 100644 --- a/include/beman/execution/detail/parallel_scheduler.hpp +++ b/include/beman/execution/detail/parallel_scheduler.hpp @@ -120,6 +120,85 @@ class parallel_scheduler { friend auto get_parallel_scheduler() -> parallel_scheduler; }; +class parallel_scheduler::sender { + using backend_type = ::beman::execution::system_context_replaceability::parallel_scheduler_backend; + + public: + using sender_concept = ::beman::execution::sender_tag; + using completion_signatures = + ::beman::execution::completion_signatures<::beman::execution::set_value_t(), + ::beman::execution::set_error_t(::std::exception_ptr), + ::beman::execution::set_stopped_t()>; + + class env { + public: + explicit env(::std::shared_ptr backend) noexcept : backend_(::std::move(backend)) {} + + auto + query(const ::beman::execution::get_completion_scheduler_t<::beman::execution::set_value_t>&) const noexcept + -> ::beman::execution::parallel_scheduler { + return ::beman::execution::parallel_scheduler{this->backend_}; + } + + private: + ::std::shared_ptr backend_; + }; + + template <::beman::execution::receiver Rcvr> + class operation : public ::beman::execution::system_context_replaceability::receiver_proxy { + public: + using operation_state_concept = ::beman::execution::operation_state_tag; + + operation(::std::shared_ptr backend, + Rcvr&& rcvr) noexcept(::std::is_nothrow_constructible_v<::std::remove_cvref_t, Rcvr>) + : backend_(::std::move(backend)), rcvr_(::std::forward(rcvr)) {} + + auto start() & noexcept -> void { + // TODO(P2079R10): define backend storage sizing and stopped-before-start handling. + this->backend_->schedule(*this, ::std::span<::std::byte>{this->storage_}); + } + + private: + auto set_value() noexcept -> void override { ::beman::execution::set_value(::std::move(this->rcvr_)); } + + auto set_error(::std::exception_ptr error) noexcept -> void override { + ::beman::execution::set_error(::std::move(this->rcvr_), ::std::move(error)); + } + + auto set_stopped() noexcept -> void override { ::beman::execution::set_stopped(::std::move(this->rcvr_)); } + + ::std::shared_ptr backend_; + ::std::remove_cvref_t rcvr_; + alignas(void*)::std::byte storage_[sizeof(void*) * 4]{}; + }; + + explicit sender(::std::shared_ptr backend) noexcept : backend_(::std::move(backend)) {} + + template + static consteval auto get_completion_signatures() noexcept -> completion_signatures { + return {}; + } + + auto get_env() const noexcept -> env { return env{this->backend_}; } + + template <::beman::execution::receiver Rcvr> + auto connect(Rcvr&& rcvr) & noexcept(::std::is_nothrow_constructible_v<::std::remove_cvref_t, Rcvr>) + -> operation { + return operation{this->backend_, ::std::forward(rcvr)}; + } + + template <::beman::execution::receiver Rcvr> + auto connect(Rcvr&& rcvr) && noexcept(::std::is_nothrow_constructible_v<::std::remove_cvref_t, Rcvr>) + -> operation { + return operation{::std::move(this->backend_), ::std::forward(rcvr)}; + } + + private: + ::std::shared_ptr backend_; +}; + +inline auto parallel_scheduler::schedule() const noexcept -> sender { return sender{this->backend_}; } + // TODO(P2079R10): implement using system_context_replaceability::query_parallel_scheduler_backend(). auto get_parallel_scheduler() -> parallel_scheduler; From 7363e379b657b07ee398be3b6a8c491f77ceb650 Mon Sep 17 00:00:00 2001 From: JorgeV92 Date: Wed, 20 May 2026 21:07:25 -0500 Subject: [PATCH 13/16] can y --- include/beman/execution26/execution.hpp | 9 ++ src/beman/execution/execution.cppm | 7 ++ tests/beman/execution/CMakeLists.txt | 1 + .../exec-parallel-scheduler.test.cpp | 84 +++++++++++++++++++ 4 files changed, 101 insertions(+) create mode 100644 tests/beman/execution/exec-parallel-scheduler.test.cpp diff --git a/include/beman/execution26/execution.hpp b/include/beman/execution26/execution.hpp index d414719b..65095bb8 100644 --- a/include/beman/execution26/execution.hpp +++ b/include/beman/execution26/execution.hpp @@ -42,6 +42,7 @@ using ::beman::execution::get_domain; using ::beman::execution::get_domain_t; using ::beman::execution::get_env; using ::beman::execution::get_env_t; +using ::beman::execution::get_parallel_scheduler; using ::beman::execution::get_scheduler; using ::beman::execution::get_scheduler_t; using ::beman::execution::get_stop_token; @@ -62,6 +63,7 @@ using ::beman::execution::let_value; using ::beman::execution::let_value_t; using ::beman::execution::operation_state; using ::beman::execution::operation_state_tag; +using ::beman::execution::parallel_scheduler; using ::beman::execution::read_env; using ::beman::execution::receiver; using ::beman::execution::receiver_of; @@ -107,6 +109,13 @@ using ::beman::execution::when_all_with_variant; using ::beman::execution::when_all_with_variant_t; using ::beman::execution::with_awaitable_senders; +namespace system_context_replaceability { +using ::beman::execution::system_context_replaceability::bulk_item_receiver_proxy; +using ::beman::execution::system_context_replaceability::parallel_scheduler_backend; +using ::beman::execution::system_context_replaceability::query_parallel_scheduler_backend; +using ::beman::execution::system_context_replaceability::receiver_proxy; +} // namespace system_context_replaceability + } // namespace beman::execution26 // ---------------------------------------------------------------------------- diff --git a/src/beman/execution/execution.cppm b/src/beman/execution/execution.cppm index 1d93dc90..f5672614 100644 --- a/src/beman/execution/execution.cppm +++ b/src/beman/execution/execution.cppm @@ -242,6 +242,13 @@ export using ::beman::execution::run_loop; export using ::beman::execution::parallel_scheduler; export using ::beman::execution::get_parallel_scheduler; +namespace system_context_replaceability { +export using ::beman::execution::system_context_replaceability::receiver_proxy; +export using ::beman::execution::system_context_replaceability::bulk_item_receiver_proxy; +export using ::beman::execution::system_context_replaceability::parallel_scheduler_backend; +export using ::beman::execution::system_context_replaceability::query_parallel_scheduler_backend; +} // namespace system_context_replaceability + // [exec.consumers], consumers export using ::beman::execution::sync_wait_t; export using ::beman::execution::sync_wait_with_variant_t; diff --git a/tests/beman/execution/CMakeLists.txt b/tests/beman/execution/CMakeLists.txt index 08530378..9474ad3c 100644 --- a/tests/beman/execution/CMakeLists.txt +++ b/tests/beman/execution/CMakeLists.txt @@ -32,6 +32,7 @@ list( exec-just.test exec-let.test exec-on.test + exec-parallel-scheduler.test exec-opstate-start.test exec-opstate.test exec-prop.test diff --git a/tests/beman/execution/exec-parallel-scheduler.test.cpp b/tests/beman/execution/exec-parallel-scheduler.test.cpp new file mode 100644 index 00000000..4006d3f0 --- /dev/null +++ b/tests/beman/execution/exec-parallel-scheduler.test.cpp @@ -0,0 +1,84 @@ +// src/beman/execution/tests/exec-parallel-scheduler.test.cpp -*-C++-*- +// SPDX-License-Identifier: Apache-2.0 WITH LLVM-exception + +#include +#include +#include +#include +#include +#include +#include +#include +#include +#ifdef BEMAN_HAS_MODULESSo +import beman.execution; +#else +#include +#endif + +namespace { +namespace replaceability = test_std::system_context_replaceability; + +struct proxy : replaceability::receiver_proxy { + auto set_value() noexcept -> void override {} + auto set_error(::std::exception_ptr) noexcept -> void override {} + auto set_stopped() noexcept -> void override {} +}; + +struct bulk_proxy : replaceability::bulk_item_receiver_proxy { + auto set_value() noexcept -> void override {} + auto set_error(::std::exception_ptr) noexcept -> void override {} + auto set_stopped() noexcept -> void override {} + auto execute(::std::size_t, ::std::size_t) noexcept -> void override {} +}; + +struct backend : replaceability::parallel_scheduler_backend { + auto schedule(replaceability::receiver_proxy&, ::std::span<::std::byte>) noexcept -> void override {} + auto schedule_bulk_chunked(::std::size_t, + replaceability::bulk_item_receiver_proxy&, + ::std::span<::std::byte>) noexcept -> void override {} + auto schedule_bulk_unchunked(::std::size_t, + replaceability::bulk_item_receiver_proxy&, + ::std::span<::std::byte>) noexcept -> void override {} +}; + +auto test_parallel_scheduler_synopsis() -> void { + static_assert(!::std::default_initializable); + static_assert(::std::copy_constructible); + static_assert(::std::move_constructible); + static_assert(test_std::scheduler); + + static_assert(::std::same_as); + static_assert(::std::same_as, + test_std::parallel_scheduler::sender>); + static_assert(test_std::sender); + static_assert(::std::same_as< + decltype(test_std::get_completion_signatures()), + test_std::completion_signatures>); + + static_assert(noexcept(test_std::get_forward_progress_guarantee( + ::std::declval()))); + static_assert(::std::same_as())), + test_std::forward_progress_guarantee>); +} + +auto test_replaceability_synopsis() -> void { + static_assert(::std::is_abstract_v); + static_assert(::std::is_abstract_v); + static_assert(::std::is_abstract_v); + static_assert(::std::derived_from); + static_assert(::std::derived_from); + static_assert(::std::same_as().template try_query(0)), + ::std::optional>); + static_assert(::std::same_as>); +} +} // namespace + +TEST(exec_parallel_scheduler) { + test_parallel_scheduler_synopsis(); + test_replaceability_synopsis(); +} From 5b36756f5b26497ba3a016d87ec46ba1b6a982b4 Mon Sep 17 00:00:00 2001 From: JorgeV92 Date: Wed, 20 May 2026 22:23:57 -0500 Subject: [PATCH 14/16] add import for schedule_result_t --- tests/beman/execution/exec-parallel-scheduler.test.cpp | 1 + 1 file changed, 1 insertion(+) diff --git a/tests/beman/execution/exec-parallel-scheduler.test.cpp b/tests/beman/execution/exec-parallel-scheduler.test.cpp index 4006d3f0..fc2f258c 100644 --- a/tests/beman/execution/exec-parallel-scheduler.test.cpp +++ b/tests/beman/execution/exec-parallel-scheduler.test.cpp @@ -12,6 +12,7 @@ #include #ifdef BEMAN_HAS_MODULESSo import beman.execution; +import beman.execution.detail.schedule_result_t; #else #include #endif From dcfa4b7195adf3752e5d2088304ab32de86e2ca7 Mon Sep 17 00:00:00 2001 From: JorgeV92 Date: Wed, 20 May 2026 22:46:10 -0500 Subject: [PATCH 15/16] fixed typo --- tests/beman/execution/exec-parallel-scheduler.test.cpp | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/tests/beman/execution/exec-parallel-scheduler.test.cpp b/tests/beman/execution/exec-parallel-scheduler.test.cpp index fc2f258c..6727dbb2 100644 --- a/tests/beman/execution/exec-parallel-scheduler.test.cpp +++ b/tests/beman/execution/exec-parallel-scheduler.test.cpp @@ -10,7 +10,7 @@ #include #include #include -#ifdef BEMAN_HAS_MODULESSo +#ifdef BEMAN_HAS_MODULES import beman.execution; import beman.execution.detail.schedule_result_t; #else From c2c77625969c7e27cc8bfef5602fa06b7a97e3a0 Mon Sep 17 00:00:00 2001 From: JorgeV92 Date: Wed, 20 May 2026 22:57:39 -0500 Subject: [PATCH 16/16] format fix --- .../exec-parallel-scheduler.test.cpp | 20 +++++++++---------- 1 file changed, 9 insertions(+), 11 deletions(-) diff --git a/tests/beman/execution/exec-parallel-scheduler.test.cpp b/tests/beman/execution/exec-parallel-scheduler.test.cpp index 6727dbb2..bc90feff 100644 --- a/tests/beman/execution/exec-parallel-scheduler.test.cpp +++ b/tests/beman/execution/exec-parallel-scheduler.test.cpp @@ -10,7 +10,7 @@ #include #include #include -#ifdef BEMAN_HAS_MODULES +#ifdef BEMAN_HAS_MODULES import beman.execution; import beman.execution.detail.schedule_result_t; #else @@ -53,16 +53,15 @@ auto test_parallel_scheduler_synopsis() -> void { static_assert(::std::same_as, test_std::parallel_scheduler::sender>); static_assert(test_std::sender); - static_assert(::std::same_as< - decltype(test_std::get_completion_signatures()), - test_std::completion_signatures>); + static_assert(::std::same_as()), + test_std::completion_signatures>); - static_assert(noexcept(test_std::get_forward_progress_guarantee( - ::std::declval()))); + static_assert( + noexcept(test_std::get_forward_progress_guarantee(::std::declval()))); static_assert(::std::same_as())), + ::std::declval())), test_std::forward_progress_guarantee>); } @@ -72,8 +71,7 @@ auto test_replaceability_synopsis() -> void { static_assert(::std::is_abstract_v); static_assert(::std::derived_from); static_assert(::std::derived_from); - static_assert(::std::same_as().template try_query(0)), - ::std::optional>); + static_assert(::std::same_as().template try_query(0)), ::std::optional>); static_assert(::std::same_as>); }