executors: Add is_never_blocking_one_way_executor trait for fork_join_executor

Author: Hackathon User

libs/core/executors/CMakeLists.txt

@@ -27,9 +27,9 @@ set(executors_headers
     hpx/executors/execution_policy_scheduling_property.hpp
     hpx/executors/execution_policy.hpp
     hpx/executors/executor_scheduler.hpp
+    hpx/executors/executor_scheduler_fwd.hpp
     hpx/executors/explicit_scheduler_executor.hpp
     hpx/executors/fork_join_executor.hpp
-    hpx/executors/fwd/executor_scheduler_fwd.hpp
     hpx/executors/limiting_executor.hpp
     hpx/executors/macros.hpp
     hpx/executors/parallel_executor_aggregated.hpp

libs/core/executors/include/hpx/executors/executor_scheduler.hpp

@@ -9,7 +9,7 @@
 #pragma once
 
 #include <hpx/config.hpp>
-#include <hpx/executors/fwd/executor_scheduler_fwd.hpp>
+#include <hpx/executors/executor_scheduler_fwd.hpp>
 #include <hpx/modules/errors.hpp>
 #include <hpx/modules/execution.hpp>
 #include <hpx/modules/execution_base.hpp>

…executors/fwd/executor_scheduler_fwd.hpp …hpx/executors/executor_scheduler_fwd.hpplibs/core/executors/include/hpx/executors/fwd/executor_scheduler_fwd.hpp renamed to libs/core/executors/include/hpx/executors/executor_scheduler_fwd.hpp libs/core/executors/include/hpx/executors/fwd/executor_scheduler_fwd.hpp renamed to libs/core/executors/include/hpx/executors/executor_scheduler_fwd.hpp

@@ -4,7 +4,7 @@
 //  Distributed under the Boost Software License, Version 1.0. (See accompanying
 //  file LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt)
 
-/// \file parallel/executors/fwd/executor_scheduler_fwd.hpp
+/// \file parallel/executors/executor_scheduler_fwd.hpp
 
 #pragma once
 

libs/core/executors/include/hpx/executors/fork_join_executor.hpp

@@ -1372,8 +1372,6 @@ namespace hpx::execution::experimental {
             return exec.shared_data_->num_threads_;
         }
 
-
-
         /// \cond NOINTERNAL
         enum class init_mode : std::uint8_t
         {
@@ -1388,8 +1386,7 @@ namespace hpx::execution::experimental {
     // executor_scheduler<fork_join_executor> is fully defined at point of use.
     // This allows fork_join_executor to participate in P2300 sender/receiver
     // pipelines via schedule(get_scheduler(exec)).
-    inline auto tag_invoke(
-        hpx::execution::experimental::get_scheduler_t,
+    inline auto tag_invoke(hpx::execution::experimental::get_scheduler_t,
         fork_join_executor const& exec) noexcept
         -> hpx::execution::experimental::executor_scheduler<fork_join_executor>
     {
@@ -1402,6 +1399,12 @@ namespace hpx::execution::experimental {
 
     /// \cond NOINTERNAL
 
+    template <>
+    struct is_never_blocking_one_way_executor<fork_join_executor>
+      : std::true_type
+    {
+    };
+
     template <>
     struct is_bulk_one_way_executor<fork_join_executor> : std::true_type
     {

libs/core/executors/tests/unit/fork_join_executor.cpp

@@ -8,9 +8,9 @@
 #include <hpx/algorithm.hpp>
 #include <hpx/chrono.hpp>
 #include <hpx/execution.hpp>
-#include <hpx/executors/executor_scheduler.hpp>
 #include <hpx/future.hpp>
 #include <hpx/init.hpp>
+#include <hpx/modules/executors.hpp>
 #include <hpx/modules/testing.hpp>
 #include <hpx/thread.hpp>