Thread System 0.3.1
High-performance C++20 thread pool with work stealing and DAG scheduling
Loading...
Searching...
No Matches
kcenon::thread::numa_thread_pool Member List

This is the complete list of members for kcenon::thread::numa_thread_pool, including all inherited members.

add_policy(std::unique_ptr< pool_policy > policy)kcenon::thread::thread_pool
cached_topology_kcenon::thread::numa_thread_poolmutableprivate
check_worker_health(bool restart_failed=true) -> std::size_tkcenon::thread::thread_pool
collect_worker_diagnostics() const -> std::vector< diagnostics::thread_info >kcenon::thread::thread_pool
configure_numa_work_stealing(const enhanced_work_stealing_config &config)kcenon::thread::numa_thread_pool
context_kcenon::thread::thread_poolprivate
diagnostics() -> diagnostics::thread_pool_diagnostics &kcenon::thread::thread_pool
diagnostics() const -> const diagnostics::thread_pool_diagnostics &kcenon::thread::thread_pool
diagnostics_kcenon::thread::thread_poolmutableprivate
diagnostics_init_flag_kcenon::thread::thread_poolmutableprivate
disable_numa_work_stealing()kcenon::thread::numa_thread_pool
enable_numa_work_stealing()kcenon::thread::numa_thread_pool
enhanced_metrics() constkcenon::thread::thread_pool
enhanced_metrics_snapshot() constkcenon::thread::thread_pool
enhanced_ws_config_kcenon::thread::numa_thread_poolprivate
enqueue(std::unique_ptr< job > &&job) -> common::VoidResultkcenon::thread::thread_pool
enqueue(std::unique_ptr< thread_worker > &&worker) -> common::VoidResultkcenon::thread::thread_pool
enqueue_batch(std::vector< std::unique_ptr< job > > &&jobs) -> common::VoidResultkcenon::thread::thread_pool
enqueue_batch(std::vector< std::unique_ptr< thread_worker > > &&workers) -> common::VoidResultkcenon::thread::thread_pool
ensure_topology_detected() constkcenon::thread::numa_thread_poolprivate
find_policy(const std::string &name) -> T *kcenon::thread::thread_pool
get_active_worker_count() const -> std::size_tkcenon::thread::thread_pool
get_context(void) const -> const thread_context &kcenon::thread::thread_pool
get_idle_worker_count() constkcenon::thread::thread_pool
get_job_queue(void) -> std::shared_ptr< job_queue >kcenon::thread::thread_pool
get_pending_task_count() const -> std::size_tkcenon::thread::thread_pool
get_policies() const -> const std::vector< std::unique_ptr< pool_policy > > &kcenon::thread::thread_pool
get_pool_instance_id() constkcenon::thread::thread_pool
get_ptr(void) -> std::shared_ptr< thread_pool >kcenon::thread::thread_pool
is_enhanced_metrics_enabled() constkcenon::thread::thread_pool
is_numa_system() constkcenon::thread::numa_thread_pool
is_numa_work_stealing_enabled() constkcenon::thread::numa_thread_pool
is_running() const -> boolkcenon::thread::thread_pool
job_queue_kcenon::thread::thread_poolprivate
metrics() const noexceptkcenon::thread::thread_pool
metrics_service_kcenon::thread::thread_poolprivate
next_pool_instance_id_kcenon::thread::thread_poolprivatestatic
numa_thread_pool(const std::string &thread_title="numa_thread_pool", const thread_context &context=thread_context())kcenon::thread::numa_thread_poolexplicit
numa_thread_pool(const std::string &thread_title, std::shared_ptr< job_queue > custom_queue, const thread_context &context=thread_context())kcenon::thread::numa_thread_pool
numa_thread_pool(const std::string &thread_title, std::unique_ptr< pool_queue_adapter_interface > queue_adapter, const thread_context &context=thread_context())kcenon::thread::numa_thread_pool
numa_topology_info() constkcenon::thread::numa_thread_pool
numa_work_stealer_kcenon::thread::numa_thread_poolprivate
numa_work_stealing_config() constkcenon::thread::numa_thread_pool
numa_work_stealing_stats() constkcenon::thread::numa_thread_pool
policies_kcenon::thread::thread_poolprivate
policies_mutex_kcenon::thread::thread_poolmutableprivate
pool_cancellation_token_kcenon::thread::thread_poolprivate
pool_instance_id_kcenon::thread::thread_poolprivate
queue_adapter_kcenon::thread::thread_poolprivate
remove_policy(const std::string &name) -> boolkcenon::thread::thread_pool
remove_workers_internal(std::size_t count, std::size_t min_workers=1) -> common::VoidResultkcenon::thread::thread_poolprivate
report_metrics()kcenon::thread::thread_pool
reset_metrics()kcenon::thread::thread_pool
set_enhanced_metrics_enabled(bool enabled)kcenon::thread::thread_pool
start(void) -> common::VoidResultkcenon::thread::thread_pool
start_pool_kcenon::thread::thread_poolprivate
stop(const bool &immediately_stop=false) -> common::VoidResultkcenon::thread::thread_pool
stop_unsafe() noexcept -> common::VoidResultkcenon::thread::thread_poolprivate
submit(F &&callable, const submit_options &opts={}) -> std::future< R >kcenon::thread::thread_pool
submit(std::vector< F > &&callables, const submit_options &opts={}) -> std::vector< std::future< R > >kcenon::thread::thread_pool
submit_wait_all(std::vector< F > &&callables, const submit_options &opts={}) -> std::vector< R >kcenon::thread::thread_pool
submit_wait_any(std::vector< F > &&callables, const submit_options &opts={}) -> common::Result< R >kcenon::thread::thread_pool
thread_pool(const std::string &thread_title="thread_pool", const thread_context &context=thread_context())kcenon::thread::thread_pool
thread_pool(const std::string &thread_title, std::shared_ptr< job_queue > custom_queue, const thread_context &context=thread_context())kcenon::thread::thread_pool
thread_pool(const std::string &thread_title, std::unique_ptr< pool_queue_adapter_interface > queue_adapter, const thread_context &context=thread_context())kcenon::thread::thread_pool
thread_title_kcenon::thread::thread_poolprivate
to_string(void) const -> std::stringkcenon::thread::thread_pool
topology_detected_kcenon::thread::numa_thread_poolmutableprivate
worker_policy_kcenon::thread::numa_thread_poolprivate
workers_kcenon::thread::thread_poolprivate
workers_mutex_kcenon::thread::thread_poolmutableprivate
~numa_thread_pool() override=defaultkcenon::thread::numa_thread_pool
~thread_pool(void)kcenon::thread::thread_poolvirtual