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

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

after_stop(void) -> common::VoidResultkcenon::thread::thread_baseinlineprotectedvirtual
before_start(void) -> common::VoidResultkcenon::thread::thread_baseinlineprotectedvirtual
consecutive_failures_kcenon::thread::thread_baseprivate
context_kcenon::thread::thread_workerprivate
current_job_kcenon::thread::thread_workerprivate
current_job_start_time_kcenon::thread::thread_workerprivate
diagnostics_kcenon::thread::thread_workerprivate
diagnostics_counter_kcenon::thread::thread_workerprivate
diagnostics_sample_rate_kcenon::thread::thread_workerprivate
do_work() -> common::VoidResult overridekcenon::thread::thread_workerprotectedvirtual
get_context(void) const -> const thread_context &kcenon::thread::thread_worker
get_current_job_info() const noexceptkcenon::thread::thread_worker
get_jobs_completed() const noexceptkcenon::thread::thread_worker
get_jobs_failed() const noexceptkcenon::thread::thread_worker
get_local_deque() noexceptkcenon::thread::thread_worker
get_policy() constkcenon::thread::thread_worker
get_state_since() const noexceptkcenon::thread::thread_worker
get_thread_id() const -> std::thread::idkcenon::thread::thread_base
get_thread_title() const -> std::stringkcenon::thread::thread_baseinline
get_total_busy_time() const noexceptkcenon::thread::thread_worker
get_total_idle_time() const noexceptkcenon::thread::thread_worker
get_wake_interval() const -> std::optional< std::chrono::milliseconds >kcenon::thread::thread_base
get_worker_id() constkcenon::thread::thread_worker
is_idle() const noexceptkcenon::thread::thread_worker
is_idle_kcenon::thread::thread_workerprivate
is_running() const -> boolkcenon::thread::thread_base
job_queue_kcenon::thread::thread_workerprivate
jobs_completed_kcenon::thread::thread_workerprivate
jobs_failed_kcenon::thread::thread_workerprivate
lifecycle_kcenon::thread::thread_baseprivate
local_deque_kcenon::thread::thread_workerprivate
max_consecutive_failureskcenon::thread::thread_baseprivatestatic
metrics_kcenon::thread::thread_workerprivate
next_worker_id_kcenon::thread::thread_workerprivatestatic
on_stop_requested() -> void overridekcenon::thread::thread_workerprotectedvirtual
operator=(const thread_base &)=deletekcenon::thread::thread_base
operator=(thread_base &&)=deletekcenon::thread::thread_base
policy_kcenon::thread::thread_workerprivate
queue_being_replaced_kcenon::thread::thread_workerprivate
queue_cv_kcenon::thread::thread_workerprivate
queue_mutex_kcenon::thread::thread_workermutableprivate
set_context(const thread_context &context) -> voidkcenon::thread::thread_worker
set_diagnostics(diagnostics::thread_pool_diagnostics *diag)kcenon::thread::thread_worker
set_diagnostics_sample_rate(std::uint32_t rate)kcenon::thread::thread_worker
set_job_queue(std::shared_ptr< job_queue > job_queue) -> voidkcenon::thread::thread_worker
set_metrics(std::shared_ptr< metrics::ThreadPoolMetrics > metrics)kcenon::thread::thread_worker
set_policy(const worker_policy &policy)kcenon::thread::thread_worker
set_steal_function(std::function< job *(std::size_t)> steal_fn)kcenon::thread::thread_worker
set_wake_interval(const std::optional< std::chrono::milliseconds > &wake_interval) -> voidkcenon::thread::thread_base
should_continue_work() const -> bool overridekcenon::thread::thread_workerprotectedvirtual
start(void) -> common::VoidResultkcenon::thread::thread_base
state_since_rep_kcenon::thread::thread_workerprivate
steal_function_kcenon::thread::thread_workerprivate
steal_victim_index_kcenon::thread::thread_workerprivate
stop(void) -> common::VoidResultkcenon::thread::thread_base
thread_base(const thread_base &)=deletekcenon::thread::thread_base
thread_base(thread_base &&)=deletekcenon::thread::thread_base
thread_base(const std::string &thread_title="thread_base")kcenon::thread::thread_base
thread_title_kcenon::thread::thread_baseprivate
thread_worker(const bool &use_time_tag=true, const thread_context &context=thread_context())kcenon::thread::thread_worker
to_string(void) const -> std::stringkcenon::thread::thread_basevirtual
total_busy_time_ns_kcenon::thread::thread_workerprivate
total_idle_time_ns_kcenon::thread::thread_workerprivate
try_get_job()kcenon::thread::thread_workerprivate
try_steal_work()kcenon::thread::thread_workerprivate
use_time_tag_kcenon::thread::thread_workerprivate
wake_interval_kcenon::thread::thread_baseprotected
wake_interval_mutex_kcenon::thread::thread_basemutableprivate
worker_cancellation_token_kcenon::thread::thread_workerprivate
worker_id_kcenon::thread::thread_workerprivate
worker_thread_kcenon::thread::thread_baseprivate
~thread_base(void)kcenon::thread::thread_basevirtual
~thread_worker(void)kcenon::thread::thread_workervirtual