| add_policy(std::unique_ptr< pool_policy > policy) | kcenon::thread::thread_pool | |
| cached_topology_ | kcenon::thread::numa_thread_pool | mutableprivate |
| check_worker_health(bool restart_failed=true) -> std::size_t | kcenon::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_pool | private |
| diagnostics() -> diagnostics::thread_pool_diagnostics & | kcenon::thread::thread_pool | |
| diagnostics() const -> const diagnostics::thread_pool_diagnostics & | kcenon::thread::thread_pool | |
| diagnostics_ | kcenon::thread::thread_pool | mutableprivate |
| diagnostics_init_flag_ | kcenon::thread::thread_pool | mutableprivate |
| disable_numa_work_stealing() | kcenon::thread::numa_thread_pool | |
| enable_numa_work_stealing() | kcenon::thread::numa_thread_pool | |
| enhanced_metrics() const | kcenon::thread::thread_pool | |
| enhanced_metrics_snapshot() const | kcenon::thread::thread_pool | |
| enhanced_ws_config_ | kcenon::thread::numa_thread_pool | private |
| enqueue(std::unique_ptr< job > &&job) -> common::VoidResult | kcenon::thread::thread_pool | |
| enqueue(std::unique_ptr< thread_worker > &&worker) -> common::VoidResult | kcenon::thread::thread_pool | |
| enqueue_batch(std::vector< std::unique_ptr< job > > &&jobs) -> common::VoidResult | kcenon::thread::thread_pool | |
| enqueue_batch(std::vector< std::unique_ptr< thread_worker > > &&workers) -> common::VoidResult | kcenon::thread::thread_pool | |
| ensure_topology_detected() const | kcenon::thread::numa_thread_pool | private |
| find_policy(const std::string &name) -> T * | kcenon::thread::thread_pool | |
| get_active_worker_count() const -> std::size_t | kcenon::thread::thread_pool | |
| get_context(void) const -> const thread_context & | kcenon::thread::thread_pool | |
| get_idle_worker_count() const | kcenon::thread::thread_pool | |
| get_job_queue(void) -> std::shared_ptr< job_queue > | kcenon::thread::thread_pool | |
| get_pending_task_count() const -> std::size_t | kcenon::thread::thread_pool | |
| get_policies() const -> const std::vector< std::unique_ptr< pool_policy > > & | kcenon::thread::thread_pool | |
| get_pool_instance_id() const | kcenon::thread::thread_pool | |
| get_ptr(void) -> std::shared_ptr< thread_pool > | kcenon::thread::thread_pool | |
| is_enhanced_metrics_enabled() const | kcenon::thread::thread_pool | |
| is_numa_system() const | kcenon::thread::numa_thread_pool | |
| is_numa_work_stealing_enabled() const | kcenon::thread::numa_thread_pool | |
| is_running() const -> bool | kcenon::thread::thread_pool | |
| job_queue_ | kcenon::thread::thread_pool | private |
| metrics() const noexcept | kcenon::thread::thread_pool | |
| metrics_service_ | kcenon::thread::thread_pool | private |
| next_pool_instance_id_ | kcenon::thread::thread_pool | privatestatic |
| numa_thread_pool(const std::string &thread_title="numa_thread_pool", const thread_context &context=thread_context()) | kcenon::thread::numa_thread_pool | explicit |
| 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() const | kcenon::thread::numa_thread_pool | |
| numa_work_stealer_ | kcenon::thread::numa_thread_pool | private |
| numa_work_stealing_config() const | kcenon::thread::numa_thread_pool | |
| numa_work_stealing_stats() const | kcenon::thread::numa_thread_pool | |
| policies_ | kcenon::thread::thread_pool | private |
| policies_mutex_ | kcenon::thread::thread_pool | mutableprivate |
| pool_cancellation_token_ | kcenon::thread::thread_pool | private |
| pool_instance_id_ | kcenon::thread::thread_pool | private |
| queue_adapter_ | kcenon::thread::thread_pool | private |
| remove_policy(const std::string &name) -> bool | kcenon::thread::thread_pool | |
| remove_workers_internal(std::size_t count, std::size_t min_workers=1) -> common::VoidResult | kcenon::thread::thread_pool | private |
| 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::VoidResult | kcenon::thread::thread_pool | |
| start_pool_ | kcenon::thread::thread_pool | private |
| stop(const bool &immediately_stop=false) -> common::VoidResult | kcenon::thread::thread_pool | |
| stop_unsafe() noexcept -> common::VoidResult | kcenon::thread::thread_pool | private |
| 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_pool | private |
| to_string(void) const -> std::string | kcenon::thread::thread_pool | |
| topology_detected_ | kcenon::thread::numa_thread_pool | mutableprivate |
| worker_policy_ | kcenon::thread::numa_thread_pool | private |
| workers_ | kcenon::thread::thread_pool | private |
| workers_mutex_ | kcenon::thread::thread_pool | mutableprivate |
| ~numa_thread_pool() override=default | kcenon::thread::numa_thread_pool | |
| ~thread_pool(void) | kcenon::thread::thread_pool | virtual |