hpx/executors/parallel_executor.hpp

Defined in header hpx/executors/parallel_executor.hpp.

See Public API for a list of names and headers that are part of the public HPX API.

Defines

HPX_MASK_TYPE_IS_CONSTEXPR_CONSTRUCTIBLE

namespace hpx

namespace execution

Typedefs

using parallel_executor = parallel_policy_executor<hpx::launch>

Functions

template<typename Tag, typename Policy, typename Property>
HPX_CXX_EXPORT auto tag_invoke(Tag tag, parallel_policy_executor<Policy> const &exec, Property &&prop) -> decltype(std::declval<parallel_policy_executor<Policy>>().policy(std::declval<Tag>()(std::declval<Policy>(), std::declval<Property>())), parallel_policy_executor<Policy>())

template<typename Tag, typename Policy>
HPX_CXX_EXPORT auto tag_invoke(Tag tag, parallel_policy_executor<Policy> const &exec) -> decltype(std::declval<Tag>()(std::declval<Policy>()))

template<typename Policy>
struct parallel_policy_executor

#include <parallel_executor.hpp>

A parallel_executor creates groups of parallel execution agents which execute in threads implicitly created by the executor. This executor prefers continuing with the creating thread first before executing newly created threads.

This executor conforms to the concepts of a TwoWayExecutor, and a BulkTwoWayExecutor

Public Types

using execution_category = std::conditional_t<std::is_same_v<Policy, launch::sync_policy>, sequenced_execution_tag, parallel_execution_tag>

Associate the parallel_execution_tag executor tag type as a default with this executor, except if the given launch policy is sync.

using executor_parameters_type = experimental::default_parameters

Associate the default_parameters executor parameters type as a default with this executor.

Public Functions

inline explicit constexpr parallel_policy_executor(threads::thread_priority priority, threads::thread_stacksize stacksize = threads::thread_stacksize::default_, threads::thread_schedule_hint schedulehint = {}, Policy l = parallel::execution::detail::get_default_policy<Policy>::call(), std::size_t hierarchical_threshold = hierarchical_threshold_default_)

Create a new parallel executor.

inline explicit constexpr parallel_policy_executor(threads::thread_stacksize stacksize, threads::thread_schedule_hint schedulehint = {}, Policy l = parallel::execution::detail::get_default_policy<Policy>::call())

inline explicit constexpr parallel_policy_executor(threads::thread_schedule_hint schedulehint, Policy l = parallel::execution::detail::get_default_policy<Policy>::call())

inline explicit constexpr parallel_policy_executor(Policy l)

inline constexpr parallel_policy_executor()

inline explicit constexpr parallel_policy_executor(threads::thread_pool_base *pool, Policy l, std::size_t hierarchical_threshold = hierarchical_threshold_default_)

inline explicit constexpr parallel_policy_executor(threads::thread_pool_base *pool, threads::thread_priority priority = threads::thread_priority::default_, threads::thread_stacksize stacksize = threads::thread_stacksize::default_, threads::thread_schedule_hint schedulehint = {}, Policy l = parallel::execution::detail::get_default_policy<Policy>::call(), std::size_t hierarchical_threshold = hierarchical_threshold_default_)

inline constexpr void set_hierarchical_threshold(std::size_t threshold) noexcept

template<typename Parameters>
inline std::size_t processing_units_count(Parameters&&, hpx::chrono::steady_duration const& = hpx::chrono::null_duration, std::size_t = 0) const

Private Functions

template<typename Executor_> inline  requires (std::is_convertible_v< Executor_, parallel_policy_executor >) friend const expr auto tag_invoke(hpx

template<typename Executor_> inline  requires (std::is_convertible_v< Executor_, parallel_policy_executor >) friend const expr auto tag_invoke(hpx

Friends

inline friend auto tag_invoke(hpx::execution::experimental::get_cores_mask_t, parallel_policy_executor const &exec)

namespace experimental

namespace parallel

namespace execution